JDBC 进阶

游标操作方式-分批查询

游标提供一种客户端读取部分服务器端结果集的机制。
当 sql 语句的匹配条件太弱时，sql 结果会返回大量的数据，就有可能导出出现内存溢出。所以就出现了将结果分批处理的方式；

流程：

1.在配置 JDBC URL 时，在最后加上参数： useCursorFetch=true 开启游标属性

static String DB_URL = "jdbc:mysql://localhost:3306/test?useCursorFetch=true"

2.创建 preparedSatement 对象，在使用 prepareStatement 方法创建对象时，预编译 sql 语句。

conn.prepareStatement(sql,游标类型,能否更新记录);
游标类型：
ResultSet.TYPE_FORWORD_ONLY:只进游标
ResultSet.TYPE_SCROLL_INSENSITIVE:可滚动。但是不受其他用户对数据库更改的影响。
ResultSet.TYPE_SCROLL_SENSITIVE:可滚动。当其他用户更改数据库时这个记录也会改变。
能否更新记录：
ResultSet.CONCUR_READ_ONLY,只读
ResultSet.CONCUR_UPDATABLE,可更新

3.使用 setFetchSize 方法，设置分批处理的结果数

4.通过 setString 方法传入条件参数，第一个参数表示 参数位置，第二个参数为条件值

preparedSatement 可以写动态参数化查询
preparedSatement 可以预编译 sql 语句
preparedSatement 可以防止SQL注入式攻击

代码实例：

import java.sql.*;

public class Main {
    static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
    static String DB_URL = "jdbc:mysql://localhost:3306/test?useSSL=true";
    static final String USER = "root";
    static final String PASSWORD = "admin";

    public static void main(String[] args) throws ClassNotFoundException{
        Connection conn = null;
        Statement statement = null;
        PreparedStatement preparedStatement = null;
        ResultSet rs = null;
//      1. 装载数据库驱动程序；
        Class.forName(JDBC_DRIVER);
//      2. 通过JDBC建立数据库连接；
        try {
            //在 url 中 开启 游标属性
            DB_URL = DB_URL + "&useCursorFetch=true";
            conn = DriverManager.getConnection(DB_URL,USER,PASSWORD);
//      3.访问数据库，执行SQL语句；
//            statement = conn.createStatement();
//            rs = statement.executeQuery("select name from test.user ");
//          对 preparedStatement 的 sql 语句进行预编译, ？ 表示参数
            preparedStatement = conn.prepareStatement("select  * from test.ipdata where id=? and startip = ?");
//            通过 preparedStatement 使用游标 进行分批查询语句
            preparedStatement.setFetchSize(1);
//            通过setInt 或者 setString 将，预编译的 sql 语句中的 条件参数传递进去
            preparedStatement.setInt(1,13);
            preparedStatement.setString(2,"16844800");
            rs = preparedStatement.executeQuery();
//      4.获得执行结果
            while(rs.next()) {
                System.out.println("Hello " + rs.getString("country"));
            }



        } catch (SQLException e) {
//            异常处理
            e.printStackTrace();
        } finally {
            // 5. 断开数据库连接，清理环境
            try {
                if(conn != null) {
                    conn.close();
                }
                if(statement != null) {
                    statement.close();
                }
                if(rs != null) {
                    rs.close();
                }
            } catch (SQLException e) {
                // pass
            }

        }
    }
}

大对象读取-流方式

当读取大对象时，有可能出现对象内容太大，内存放不下，从而出现的内存溢出问题。

主要涉及方法 ResultSet.getBinaryStream() 方法。

流程

  1. 通过对 ResultSet 对象使用 getBinaryStream() 获取流对象。
  2. 每次读取流对象中的一行内容输出到外部文件中
  3. 重复2 步骤，直至读取完流对象内容。
public static void main(String[] args) throws ClassNotFoundException {
    Connection conn = null;
    PreparedStatement preparedStatement = null;
    ResultSet resultSet = null;

    Class.forName(JDBC_DRIVER);
    try {
        conn = DriverManager.getConnection(JDBC_URL, USER, PASSWORD);
//            创建 preparedStatement 对象
        preparedStatement = conn.prepareStatement("select * from blog where id = ?");
        preparedStatement.setInt(1, 1);
//            执行 sql
        resultSet = preparedStatement.executeQuery();
        while (resultSet.next()) {
//                获取对象流
            InputStream in = resultSet.getBinaryStream("context");
//                将对象流写入文件
            File f = new File(FILE_URL);
            OutputStream out = new FileOutputStream(f);
            int temp = 0;
                while ((temp = in.read()) != -1) {//边读边写
                    out.write(temp);
                }
                in.close();
                out.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                if (conn != null)
                    conn.close();
                if (preparedStatement != null)
                    preparedStatement.close();
                if (resultSet != null)
                    resultSet.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
    }
}

一条语句多条执行- sql 的批处理

流程：

  1. statement 对象使用 addBatch() 方法添加 sql 语句
  2. statement 对象使用 executeBatch() 方法执行所有添加的 sql 语句
  3. statement 对象使用 clearBatch() 方法清空已执行的 sql 语句
public class HelloBatch {
    static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
    static String DB_URL = "jdbc:mysql://localhost:3306/test?useSSL=true";
    static final String USER = "root";
    static final String PASSWORD = "admin";

    static void insertUsers(Set<String> users) throws ClassNotFoundException{
        Connection conn = null;
        Statement statement = null;
        ResultSet rs = null;
//      1. 装载数据库驱动程序；
        Class.forName(JDBC_DRIVER);
//      2. 通过JDBC建立数据库连接；
        try {
            conn = DriverManager.getConnection(DB_URL,USER,PASSWORD);
//      3.访问数据库，执行SQL语句；
            statement = conn.createStatement();
//            添加 sql 语句到 Batch
            for (String user : users) {
                statement.addBatch("insert into user(name) values ('" + user + "')");
                System.out.println("insert into user(name) values (" + user + ")");
            }
//            批执行 sql 语句
            statement.executeBatch();
//            清空已执行语句
            statement.clearBatch();
        } catch (SQLException e) {
//            异常处理
            e.printStackTrace();
        } finally {
            // 5. 断开数据库连接，清理环境
            try {
                if(conn != null) {
                    conn.close();
                }
                if(statement != null) {
                    statement.close();
                }
                if(rs != null) {
                    rs.close();
                }
            } catch (SQLException e) {
                // pass
            }

        }
    }

    public static void main(String[] args) throws ClassNotFoundException {
        Set<String> users = new HashSet<>();
        users.add("GuoYi");
        users.add("GuoEi");
        users.add("GuoSi");

        insertUsers(users);
    }

}

jdbc 设置字符集

在 JDBC URL 中添加参数 characterEncoding=utf8

数据库设置字符集

查看数据库各级字符集.png
『项目地址』：https://github.com/wengfe/JAVA/tree/master/HelloJDBC/src
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 203,324评论 5赞 476
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 85,303评论 2赞 381
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 150,192评论 0赞 337
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 54,555评论 1赞 273
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 63,569评论 5赞 365
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,566评论 1赞 281
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 37,927评论 3赞 395
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,583评论 0赞 257
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 40,827评论 1赞 297
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,590评论 2赞 320
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,669评论 1赞 329
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,365评论 4赞 318
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 38,941评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,928评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,159评论 1赞 259
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 42,880评论 2赞 349
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,399评论 2赞 342