jdbc java数据库连接 3）Statement接口之执行DDL和DML语句的简化

上一章的代码中，可以发现，jdbc执行DDL和DML有几个步骤都是一样的：

　　　1）执行语句开始时，创建驱动注册对象、获取连接的数据库对象、创建Statement对象

            // 创建驱动注册对象
            Class.forName("com.mysql.jdbc.Driver");

            // 获取连接的数据库对象
             Connection conn = DriverManager.getConnection(url, user,
                    password);

            // 创建Statement对象
             Statement stsm = conn.createStatement();

　　

　　　　2）所有操作执行完后，关闭连接（后来的先关）

            if (stsm != null) {
                try {
                    stsm.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                    throw new RuntimeException(e);
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                    throw new RuntimeException(e);
                }

所以，我们可以把这三大部分凑起来，建立一个jdbc的工具类：

　　jdbcutil

　　　　

/**
 * 这是jdbc执行DDL和DML的工具类
 * 
 * @author LZl
 * 
 */
public class Jdbcutil {

    // 创建数据库的基本信息
    // 创建url
    private static String url = "jdbc:mysql://localhost:3306/day1029?useUnicode=true&characterEncoding = GB2312 ";
    // 数据库的用户名和密码
    private static String user = "root";
    private static String password = "root";
    public static Connection conn = null;
    static Statement stsm = null;

    /**
     * 一：注册的驱动程序 获取连接对象的方法 静态代码块（好处是只需要加载一次，且随着类的加载而加载）
     */

    static {
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("获取数据库连接对象出错");
        }
    }

    /**
     * 二：获取连接对象 该方法返回一个连接
     */

    public static Connection getConnection() {

        // 创建连接对象
        try {
            conn = DriverManager.getConnection(url, user, password);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            throw new RuntimeException(e);
        }
        return conn;

    }

    /**
     * 三：释放资源，断开连接 参数列表：conn。stsm
     */

    public static void close(Connection conn, Statement stsm) {

        if (stsm != null) {
            try {
                stsm.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
                throw new RuntimeException(e);
            }
        }

        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
                throw new RuntimeException(e);
            }
        }
    }
　　
}

　　　工具类再重载一个带有3个参数的关闭连接的方法：

 1     public static void close(Connection conn,Statement stmt,ResultSet rs){
 2         if(rs!=null)
 3             try {
 4                 rs.close();
 5             } catch (SQLException e1) {
 6                 e1.printStackTrace();
 7                 throw new RuntimeException(e1);
 8             }
 9         if(stmt!=null){
10             try {
11                 stmt.close();
12             } catch (SQLException e) {
13                 e.printStackTrace();
14                 throw new RuntimeException(e);
15             }
16         }
17         if(conn!=null){
18             try {
19                 conn.close();
20             } catch (SQLException e) {
21                 e.printStackTrace();
22                 throw new RuntimeException(e);
23             }
24         }
25     }

然后，1）jdbc使用DDL的方法要这样：

public class UtilTest {

    private static Connection conn = null;
    // 创建Statement对象
    private static Statement stsm;

    // 执行DDL语句（创建）
    private static void DDL() {

        try {
            // 使用jdbc工具类来获取连接对象
            conn = Jdbcutil.getConnection();

            // 准备sql语句
            String sql = "CREATE TABLE person(id INT PRIMARY KEY AUTO_INCREMENT,NAME VARCHAR(10),sex VARCHAR(5),age INT,psot VARCHAR(10),email VARCHAR(20),phone INT)";

            stsm = conn.createStatement();

            // 发送sql语句
            int result = stsm.executeUpdate(sql);
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        } finally {
            // 调用工具类的方法，关闭连接
            Jdbcutil.close(conn, stsm);
        }
    }
    public static void main(String[] args) {
        DDL();
    }
}

　

　　 

　　2）执行DML语句：

    //创建驱动注册对象
    private static Connection conn = null;
    // 创建Statement对象
    private static Statement stsm = null;

// 执行DML语句（插入）
    private static void DML() {

        try {
            // 使用工具类获取连接对象
            conn = Jdbcutil.getConnection();

            // 准备sql语句
            String sql = "INSERT INTO person (NAME,sex,age) VALUES ('张三','男',20);";

            // 创建statement对象
            stsm = conn.createStatement();

            // 执行sql语句
            int result = stsm.executeUpdate(sql);
            System.out.println("影响了" + result + "行");

        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        } finally {
            // 调用工具类关闭连接
            Jdbcutil.close(conn, stsm);
        }
    }

　　3）执行DQL语句：

    // 创建驱动注册对象
    private static Connection conn = null;
    // 创建Statement对象
    private static Statement stsm = null;

        // 执行DQL语句
    private static void DQL() {

        try {

            // 调用工具类连接对象
            conn = Jdbcutil.getConnection();

            // 创建statement对象
            stsm = conn.createStatement();

            // 准备sql语句
            String sql = "SELECT * FROM person;";

            // 执行sql语句,返回的是RrsultSet对象
            ResultSet rs = stsm.executeQuery(sql);

            // 查看第二行数据

            // 移动光标
            rs.next();
            rs.next();
            // 使用列名来查看
            int id = rs.getInt("id");
            String name = rs.getString("name");
            String sex = rs.getString("sex");
            System.out.println(id + "," + name + "," + sex);

        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        } finally {
            // 调用工具类关闭连接,这里要多关闭一个连接：ResultSet，工具类的关闭方法要添加它
            Jdbcutil.close(conn, stsm,rs);
        }

    }