1. JDBC的介绍

  jdbc为java开发者使用数据库提供了统一的编程接口，它由一组java类和接口组成。   访问数据库的流程   在连接这一过程中，一般初学者是MySQL和java在同一个电脑上，建立socket连接。   常用接口：- 一般针对java开发使用 Driver接口就行 ，- 在连接数据库时，需要装载特定厂商的数据驱动程序：    MySQL：Class.forname(‘com.mysql.jdbc.Driver’);    Oracle：Class.forname(‘oracle.jdbc.driver.OracleDriver’);

2.JDBC重要的API（以MySQL为例）

建立连接：

 @Test public void getConnect(){ try { //加载驱动 Class.forName("com.mysql.jdbc.Driver"); //获取连接 String url="jdbc:mysql://localhost:3306/library"; String user="root"; String password="123456"; Connection cOnnection= DriverManager.getConnection(url, user, password); } catch (Exception e) { e.printStackTrace(); } }

Statement 注意：这里Statement- 用于执行静态SQL语句并返回它所生成的结果对象，这里的Statement有三个类：   - Statement由createStatement创建，用于发送简单的SQL语句。（不带参）   - PreparedStatement：继承自Statement父类，由preparedStatement创建，用于发送含有一个或多个输入参数的SQL语句。PreparedStatement对象比Statement对象效率更高，并且可以防止SQL注入。   - CallableStatement:继承自PreparedStatement。由方法prePareCall创建，用于调用存储。 常用的Statement的方法有：   - execute（）：运行语句，返回是否有结果集   - executeQuery（）：运行select语句，返回ResultSet结果集   - executeUpdate（）：运行insert/update/delete操作，返回影响的行数 相关代码：

@Test public void testStatement() throws SQLException { //创建Statement Statement statement = connection.createStatement(); String sql="select * from book"; boolean isNull= statement.execute(sql); //创建PreparedStatement sql="select * from book"; PreparedStatement preparedStatement1 = connection.prepareStatement(sql); ResultSet resultSet = preparedStatement1.executeQuery(); //PreparedStatement防止SQL注入,这里的?表示占位符 sql="select * from book where bid = ?"; PreparedStatement preparedStatement2 = connection.prepareStatement(sql); preparedStatement2.setObject(1,2); preparedStatement2.executeQuery(); }

ResultSet 描述：ResultSet 主要是由executeQuery（）方法执行返回 读取数据的流程图： 例：

 @Test public void testStatement() throws SQLException { //创建PreparedStatement String sql = "select * from book"; PreparedStatement preparedStatement1 = connection.prepareStatement(sql); ResultSet resultSet = preparedStatement1.executeQuery(); while(resultSet.next()){ //表示是否还有下一个 System.out.println("bid"+resultSet.getInt(1)); System.out.println("bname"+resultSet.getString(2)); System.out.println("author"+resultSet.getString(3)); } }

jdbc的批处理

  • 注意：如果使用大量的批处理时，建议使用statement，因为preparedstatement的预编译空间有限，当数据量特别大时，会发生异常。 例：
 @Test public void testStatement() throws SQLException { //创建Statement Statement statement = connection.createStatement(); for (int i = 0; i < 50; i++) { //获得当前的系统时间 long timestamp = System.currentTimeMillis(); String sql = "insert into t_date(t_time,t_id) values(" + timestamp + "," + i + ")"; //为批处理添加执行的SQL语句 statement.addBatch(sql); } //执行批处理 statement.executeBatch(); //提交事务 connection.commit(); }

jdbc的事务

 @Test public void testTransaction() { //取消自动提交 try { connection.setAutoCommit(false); //插入一条DML语句 PreparedStatement stetm1 = connection.prepareStatement("insert into book values(1001,'朝花夕拾','鲁迅')"); stetm1.execute(); //插入另条DML语句 PreparedStatement stetm2 = connection.prepareStatement("insert into book values(1001,'海贼王','尾田一郎')"); stetm2.execute(); //提交 connection.commit(); } catch (SQLException e) { try { //失败后自动回滚 connection.rollback(); } catch (SQLException e1) { e1.printStackTrace(); } e.printStackTrace(); } }

CLOB操作： 用于存储大量的文本数据，大字段的操作常常以流的方式处理。而非一般的字段一次读取即可。 

//代码实现： public class ReadAndWriteClob { public static void main(String[] args) { //获取数据库连接 try { Class.forName("com.mysql.jdbc.Driver"); Connection cOnn= DriverManager.getConnection("jdbc:mysql://localhost:3306/library", "root", "123456"); //clob字段插入 //表：user_info //字段：name varchar , introduce clob String sql = "insert into user_info values(?,?)"; PreparedStatement prepared1 = conn.prepareStatement(sql); //插入数据 prepared1.setObject(1, "user1"); //设置插入文本对象，第二个参数是一个输入流，直接读取文件 prepared1.setClob(2,new BufferedReader( new InputStreamReader( new FileInputStream("src/a.txt")))); prepared1.execute(); //clob字段读取 sql="select * from user_info"; PreparedStatement prepared2 =conn.prepareStatement(sql); ResultSet resultSet = prepared2.executeQuery(); while(resultSet.next()){ Clob introduce = resultSet.getClob("introduce"); Reader characterStream = introduce.getCharacterStream(); int temp=0; while((temp=characterStream.read())!=-1){ System.out.print((char)temp); } } } catch (Exception e) { e.printStackTrace(); } } }

BLOB操作： 用于存储大量的二进制数据，二进制可以存入任何类型的文件（音频、视频等等..）。 

//代码实现 public class ReadAndWriteClob { public static void main(String[] args) { //获取数据库连接 try { Class.forName("com.mysql.jdbc.Driver"); Connection cOnn= DriverManager.getConnection("jdbc:mysql://localhost:3306/library", "root", "123456"); //clob字段插入 //表：user_info //字段：name varchar , headblob String sql = "insert into user_info values(?,?)"; PreparedStatement prepared1 = conn.prepareStatement(sql); //插入数据 prepared1.setObject(1, "user1"); //设置插入图片对象，第二个参数是一个基本输入流 prepared1.setBlob(2,new FileInputStream("src/a.jpg")); prepared1.execute(); //clob字段读取 sql="select * from user_info"; PreparedStatement prepared2 =conn.prepareStatement(sql); ResultSet resultSet = prepared2.executeQuery(); while(resultSet.next()){ Blob head= resultSet.getBlob("headImg"); //获取的是基本的流， InputStream binaryStream = headImg.getBinaryStream(); int len=0; byte flush []=new byte [1025]; OutputStream os=new FileOutputStream(new File("d:\\c.jpg")); while((len=binaryStream.read(flush))!=-1){ os.write(flush,0,len); os.flush(); } os.close(); binaryStream.close(); } } catch (Exception e) { e.printStackTrace(); } } }

对jdbc的封装 这里需要加载配置文件： 代码实现：

public class jdbcUtils { private static Properties pro; static { try { pro = new Properties(); InputStream in = jdbcUtils.class.getClassLoader().getResourceAsStream("dbproperties.properties"); pro.load(in); Class.forName(pro.getProperty("driver")); } catch (Exception e) { e.printStackTrace(); } } //建立与数据库的连接 public static Connection getMySQLConn(){ try { return DriverManager.getConnection(pro.getProperty("url"), pro.getProperty("user"), pro.getProperty("password")); } catch (SQLException e) { e.printStackTrace(); } return null; } /** * 关闭顺序：resultSet --preparStatement -- Connection * 在关闭时，不能讲这三者的close()写在同一个try{}catch{}中 */ public static void close(Statement stem,ResultSet rs,Connection conn){ if(rs!=null){ try { rs.close(); } catch (SQLException e) { e.printStackTrace(); } } if(stem!=null){ try { stem.close(); } catch (SQLException e) { e.printStackTrace(); } } if(conn!=null){ try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } } }