JAVA基礎知識之JDBC——編程步驟及執行SQL

JDBC編程步驟

下面以mysql數據庫為例，

1.加載驅動

首先需要下載數據庫的驅動jar文件，並且在eclipse包中加入到class path中去， 例如mysql的驅動文件 mysql-connector-java-5.1.23-bin.jar

然后就可以在java程序中用反射加載驅動

Class.forName("com.mysql.jdbc.Driver");

2.獲取數據庫連接，即Connectiond對象

使用java.sql.DriverManager的getConnection(String url, String user, String pass)方法獲取數據庫連接Connectiond對象

Connection conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/dedecms","root","");

3.通過Connectiond創建statement對象，用來執行SQL

通常有三種statement對象，

• createStatement() , 創建普通的statement對象，可以直接執行sql語句
• prepareStatement(String sql) , 創建預編譯的statement對象，支持sql語句帶參數
• prepareCall(String sql) , 創建能執行存儲過程的statement對象

4.執行SQL語句，所有statement對象都有三個執行sql的方法

• execute()可執行任何SQL語句返回boolean，表示是否返回了數據，需要通過statement對象的getResultSet()方法才能獲取結果集，通過statement的getUpdateCount()方法獲取影響條數
• executeQuery()返回ResultSet
• executeUpdate()執行SQL語句返回受影響記錄數

5.操作結果集ResultSet

next(), previous(), first(), last(), beforeFirst(), afterLast(), absolute() 可以進行行移動

getXxx(...)可以在具體行上面，獲取指定列的值，參數可以是數字索引或者是列名

6.回收數據庫資源

關閉ResultSet, Statement, Connection

 

 下面演示一下JDBC的常用編程步驟，

package db;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Connection;
import java.sql.DriverManager;

public class ConnMySQL {
    public static void connMySQL() throws ClassNotFoundException, SQLException {
        Class.forName("com.mysql.jdbc.Driver");
        try (
                Connection conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/dedecms","root","");
                Statement stmt = conn.createStatement();
                /*
                 * Statement有三種執行SQL的方法
                 * 1.execute()可執行任何SQL語句返回boolean
                 * 2.executeQuery()返回ResultSet
                 * 3.executeUpdate()執行DML語句返回受影響記錄數
                 */
                ResultSet rs = stmt.executeQuery("select * from    dede_addoninfos")) {
            //ResultSet通過next()能向前迭代，通過各種getXxx()方法獲取對應字段值
            while(rs.next()) {
                System.out.println(rs.getInt(1)+"\t | "+rs.getInt(2) + "\t | "+rs.getInt(3) + "\t |"+rs.getString("title"));
            }
        }
    }
    
    public static void main(String[] args) throws SQLException, ClassNotFoundException {
        connMySQL();
    }
}

上面程序的第14行，可以使用createStatement() 或者prepareStatement()兩種方式創建statement對象，其中第二種支持帶參數sql的預編譯

在第21行，則可以使用execute(), executeQuery(), executeUpdate()三種方式執行SQL，只不過第一種返回boolean，第二種返回結果集，第三種返回記錄數

在第24行，既可以用rs.getString(7)這種方式取值，也可以用rs.getString("title")這種方式取值

上面執行結果如下，

99     | 9     | -8     |武漢地區招聘dedecms網頁美工
100     | 9     | -8     |吉林地區 禮聘 PHP程序員  網頁設計師 系統運維工程師  薪酬面議
101     | 9     | -8     |4000每月 招聘dede二次開發程序一名
102     | 9     | -8     |尊米網誠聘全職PHP程序員（廣州）
103     | 9     | -8     |《每日商報》招聘PHP程序員、網頁設計師
104     | 9     | -8     |招聘PHP程序員3名底薪3000起 +獎金 （包吃住）
105     | 9     | -8     |佰邦達科技（北京）有限公司招聘PHP開發工程師

 

下面演示兩種Statement對比以及兩種執行SQL的用法，

mysql的jdbc配置如下，

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://127.0.0.1:3306/dedecms?useUnicode=true&characterEncoding=utf8
user=root
pass=

 

package db;

import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.sql.Connection;
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 java.util.Properties;

public class ExecuteSQL {
    private String driver;
    private String url;
    private String user;
    private String pass;
    public void initParam(String paramFile) throws FileNotFoundException, IOException, ClassNotFoundException {
        //用Properties類加載屬性文件
        Properties prop = new Properties();
        prop.load(new FileInputStream(paramFile));
        driver = prop.getProperty("driver");
        url = prop.getProperty("url");
        user = prop.getProperty("user");
        pass = prop.getProperty("pass");
        Class.forName(driver);
    }
    public void createTable(String sql) throws SQLException, ClassNotFoundException {
        try (
                Connection conn = DriverManager.getConnection(url, user, pass);
                Statement stmt = conn.createStatement()) {
            //執行DDL語句，創建數據表
            stmt.executeUpdate(sql);
        }
        
    }
    public int insertData(String sql) throws SQLException, ClassNotFoundException {
        try (
                Connection conn = DriverManager.getConnection(url, user, pass);
                Statement stmt = conn.createStatement()) {
            //執行DML語句，插入數據
            return stmt.executeUpdate(sql);
        }
    }
    
    public void executeSQL(String sql) throws ClassNotFoundException, SQLException {
        try (
                Connection conn = DriverManager.getConnection(url, user, pass);
                Statement stmt = conn.createStatement()) {
            //execute()返回boolean,true表示有ResultSet, falseb表示沒有
            boolean hasResultSet = stmt.execute(sql);
            if (hasResultSet) {
                try (
                        // 獲取結果集
                        ResultSet rs = stmt.getResultSet()) {
                    //ResultSetMetaData是用於分析結果集的接口
                    ResultSetMetaData rsmd = rs.getMetaData();
                    int columnCount = rsmd.getColumnCount();
                    while(rs.next()) {
                        for(int i = 0; i < columnCount; i++) {
                            System.out.print(rs.getString(i + 1) + "\t");
                        }
                        System.out.print("\n");
                    }
                }
            } else {
                System.out.println("該SQL執行結果影響的記錄條數有 "+ stmt.getUpdateCount() + " 條");
            }
        }
    }
    
    public void insertUseStatement() throws SQLException, ClassNotFoundException {
        long start = System.currentTimeMillis();
        try (
                Connection conn = DriverManager.getConnection(url, user, pass);
                Statement stmt = conn.createStatement()) {
            for (int i = 0 ; i < 10 ; i++) {
                stmt.executeUpdate("insert into jdbc_test values("
                        + " null ,'title"+i+"','content"+i+"')");
            }
            System.out.println("使用Statement費時:"+(System.currentTimeMillis()-start));
        }
    }
    
    public void insertUsePrepare() throws ClassNotFoundException, SQLException {
        long start = System.currentTimeMillis();
        try (
                Connection conn = DriverManager.getConnection(url, user, pass);
                PreparedStatement pstmt = conn.prepareStatement("insert into jdbc_test values(null,?,?)")) {

            
            for (int i = 0 ; i < 10 ; i++) {
                //序號1,2表示sql中第幾個參數
                pstmt.setString(1, "title"+i);
                pstmt.setString(2, "content"+i);
                pstmt.executeUpdate();
            }
            
            System.out.println("使用PreparedStatement費時:"+(System.currentTimeMillis()-start));
        }
    }
    
    public static void main(String[] args) throws ClassNotFoundException, SQLException, FileNotFoundException, IOException {
        ExecuteSQL es = new ExecuteSQL();
        es.initParam("mysql.ini");
        /*
        es.createTable("create table jdbc_test "
                + "(jdbc_id int auto_increment primary key, "
                + "jdbc_name varchar(255), "
                + "jdbc_desc text) CHARSET=utf8;");
        System.out.println("=================建表成功=================");
        */
        
       /* 
        int result = es.insertData("insert into jdbc_test (jdbc_name, jdbc_desc) "
                + " select title, body from dede_addoninfos;");
        System.out.println("====共有 "+result+" 條記錄受影響===");
        */
        
       //es.executeSQL("select * from jdbc_test");
        es.insertUseStatement();
        es.insertUsePrepare();
    }
}

上面程序的insertUseStatement()和insertUsePrepare()分別用了普通的statement和preparestatement,

preparestatement可以支持參數形式，因此不需要拼接參數，省去了麻煩而且更安全（SQL注入）

多次執行程序會發現preparestatement的性能要高很多。