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)+"	 | "+rs.getInt(2) + "	 | "+rs.getInt(3) + "	 |"+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) + "	");
                        }
                        System.out.print("
");
                    }
                }
            } 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的性能要高很多。