jdbc-mysql基础 PreparedStatement addBatch 批处理

礼悟：
　　 公恒学思合行悟，尊师重道存感恩。叶见寻根三返一，江河湖海同一体。
虚怀若谷良心主，愿行无悔给最苦。读书锻炼养身心，诚劝且行且珍惜。




特制的异常类

package com.jizuiku;

/**
* 这个类很重要，即完成了抛异常的动作、通过编译，又可以使数据逻辑层的接口保持简洁。
*
* @author 博客园-给最苦
* @version V17.11.08
*/
public class DaoException extends RuntimeException {

/**
*
*/
private static final long serialVersionUID = 1L;

public DaoException() {
// TODO Auto-generated constructor stub
}

public DaoException(String message) {
super(message);
// TODO Auto-generated constructor stub
}

public DaoException(Throwable cause) {
super(cause);
// TODO Auto-generated constructor stub
}

public DaoException(String message, Throwable cause) {
super(message, cause);
// TODO Auto-generated constructor stub
}

public DaoException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
super(message, cause, enableSuppression, writableStackTrace);
// TODO Auto-generated constructor stub
}

}

JDBCUtils类

package com.jizuiku;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

/**
*
*
* @author 给最苦
* @version V17.11.07
*/
public final class JDBCUtils {

/**
* url格式 -> jdbc:子协议:子名称//主机名:端口号/数据库的名字?属性名=属性值&属性名=属性值
* configString变量中有多个参数，需要深入地去研究它们的具体含义
*/
private static String configString = "?useUnicode=true&characterEncoding=utf8&useSSL=true";
private static String url = "jdbc:mysql://localhost:3306/jdbcforjava" + configString;
// 本地的mysql数据库(无子名称) 端口号3306 数据库jdbcforjava

private static String user = "root";
private static String password = "";

// 工具类，直接使用，不可生对象
private JDBCUtils() {
}

// 注册驱动,这里应用的是static代码块只执行一次的特点
static {
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
throw new ExceptionInInitializerError(e);
}
}

/**
* 获取与指定数据库的链接
*
*/
public static Connection getConnection() throws SQLException {
return DriverManager.getConnection(url, user, password);
}

/**
* 释放三种资源ResultSet PreparedStatement Connection
*
*/
public static void free(ResultSet rs, PreparedStatement ps, Connection con) {
try {
if (rs != null) {
rs.close();
}
} catch (SQLException e) {
// TODO Auto-generated catch block
throw new DaoException(e.getMessage(), e);
} finally {
try {
if (ps != null) {
ps.close();
}
} catch (SQLException e) {
// TODO Auto-generated catch block
throw new DaoException(e.getMessage(), e);
} finally {
try {
if (con != null) {
con.close();
}
} catch (SQLException e) {
// TODO Auto-generated catch block
throw new DaoException(e.getMessage(), e);
}
}
}
}
}

未执行代码时，数据库中的内容



测试类

package com.jizuiku;

import java.math.BigDecimal;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

/**
*
*
* @author 博客园-给最苦
* @version V17.11.09
*/
public class Demo {

public static void main(String[] args) {
test();
}

public static void test() {
Connection con = null;
PreparedStatement ps = null;
ResultSet rs = null;

try {

// 注册驱动并建立连接
con = JDBCUtils.getConnection();

// 创建语句 并 对sql语句进行一些预处理;注明要返回主键
String sql = "insert into book(name,quantity,time,price) values(?,?,?,?)";
ps = con.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);

/*
* 向sql语句中传入值 并 生成1000条插入语句
* 当数据量太大时，也会拆成多个小包进行传递
* 针对不同的数据库，需要测试一个包 存多少条sql语句是适合的
*/
for (int i = 0; i < 1000; ++i) {

ps.setString(1, "心经");
ps.setInt(2, i);
ps.setDate(3, new java.sql.Date(new java.util.Date().getTime()));
ps.setBigDecimal(4, new BigDecimal(Double.toString(87.56)));

// 装填语句
ps.addBatch();

}

// 需要等待几秒钟
// 批处理的效率 很高吗？ 需要具体问题具体分析。
ps.executeBatch();
rs = ps.getGeneratedKeys();

while(rs.next()){
System.out.println(rs.getObject(1));
}

} catch (SQLException e) {
throw new DaoException(e);

} finally {
// 释放资源
JDBCUtils.free(rs, ps, con);

}
}
}

控制台输出的结果



数据库中的内容变化



　　注：操作数据库要谨慎小心，给最苦 这里的代码 看看就好。

学习资源：itcast和itheima视频库。如果您有公开的资源，可以分享给我的话，用您的资源学习也可以。
博文是观看视频后，融入思考写成的。博文好，是老师讲得好。博文坏，是 给最苦 没认真。