JDBC全解析

好久沒用JDBC了，都有點忘了。昨天晚上系統的總結了下

包括對結果集的指針的操作，批處理，存儲過程的操作等等

package com.jdbc;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;

import com.jdbc.entity.Courseinfo;

public class OralceConnTest {
    private String url="jdbc:oracle:thin:@localhost:1521:ibn";
    private String user="test";
    private String pwd="abs";
    private Connection conn;
    private Statement stat;
    private PreparedStatement ps;
    private ResultSet rs;
    private CallableStatement cs;
    /**
     * 關閉連接 關閉語句對象 關閉結果集
     * 注意Statement和PreparedStatement的區別
     * @param args
     * @throws SQLException
     * @throws InstantiationException
     * @throws IllegalAccessException
     * @throws ClassNotFoundException
     */
    public static void main(String[]args) throws SQLException, InstantiationException, IllegalAccessException, ClassNotFoundException{
        OralceConnTest cont=OralceConnTest.class.newInstance();
        cont.getConnection();
        cont.callStatement();
//        Courseinfo course=new Courseinfo();
//        course.setId(5);
//        course.setUsername("小明");
//        course.setPassword("456");
//        cont.insert(course);
    }
    /**
     * 加載驅動，建立連接
     * @return
     */
    public Connection getConnection(){
        try {
            Class.forName("oracle.jdbc.driver.OracleDriver");
            conn=DriverManager.getConnection(url, user, pwd);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return conn;
    }
    /**
     *查詢數據庫的表 
     * @throws SQLException
     * @throws ClassNotFoundException
     */
    public void conn() throws SQLException, ClassNotFoundException{
        try {
            stat=conn.createStatement();
            ResultSet rs=stat.executeQuery("select userid,username,password from userinfo");
            while(rs.next()){
                StringBuffer sb=new StringBuffer();
                String a=rs.getString(1);
                String b=rs.getString(2);
                String c=rs.getString(3);
                sb.append(a).append(b).append(c);
                System.out.println(sb);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
            conn.close();
            stat.close();
        }
    }
    /**
     * 執行插入操作 注意插入操作 insert into tablename values(id,'name','password') 注意這個單引號不能忘掉
     * @param course
     */
    public void insert(Courseinfo course){
        try {
            //將自動提交事務設關閉
            conn.setAutoCommit(false);
            stat=conn.createStatement();
            String sql="insert into userinfo(userid,username,password)" +
            "values("+course.getId()+",'"
            +course.getUsername()+"','"+course.getPassword()+"')";
            int a=stat.executeUpdate(sql);
            if(a==1){
                System.out.println("statement插入正常");
                //事務提交
                conn.commit();
            }else{
                //事務回滾
                conn.rollback();
            }
            //將事務自動提交恢復
            conn.setAutoCommit(true);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{

            if(stat!=null){
                try {
                    stat.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
            if(conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }
    /**
     * statement每次執行sql語句，相關數據庫都要執行sql語句的編譯
     * preparedstatement是預編譯得,   preparedstatement支持批處理
     * statement執行update必須有參數
     * preparedStatement在創建時已經預編譯了，沒有參數
     * @param course
     */
    public void prepareInsert(Courseinfo course){

        try {
            String sql="insert into userinfo(userid,username,password)values(?,?,?)";
            ps=conn.prepareStatement(sql);
            ps.setInt(1, course.getId());
            ps.setString(2, course.getUsername());
            ps.setString(3, course.getPassword());
            int a=ps.executeUpdate();
            if(a==1){
                System.out.println("preparedStatementd插入正常");
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            if(ps!=null){
                try {
                    ps.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
            if(conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    
    }
    /**
     * 獲取數據庫基本信息
     */
    public void getDbData(String tablename){
        String sql="select*from "+tablename;
        try {
            //獲取數據庫元數據
            DatabaseMetaData dmd=conn.getMetaData();
            //獲取數據庫的各種信息   數據庫名字
            System.out.println(dmd.getDatabaseProductName());
            stat=conn.createStatement();
            rs=stat.executeQuery(sql);
            //結果集元數據
            ResultSetMetaData rmd=rs.getMetaData();
            //獲取結果集列數
            int columnCount=rmd.getColumnCount();
            for(int i=0;i<columnCount;i++){
                //獲取列名
                System.out.println(rmd.getColumnName(i));
            }
            while(rs.next()){
                for(int i=0;i<columnCount;i++){
                    //由列名獲取結果集
                    String value=rs.getString(rmd.getColumnName(i));
                }
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    /**
     * 批處理
     */
    public void batchExecute(){
        String sql="insert into courseinfo(userid) values(?)";
        try {
            conn.setAutoCommit(false);
            ps=conn.prepareStatement(sql);
            for(int i=5;i<100;i++){
                ps.setInt(1, i);
                //將sql語句加入批處理
                ps.addBatch();
                //每10條處理一次
                if(i%10==0){
                    stat.executeBatch();
                    stat.clearBatch();
                }
                stat.executeBatch();//處理最后五條
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
    }
    /**
     * 操作結果集
     *基於緩存的分頁策略
     *起始數據 (page-1)*pageSize+1
     * @param pageSize 每頁有多少條數據
     * @param page 第幾頁
     */
    public void bufferPageDemo(int pageSize,int page){
        String sql="select*from courseinfo";
        try {
            //結果集滾動不敏感的(可跳步的)
            /**
             * ResultSet有個結果集指針，初始是指向第一個結果的
             * 
             * 1.ResultSet.TYPE_FORWARD_ONLY 指針只能安裝列順序向前移動，也就是說在取得name列之后，將不能再返回獲取id列的值；
             * 2.ResultSet.TYPE_SCROLL_INSENSITIVE指針可以前后移動，INSENSITIVE表示不及時更新，就是如果數據庫里的數據修改過，並不在ResultSet中反映出來；
             * 3.ResultSet.TYPE_SCROLL_SENSITIVE指針可以前后移動，SENSITIVE表示及時跟蹤數據庫的更新，以便更改ResultSet中的數據。
             * 
             * 
             * 1.ResultSet.CONCUR_READ_ONLY表示當前ResultSet對象只讀， 不能用結果集更新數據庫中的表
             * 2.ResultSet.CONCUR_UPDATABLE表示當前ResultSet能用結果集更新數據庫中的表
             * 
             * ResultSet提供各種控制指針的方法
             */
            //conn.createStatement(resultSetType, resultSetConcurrency)
            stat=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
                    ResultSet.CONCUR_UPDATABLE);
            rs=stat.executeQuery(sql);
            rs.last();//移動到最后一行
            int rownum=rs.getRow();//記錄當前的行號，記錄的條數
            rs.absolute(1);//將指針移到第一行
            rs.relative(2);//相對當前位置移動2行
            /*更新第三條記錄*/
            rs.updateInt(1, 100);
            rs.updateString(2, "更新地方");
            rs.updateRow();//更新數據源的數據
            /*插入數據*/
            rs.moveToInsertRow();//指針移到插入行
            rs.updateInt(1, 100);
            rs.updateString(2, "插入地方");
            rs.insertRow();
            rs.moveToCurrentRow();//指針移到插入前的位置
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    /**
     * 存儲過程的調用
     * 
     * 
     */
    public void callStatement(){
        StringBuffer sb=new StringBuffer(20);//線程安全
        /*
         * sys_refcursor游標類型
          create or replace procedure testc(infos out sys_refcursor,num out number,names  out varchar2)
            is
            begin
            open infos for 'select*from userinfo';
            select count(*) into num from userinfo;
            select username into names from userinfo where userid=1;
            end testc;
         */
        sb.append("{call testc(?,?,?)}");
        try {
            cs=conn.prepareCall(sb.toString());
            //返回游標類型
            cs.registerOutParameter(1, oracle.jdbc.OracleTypes.CURSOR);
            //返回num類型
            cs.registerOutParameter(2, java.sql.Types.INTEGER);
            //返回字符類型
            cs.registerOutParameter(3, java.sql.Types.VARCHAR);
            cs.execute();
            rs=(ResultSet)cs.getObject(1);
            //獲取結果集的列數
            int count=rs.getMetaData().getColumnCount();//獲得結果集記錄的字段數
            System.out.println("count="+count);
            while(rs.next()){
                for(int i=1;i<=count;i++){
                    System.out.println(rs.getString(i));
                }
            }
            System.out.println("------返回number類型-------");
            int counts=cs.getInt(2);
            System.out.println(counts);
            System.out.println("-----返回varchar-------");
            String name=cs.getString(3);
            System.out.println(name);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        /*調用存儲過程，返回游標，整數，字符串*/
        
        /*調用存儲過程，返回整數*/
        /**/
        /**/
        
    }
}