JDBC

  

连接数据的步骤

注册驱动 (只做一次)

建立连接(Connection)

创建执行SQL的语句(Statement)

执行语句

处理执行结果(ResultSet)

释放资源

一、工具类

Class.forName(“com.mysql.jdbc.Driver”);

推荐这种方式，不会对具体的驱动类产生依赖。

DriverManager.registerDriver(com.mysql.jdbc.Driver);

会造成DriverManager中产生两个一样的驱动，并会对具体的驱动类产生依赖。

System.setProperty(“jdbc.drivers”, “driver1:driver2”);

虽然不会对具体的驱动类产生依赖；但注册不太方便，所以很少使用。

驱动类型(四种类型)

 

Connection conn = DriverManager.getConnection(url, user, password);

url格式：

JDBC:子协议:子名称//主机名:端口/数据库名？属性名=属性值&…

User,password可以用“属性名=属性值”方式告诉数据库；

其他参数如：useUnicode=true&characterEncoding=GBK。

public final class JdbcUtils {
 private static String url="jdbc:mysql://localhost:3306/jdbc";
 private static String user="root";
 private static String password="******";
 private JdbcUtils(){
  
 }
 static{
  try {
//   注册驱动
   Class.forName("com.mysql.jdbc.Driver");//推荐
//   DriverManager.registerDriver(new com.mysql.jdbc.Driver());//2
//   System.setProperty("jdbc.drivers", "com.mysql.jdbc.Driver[:...:...]");//注册方式3可以注册多个驱动用“：”分隔。
  } catch (ClassNotFoundException e) {
   throw new ExceptionInInitializerError(e);
  }
 }
 public static Connection getConnection() throws SQLException{
  return DriverManager.getConnection(url, user, password);
 }
 public static void free(ResultSet rs,Statement st,Connection conn){
  try {
   if(rs!=null)
    rs.close();
  } catch (SQLException e) {
   e.printStackTrace();
  }finally{
   try {
    if(st!=null)
    st.close();
   } catch (SQLException e) {
    e.printStackTrace();
   }finally{
    try {
     if(conn!=null)
     conn.close();
    } catch (SQLException e) {
     e.printStackTrace();
    }
   }
  }
 }
}

二、应用类

l释放ResultSet, Statement,Connection.

l数据库连接（Connection）是非常稀有的资源，用完后必须马上释放，如果Connection不能及时正确的关闭将导致系统宕机。Connection的使用原则是尽量晚创建，尽量早的释放。

 

Connection conn = null;

Statement st=null;

ResultSet rs = null;

try {

//获得Connection

//创建Statement

//处理查询结果ResultSet

} finally {

//释放资源ResultSet, Statement,Connection

}

 

public class Base {
 public static void main(String[] args) {
  template();
 }
 static void template(){
  Connection conn=null;
  Statement st=null;
  ResultSet rs=null;
  try {
//   建立连接
   conn=JdbcUtils.getConnection();
//   创建语句
   st=conn.createStatement();
//   执行语句
   rs=st.executeQuery("select * from user");
//   处理结果
   while(rs.next()){
    System.out.println(rs.getObject(1)+"\t"+rs.getObject(2)
      +"\t"+rs.getObject(3)+"\t"+rs.getObject(4));
   }
  } catch (Exception e) {
   e.printStackTrace();
  }finally{
//   释放资源
   JdbcUtils.free(rs, st, conn);
  }
 }
}

l在SQL中包含特殊字符或SQL的关键字(如：' or 1 or ')时Statement将出现不可预料的结果（出现异常或查询的结果不正确），可用PreparedStatement来解决。

lPreperedStatement（从Statement扩展而来）相对Statement的优点：

1.没有SQL注入的问题。

2.Statement会使数据库频繁编译SQL，可能造成数据库缓冲区溢出。

3.数据库和驱动可以对PreperedStatement进行优化（只有在相关联的数据库连接没有关闭的情况下有效）。

  

l详细信息见java.sql.Types

l几种特殊且比较常用的类型

1.DATA,TIME,TIMESTAMPà date,time,datetime

存：ps.setDate(i,d); ps.setTime(i,t); ps.setTimestamp(i, ts);

    取：rs.getDate(i); rs.getTime(i); rs.getTimestamp(i);

2.CLOB à text

  存：ps.setCharacterStream(index, reader, length);

         ps.setString(i, s);

  取：reader = rs. getCharacterStream(i);

         reader = rs.getClob(i).getCharacterStream();

         string = rs.getString(i);

3.BLOB à blob

 存：ps.setBinaryStream(i, inputStream, length);

       取：rs.getBinaryStream(i);

        rs.getBlob(i).getBinaryStream();

  

JavaEE三层架构简介

表示层 、业务逻辑层、数据访问层，三层之间用接口隔离。

定义domain对象User，定义存取用户的接口

用JDBC实现接口

用配置文件(properties)和反射实现与具体类的耦合

三、几个API
*　　PreparedStatement.getGeneratedKeys()
*　　PreparedStatement ps=connection.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);
*　　ps.executeUpdate();
*　　ResultSet rs=st.getGeneratedKeys();
*　　rs.getInt(1);

可用于判断是否操作成功。

public class OtherApi {
 public static void main(String[] args) {
  int id=create();
  System.out.println("i="+id);
 }
 static int create(){
  int id=0;
  Connection conn=null;
  PreparedStatement ps=null;
  ResultSet rs=null;
  try {
//   建立连接
//   conn=JdbcUtils.getConnection();
   conn=JdbcUtilsSing.getInstance().getConnection();//使用单例
   String sql="insert into user(name,birthday,money)values('name1 gk','1987-01-01',400)";
   ps=conn.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);//插入之后从JDBC驱动将主键返回给程序
   ps.executeUpdate();
   rs=ps.getGeneratedKeys();//返回rs是因为主键可能不同的类型，也可能是复合主键 。
   if(rs.next()){
    id=rs.getInt(1);
   }
   System.out.println("i="+id);
  } catch (Exception e) {
   e.printStackTrace();
  }finally{
//   释放资源
   JdbcUtils.free(rs, ps, conn);
  }
  return id;
 }
}

---------------------------------------------------------------------------------------------------------------

*　　批处理，可以幅提升大量增、删、改的速度。
*　　PreparedStatement.addBatch();
*　　PreparedStatement.executeBatch();

public class BatchTest {
 public static void main(String[] args) {
  long start=System.currentTimeMillis();
  /*for(int i=0;i<1000;i++){
   create(i);
  }*/
  createBatch();
  long end=System.currentTimeMillis();
  System.out.println("create:"+(end-start));
 }
 /*static void create(int i){
  int id=0;
  Connection conn=null;
  PreparedStatement ps=null;
  ResultSet rs=null;
  try {
//   建立连接
//   conn=JdbcUtils.getConnection();
   conn=JdbcUtilsSing.getInstance().getConnection();//使用单例
   String sql="insert into user(name,birthday,money)values(?,?,?)";
   ps=conn.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);//插入之后从JDBC驱动将主键返回给程序
   ps.setString(1, "batch name"+i);
   ps.setDate(2, new Date(System.currentTimeMillis()));
   ps.setFloat(3, 100f+i);
   ps.executeUpdate();
   rs=ps.getGeneratedKeys();//返回rs是因为主键可能不同的类型，也可能是复合主键 。
   
   if(rs.next()){
    id=rs.getInt(1);
   }
   System.out.println("i="+id);
  } catch (Exception e) {
   e.printStackTrace();
  }finally{
//   释放资源
   JdbcUtils.free(rs, ps, conn);
  }
//  return id;
 }*/
 static void createBatch(){
  Connection conn=null;
  PreparedStatement ps=null;
  ResultSet rs=null;
  try {
//   建立连接
//   conn=JdbcUtils.getConnection();
   conn=JdbcUtilsSing.getInstance().getConnection();//使用单例
   String sql="insert into user(name,birthday,money)values(?,?,?)";
   ps=conn.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);//插入之后从JDBC驱动将主键返回给程序
   for(int i=0;i<1000;i++){
    ps.setString(1, "batch name"+i);
    ps.setDate(2, new Date(System.currentTimeMillis()));
    ps.setFloat(3, 100f+i);
    ps.addBatch();
   }
   int[] is=ps.executeBatch();
  } catch (Exception e) {
   e.printStackTrace();
  }finally{
//   释放资源
   JdbcUtils.free(rs, ps, conn);
  }
 }
}

-----------------------------------------------------------------------------------------------------------------------------------

*　　可滚动的结果集
*　　Statement st=connection.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATEBLE);
*　　ResultSet rs=st.executeQuery(sql);
*　　rs.beforeFirst();rs.afterLast();rs.first();rs.isFirst();rs.last();rs.isLast();rs.absolute(9);rs.moveToInsertRow();
public class ScrollTest {
 public static void main(String[] args) {
  scroll();
 }

 static void scroll() {
  Connection conn = null;
  PreparedStatement ps = null;
  ResultSet rs = null;
  try {
   // 建立连接
   // conn=JdbcUtils.getConnection();
   conn = JdbcUtilsSing.getInstance().getConnection();// 使用单例
   String sql = "select id,name,birthday,money from user";
   ps = conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_SENSITIVE,
     ResultSet.CONCUR_READ_ONLY);
   rs = ps.executeQuery();
//   rs.afterLast();//到最后一行的后一行，此时要读到记录必须前移
//   rs.beforeFirst();//到第一行的前面
//   boolean b=rs.first();//判断当前是不是第一行
//   boolean b=rs.last();//判断当前是不是最后一行
   while (rs.next()) {
    // System.out.println(rs.getObject(1)+"\t"+rs.getObject(2)+"\t"+rs.getObject(3)+"\t"+rs.getObject(4));
    System.out.println(rs.getInt("id") + "\t"
      + rs.getString("name") + "\t" + rs.getDate("birthday")
      + "\t" + rs.getFloat("money"));
   }
   System.out.println("---------------------------------------");
   rs.absolute(5);//定位到第五行，可用于分页,要全部查出再分页，效率低
   int i=0;
   while(rs.previous()&&i++<3) {
    System.out.println(rs.getInt("id") + "\t"
      + rs.getString("name") + "\t" + rs.getDate("birthday")
      + "\t" + rs.getFloat("money"));
   }
  } catch (Exception e) {
   e.printStackTrace();
  } finally {
   // 释放资源
   JdbcUtils.free(rs, ps, conn);
  }
 }
}

------------------------------------------------------------------------------------------------------------

*　　可更新的结果集
*　　conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATEBLE);
*　　rs.updateString("col name","new value");
*　　rs.updateRow();

 static void read(){
  Connection conn=null;
  PreparedStatement ps=null;
  ResultSet rs=null;
  try {
//   建立连接
//   conn=JdbcUtils.getConnection();
   conn=JdbcUtilsSing.getInstance().getConnection();//使用单例
   String sql="select id,name,birthday,money from user where id>7";
   ps=conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
   rs=ps.executeQuery();
   while(rs.next()){
//    System.out.println(rs.getObject(1)+"\t"+rs.getObject(2)+"\t"+rs.getObject(3)+"\t"+rs.getObject(4));
    System.out.println(rs.getInt("id")+"\t"
      +rs.getString("name")+"\t"
      +rs.getDate("birthday")+"\t"
      +rs.getFloat("money"));
    String name=rs.getString("name");
    if("batch name2".equals(name)){
     rs.updateFloat("money", 200f);
     rs.updateRow();
    }
   }
  } catch (Exception e) {
   e.printStackTrace();
  }finally{
//   释放资源
   JdbcUtils.free(rs, ps, conn);
  }
 }

四、数据库源信息

DatabaseMetaData meta = connection.getMetaData();

通过DatabaseMetaData可以获得数据库相关的信息如：数据库版本、数据库名、数据库厂商信息、是否支持事务、是否支持某种事务隔离级别，是否支持滚动结果集等。

public class DBMD {
 public static void main(String[] args) throws SQLException {
  Connection conn=JdbcUtils.getConnection();
  DatabaseMetaData dbmd=conn.getMetaData();//返回数据库的源信息
  System.out.println("db name:"+dbmd.getDatabaseProductName());//数据库名
  System.out.println("tx:"+dbmd.supportsTransactions());//是否支持事务
  conn.close();
 }
}

----------------------------------------------------------------------------------------------------------------

ParameterMetaData pmd = preparedStatement.getParameterMetaData();

通过 ParameterMetaData可以获得参数信息。

public class ParameterMetaTest {
 public static void main(String[] args) {
  Object[] params = new Object[] { "lisi",new Date(System.currentTimeMillis()), 100f };
  read("select * from user where name=? and birthday<? and money>?",params);
 }

 static void read(String sql, Object[] params) {
  Connection conn = null;
  PreparedStatement ps = null;
  ResultSet rs = null;
  try {
   // 建立连接
   // conn=JdbcUtils.getConnection();
   conn = JdbcUtilsSing.getInstance().getConnection();// 使用单例
   ps = conn.prepareStatement(sql);
   // ParameterMetaData pmd = ps.getParameterMetaData();
   // int count = pmd.getParameterCount();
   // for (int i = 1; i <= count; i++) {
   // ps.setObject(i, params[i - 1]);
   // }
   for (int i = 1; i <= params.length; i++) {
    ps.setObject(i, params[i - 1]);
   }
   // for (int i = 1; i <= count; i++) {
   // System.out.print(pmd.getParameterClassName(i)+"\t");
   // System.out.print(pmd.getParameterType(i)+"\t");
   // System.out.println(pmd.getParameterTypeName(i));
   // }
   rs = ps.executeQuery();
   while (rs.next()) {
    System.out.println(rs.getInt("id") + "\t" + rs.getString("name") + "\t" + rs.getDate("birthday")+ "\t" + rs.getFloat("money"));
   }
  } catch (Exception e) {
   e.printStackTrace();
  } finally {
   JdbcUtils.free(rs, ps, conn);
  }
 }
}

----------------------------------------------------------------------------------------------------------------------

ResultSetMetaData meta = rs.getMetaData();

通过ResultSetMetaData可以获得结果有几列、各列名、各列别名、各列类型等。

可以将ResultSet放入Map(key:列名 value:列值)。

用反射ResultSetMetaData将查询结果读入对象中（简单的O/RMapping）

1)让SQL语句中列别名和要读入的对象属性名一样；

2)通过ResultSetMetaData获得结果列数和列别名；

3)通过反射将对象的所有setXxx方法找到;

4)将3）找到的方法setXxx和2）找到的列别名进行匹配（即方法中的xxx于列别名相等）；

5)由上一步找到的方法和列别名对应关系进行赋值

Method.invoke(obj, rs.getObject(columnAliasName));

public class ResultSetMetaDataTest {
 public static void main(String[] args) {
  List<Map<String,Object>> datas=read("select * from user where id<5");
  System.out.println(datas);
 }
 static List<Map<String, Object>> read(String sql) {
  Connection conn = null;
  PreparedStatement ps = null;
  ResultSet rs = null;
  List<Map<String,Object>> datas=null;
  Map<String,Object> data=null;
  try {
   // 建立连接
   // conn=JdbcUtils.getConnection();
   conn = JdbcUtilsSing.getInstance().getConnection();// 使用单例
   ps = conn.prepareStatement(sql);
   rs = ps.executeQuery();
   ResultSetMetaData rsmd = rs.getMetaData();
   int count = rsmd.getColumnCount();
   String[] colNames=new String[count];
    for (int i = 1; i <= count; i++) {
//    System.out.print(rsmd.getColumnClassName(i) + "\t");
//    System.out.print(rsmd.getColumnName(i) + "\t");
//    System.out.println(rsmd.getColumnLabel(i) + "\t");
    colNames[i-1]=rsmd.getColumnLabel(i);//如果设置了别名使用，没有的话Name与Label一样
   }
    datas=new ArrayList<Map<String,Object>>();
   while (rs.next()) {
    data=new HashMap<String,Object>();
    for(int i=0;i<colNames.length;i++){
     data.put(colNames[i], rs.getObject(colNames[i]));
    }
    datas.add(data);
   }
  } catch (Exception e) {
   e.printStackTrace();
  } finally {
   JdbcUtils.free(rs, ps, conn);
  }
  return datas;
 }
}