package com.gxa.edu; import javax.swing.JFrame; import javax.swing.JButton; import javax.swing.ImageIcon; import javax.swing.JLabel; import javax.swing.JTextArea; import javax.swing.JTextField; import javax.swing.JPasswordField; import javax.swing.JComboBox; import javax.swing.JRadioButton; import javax.swing.ButtonGroup; import java.awt.FlowLayout; import java.awt.Color; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; /** * @author Administrator * 国信安百杰高端Java培训 */ public class Test extends JFrame { public final String url = "jdbc:sqlserver://127.0.0.1:1433;DatabaseName=stu"; public final String username = "sa"; public final String password = "123456"; public final String classdriver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; public Connection conn; public Statement stmt; public ResultSet rs; public Test() { try { Class.forName(classdriver); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 利用JDBC来创建表 */ public void createTable() { String sql = "create table batch (a1 varchar(10),a2 varchar(500))"; try { conn = DriverManager.getConnection(url, username, password); stmt = conn.createStatement(); boolean f = stmt.execute(sql); System.out.println(f); } catch (SQLException e) { e.printStackTrace(); } } /** * 对数据库进行批量插入数据操作 * 执行次数100万 */ public void insertBatch() { //思路:将100万条数据分成n等份,1等份为1000条数据 //如何实现? //1、必须将Connection接口的自动提交方式改为手动 //2、利用Statement接口中的如下三个方法:addBatch、clearBath、executeBatch try { conn = DriverManager.getConnection(url, username, password); conn.setAutoCommit(false); stmt = conn.createStatement(); for (int i = 0; i < 1000000; i++) { String sql = "insert into batch values ('"+i+"', '第"+i+"条数据')"; //利用addBatch方法将SQL语句加入到stmt对象中 stmt.addBatch(sql); if (i % 1000 == 0 && i != 0) { //利用executeBatch方法执行1000条SQL语句 stmt.executeBatch(); stmt.clearBatch(); conn.commit(); } } stmt.executeBatch(); stmt.clearBatch(); conn.commit(); close(); //关闭资源 } catch (SQLException e) { e.printStackTrace(); } } public void close() { try { if (rs != null) rs.close(); if (stmt != null) stmt.close(); if (conn != null) conn.close(); } catch (SQLException e) { e.printStackTrace(); } } /** * @param args */ public static void main(String[] args) { // TODO Auto-generated method stub Test t = new Test(); //t.createTable(); t.insertBatch(); } }
下面是另外一篇:
http://hi.baidu.com/a393060727/blog/item/152068f4e6d17adef2d38554.html
不过下面少了stmt.clearBatch();这样的操作,而且如果bath 与 PrepareStatement一起使用的话交果会更好。
jdbc连接数据库:首先要找到相应的数据库驱动,指定连接的数据库
加载驱动:Class.forName(驱动名);
获得连接:Connection con = DriverManager.getConnection("数据库连接","用户名","密码");
执行SQL语句:Statement && PreparedStatement
写法:Statement stmt = con.createStatement(); 或PreparedStatement pstm = con.preparedStatement(sql);
执行查询:返回结果ResultSet集 stmt.executeQuery(sql语句);
执行增删改:返回影响行数 int count = stmt.executeUpdate(sql语句);
获得游标:rs.next();判断是否有下一个游标 返回一个boolean
获得结果类型:rs.get类型名(字段名)
操作完成,关闭顺序,后打开的先关闭。
调用存储过程:CallableStatement csmt =con.prepareCall("{call p(?,?,?,?)}");
创建一个调用存储过程的对象,调用存储过程,存储过程名字叫p,他有4个参数
csmt.registerOutParament(3,Types.INTEGER);
csmt.registerOutParament(4,Types.INTEGER);//设置输出数,并设置类型
csmt.setInt(1,3);
csmt.setInt(2,5);
csmt.setInt(4,7);//设置参数的值
csmt.execute();//执行操作
csmt.getInt(3);
csmt.getInt(4);//获取存储过程的输出值
csmt.close();//关闭执行结果
批处理Batch
用:
Statement stmt = con.createStatement();
stmt.addButch(SQL语句);
stmt.addButch(SQL语句);
stmt.addButch(SQL语句);
stmt.addButch(SQL语句);
stmt.executeButh();
或:
PreparedStatement pstm = null;
pstm = con.prepareStatement("insert into aa values(?,?,?)");
pstm.setInt(1, 12);
pstm.setString(2,"李五A");
pstm.setString(3, "中文A");
pstm.addBatch();
pstm.setInt(1, 22);
pstm.setString(2,"李五B");
pstm.setString(3, "中文B");
pstm.addBatch();
pstm.setInt(1, 32);
pstm.setString(2,"李五C");
pstm.setString(3, "中文C");
pstm.addBatch();
//批量执行上面3条语句. 一口吞了,很爽
int [] counts = statement.executeBatch();
//Commit it 咽下去,到肚子(DB)里面
connection.commit();