JDBC基础

2018-08-14 本文已影响0人冰与河豚鱼

Driver ：接口，定义了各个驱动程序都必须要实现的功能，是驱动程序的抽象，通过操作java接口，就可以实现对各个驱动的操作

DriverManger：是Driver的管理类，用户通过Class.forName()的方式就可以向DriverManger注册一个驱动程序，然后通过DriverManger的getConnection(DB_URL,USER,PASS)方法调用该驱动程序建立到后端数据库的物理连接。

DB_URL：jdbc:mysql://127.0.0.1:3306/mysql是后端数据库的唯一标识符，应用程序通过该标识符即可唯一确定后端的某个数据库实例。它是由三部分组成：jdbc(协议):mysql(子协议)：//127.0.0.1(主机):3306(数据库端口)/mysql(数据库)(子名称)
常用DB_URL格式：
MySQL：Jdbc:mysql://<ip>:<port>/database
ORACLE：jdbc:oracle:thin:@<ip>:<port>:database
SQL server：jdbc:microsoft:sqlserver://<ip>:<port>;DatabaseName=database

Connection：代表了java应用程序对后端数据库的一条物理连接，基于这条连接可以执行一些sql语句。Connection对象->Statement方法->ResultSet对象

Statement方法创建了一个Statement对象，是sql的容器，在这容器中可以进行select,delete,update等操作，容器中盛载sql语句，通过statement对象的executeQuery()方法可以执行数据库查询得到查询结果的集合，这个集合是用Resultet对象/Int值来表示的。

ResultSet对象代表了sql语句查询的结果，而ResultSet实际上是一个由行和列组成的二元表，其内部有指针指向当前对应的行记录，默认该指针指向第一行记录：
通过调用.next()方法将光标指向下一行，
通过调用.previous()方法将光标向前移动
通过调用.absolute()方法将光标直接定位到某一行
通过调用.beforeFirst()方法将光标直接移动到第一行的最前端，通过.next()方法返回第一行
通过调用.afterLast()方法将光标直接移动到最后一行的下一条记录

将光标调整到对应的行以后，然后获取对应的列的结果：
.getString(列名)
.getInt(列名)

JDBC构建步骤：

装载驱动程序
建立数据库连接
执行sql语句
获取执行结果
清理资源

//代码如下：

 public class HelloJdbc {
   static final String JDBC_DRIVER="";
   static String DB_URL="jdbc:mysql://localhost/demo";
   static final String USER="root";
   static final String PASSWD="root";

 public static void helloword()throws ClassNotFoundException{
   Connection conn=null;
   Statement sta=null;
   ResultSet rs=null;

 //加载驱动程序
 Class.forName(JDBC_DRIVER);
 //建立后端数据库连接
 try {
    conn=DriverManager.getConnection(DB_URL, USER, PASSWD);
 //执行sql语句
    sta=conn.createStatement();
    rs=sta.executeQuery("select name from student");
 //获取执行结果
    while(rs.next()) {
        System.out.println("hello");
    }
} catch (SQLException e) {
 //异常处理
    e.printStackTrace();
}finally {
 //清理资源
        try {
    if(rs!=null) rs.close();
    if(sta!=null) sta.close();
    if(conn!=null) conn.close();    
    } catch (SQLException e) {
        e.printStackTrace();
    }
  }

}
业务场景：

过滤条件较弱，一次可能读出较多记录
读取数据库表中所有记录（海量数据读取）
异常分析：jvm有内容限制，读取数据超出限制，会得到内存溢出的异常
解决方法：游标提供一种客户端读取部分服务器端结果集的机制，允许分批读取sql查询的结果。
如何使用游标：

在DB_URL后添加useCursorFetch=true，开启游标
PreparedStatement接口，继承自Statement，使用PrepareStatement替换Statement，PrepareStatement要求程序员在生成PrepareStatement时就要传入sql语句，而这个sql语句则是一个参数格式化的sql，即sql的过滤条件参数都是通过？的形式来表示，后续通过PrepareStatement的setString()和setInt()设置参数，然后进行执行。通过.setFetchSize()设置JDBC每次从服务器端取回的记录的数量
DB_URL:jdbc:mysql://<ip>:<port>/database?useCursorFetch=true
代码如下：

       //加载驱动程序                        
      Class.forName(JDBC_DRIVER);
 //建立后端数据库连接
 try {
    conn=DriverManager.getConnection(DB_URL, USER, PASSWD);
    DB_URL=DB_URL+"useCursorFetch=true";
 //执行sql语句
    conn.prepareStatement("select name from student");
    ptmt.setFetchSize(1); 
    rs=ptmt.executeQuery();
 //获取执行结果
    while(rs.next()) {
        System.out.println("hello");
    }
} catch (SQLException e) {
 //异常处理
    e.printStackTrace();
}finally {
 //清理资源
    try {
    if(rs!=null) rs.close();
    if(sta!=null) sta.close();
    if(conn!=null) conn.close();    
    } catch (SQLException e) {
    e.printStackTrace();
    }
}

大对象读取（图片等）
异常分析：内存溢出
解决方法：流方式
代码如下:

  try { Class.forName(JDBC_DRIVER);
   conn=DriverManager.getConnection(DB_URL, USER, PASSWD);
   String sql="select name from student";
   ptmt=conn.prepareStatement(sql);
   rs=ptmt.excuteQuery();
   while(rs.next()) {
 //获取对象流
 InputStream in=rs.getBinaryStream("blog");
 //将对象流写入对象
 File f=new File(FILE_URL);
 OutputStream out=null;
 out=new FileOutputStream(f);
 int temp=0;
 while((temp=in.read())!=-1) {
     //边读边写
     out.write(temp);
 }
 in.close();
 out.close();
  }}catch(SQLException e) {
    e.printStackTrace(); }finally {}

海量数据插入
原因分析：每次sql的update操作时都是一次客户端到服务端发送sql，接收sql的过程。每执行一次，就要发送一次，效率太低
解决方法：批处理，发送一次sql，发送多条数据
Statement->
-addBatch() 把sql打包成一个执行单元；batch是执行sql的单位
-executeBatch() 执行这批sql
-clearBatch() 清空batch中的sql语句

代码如下：

Set<String> users=new HashSet<String>();
   users.add("");
   users.add("");

Class.forName(JDBC_DRIVER);
try {
    conn=DriverManager.getConnection(DB_URL, USER, PASSWD);
    sta=conn.createStatement();
    for(String user:users) {
        sta.addBatch("insert into user(username) values("+user+")");
    }
    sta.executeBatch();
    sta.clearBatch();
}catch(SQLException e) {
    e.printStackTrace();
}finally {
    //如上，清理资源
}

JDBC基础

猜你喜欢

热点阅读