JavaWeb学习总结（九）--JDBC入门

时间：2024-12-14 14:33:08

一、什么是JDBC

JDBC（Java DataBase Connectivity）就是Java数据库连接，说白了就是用Java语言来操作数据库。原来我们操作数据库是在控制台使用SQL语句来操作数据库，JDBC是用Java语言向数据库发送SQL语句。

JavaWeb学习总结（九）--JDBC入门

组成JDBC的２个包：
　　　java.sql
　　　javax.sql
 开发JDBC应用需要以上2个包的支持外，还需要导入相应JDBC的数据库实现(即数据库驱动)。

二、实现代码

package cn.zy.jdbc;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.Statement;

import org.junit.Test;

public class Demo01 {

    /*

     * 得到数据库连接

     */

    public static Connection getConnection() throws Exception{

        //加载驱动

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

        //mysql的url

        String url = "jdbc:mysql://localhost:3306/testdb";

        Connection con = DriverManager.getConnection(url,"root","123456");

        return con;

    }

    /*

     * 实现增删改

     */

    @Test

    public void insert() throws Exception{

        //得到连接

        Connection con = getConnection();

        //Statement语句的发送器，它的功能就是向数据库发送sql语句！

        Statement stmt = con.createStatement();

        String sql = "insert user(name,password) value('scott','tiger')";

        //执行sql

        stmt.executeUpdate(sql);

    }

    /*

     * 查询

     */

    @Test

    public void query() throws Exception{

        Connection con = getConnection();

        Statement stmt = con.createStatement();

        String sql = "select * from user";

        //得到查询出来的结果集

        ResultSet rs = stmt.executeQuery(sql);

        //输出查询到的结果

        while (rs.next()){

            String username = rs.getString("name");

            String password = rs.getString("password");

            System.out.println(username + ','+ password);

        }

        /*

         * 关闭资源

         */

        rs.close();

        stmt.close();

        con.close();

    }

}

三、JDBC对象介绍

在JDBC中常用的类有：

  • DriverManager
  • Connection
  • Statement
  • ResultSet

3.1 DriverManager

Jdbc程序中的DriverManager用于加载驱动，并创建与数据库的链接，这个API的常用方法：

   DriverManager.getConnection(url, user, password);

常用数据库URL地址的写法：

  • Oracle写法：jdbc:oracle:thin:@localhost:1521:sid         （driverClassName:oracle.jdbc.driver.OracleDriver）
  • SqlServer写法：jdbc:microsoft:sqlserver://localhost:1433; DatabaseName=sid
  • MySql写法：jdbc:mysql://localhost:3306/sid

3.2 Connection

Jdbc程序中的Connection，它用于代表数据库的链接，Collection是数据库编程中最重要的一个对象，客户端与数据库所有交互都是通过connection对象完成的，这个对象的常用方法：

  • createStatement()：创建向数据库发送sql的statement对象。
  • prepareStatement(sql) ：创建向数据库发送预编译sql的PrepareSatement对象。
  • prepareCall(sql)：创建执行存储过程的callableStatement对象。
  • setAutoCommit(boolean autoCommit)：设置事务是否自动提交。
  • commit() ：在链接上提交事务。
  • rollback() ：在此链接上回滚事务。

3.3 Statement

Jdbc程序中的Statement对象用于向数据库发送SQL语句， Statement对象常用方法：

  • executeQuery(String sql) ：用于向数据发送查询语句。
  • executeUpdate(String sql)：用于向数据库发送insert、update或delete语句
  • execute(String sql)：用于向数据库发送任意sql语句
  • addBatch(String sql) ：把多条sql语句放到一个批处理中。
  • executeBatch()：向数据库发送一批sql语句执行。

3.4 ResultSet

Jdbc程序中的ResultSet用于代表Sql语句的执行结果。Resultset封装执行结果时，采用的类似于表格的方式。ResultSet 对象维护了一个指向表格数据行的游标，初始的时候，游标在第一行之前，调用ResultSet.next() 方法，可以使游标指向具体的数据行，进行调用方法获取该行的数据。
　　ResultSet既然用于封装执行结果的，所以该对象提供的都是用于获取数据的get方法：
　　获取任意类型的数据
　　　　getObject(int index)
　　　　getObject(string columnName)
　　获取指定类型的数据，例如：
　　　　getString(int index)
　　　　getString(String columnName)

　　ResultSet还提供了对结果集进行滚动的方法：

  • next()：移动到下一行
  • Previous()：移动到前一行
  • absolute(int row)：移动到指定行
  • beforeFirst()：移动resultSet的最前面。
  • afterLast() ：移动到resultSet的最后面。

3.5 PreparedStatement

PreperedStatement是Statement的子类，它的实例对象可以通过调用Connection.preparedStatement()方法获得，相对于Statement对象而言：PreperedStatement可以避免SQL注入的问题。在实际项目中，应该都使用PreparedStatement.
　　Statement会使数据库频繁编译SQL，可能造成数据库缓冲区溢出。PreparedStatement可对SQL进行预编译，从而提高数据库的执行效率。并且PreperedStatement对于sql中的参数，允许使用占位符的形式进行替换，简化sql语句的编写。

 注意MySQL中默认是没有开启预编译的，如果需要打开需要修改url：jdbc:mysql://localhost:3306/test?useServerPrepStmts=true

四、使用JdbcUtils和PreparedStatement

1. 创建users表

CREATE TABLE users(

    id INT PRIMARY KEY,

    NAME VARCHAR(40),

    PASSWORD VARCHAR(40),

    email VARCHAR(60),

    birthday DATE

);

2. 新建一个Java工程，导入驱动包，在src下创建一个db.properties文件

JavaWeb学习总结（九）--JDBC入门

在db.properties中编写MySQL数据库的连接信息，如下所示：

driver=com.mysql.jdbc.Driver

url=jdbc\:mysql\://localhost\:3306/testdb

username=root

password=123456

3.编写一个JdbcUtils工具类，用于连接数据库，获取数据库连接和释放数据库连接，代码如下：

package cn.zy.utils;

import java.io.InputStream;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Properties;

public class JdbcUtils {

    private static Properties props = null;

    private static String driver = null;

    private static String url = null;

    private static String username = null;

    private static String password = null;

    //只在JdbcUtils类被加载时执行一次！

    static {

        try {

          // 给props进行初始化，即加载dbconfig.properties文件到props对象中

            InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");

            Properties prop = new Properties();

            prop.load(in);

            //获取数据库的驱动

            driver = prop.getProperty("driver");

            //获取url

            url= prop.getProperty("url");

            //获取用户名

            username = prop.getProperty("username");

            //获取密码

            password = prop.getProperty("password");

            //加载驱动

            Class.forName(driver);

        } catch (Exception e) {

            throw new ExceptionInInitializerError(e);

        }

    }

    /*

     * 获取数据库连接对象

     */

    public static Connection getConnection() throws SQLException{

        return DriverManager.getConnection(url,username,password);

    }

    /*

     * 释放资源

     */

    public static void release(Connection conn,Statement st,ResultSet rs){

        if(rs!=null){

            try{

                //关闭存储查询结果的ResultSet对象

                rs.close();

            }catch (Exception e) {

                e.printStackTrace();

            }

            rs = null;

        }

        if(st!=null){

            try{

                //关闭负责执行SQL命令的Statement对象

                st.close();

            }catch (Exception e) {

                e.printStackTrace();

            }

        }

        if(conn!=null){

            try{

                //关闭Connection数据库连接对象

                conn.close();

            }catch (Exception e) {

                e.printStackTrace();

            }

        }

    }

}

4.使用PreparedStatement实现增删改查

package cn.zy.test;

import java.sql.Connection;

import java.util.Date;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import org.junit.Test;

import cn.zy.utils.JdbcUtils;

public class JdbcUtilsTest {

    @Test

    public void insert(){

        Connection conn = null;

        PreparedStatement st = null;

        ResultSet rs = null;

        try {

            //获取一个数据库连接

             conn = JdbcUtils.getConnection();

            //要执行的SQL模板，SQL中的参数使用?作为占位符

             String sql = "insert into users(id,name,password,email,birthday) values(?,?,?,?,?)";

            //通过conn对象获取负责执行SQL命令的prepareStatement对象

            st = conn.prepareStatement(sql);

            //为SQL语句中的参数赋值，注意，索引是从1开始的

            st.setInt(1, 1);

            st.setString(2,"scott");

            st.setString(3,"tiger");

            st.setString(4, "zy5724@163.com");

            st.setDate(5, new java.sql.Date(new Date().getTime()));

            int num = st.executeUpdate();

            if (num>0){

                System.out.print("更新成功");

            }

        } catch (SQLException e) {

            e.printStackTrace();

        }finally{

            JdbcUtils.release(conn, st, rs);

        }

    }

    @Test

    public void query(){

        Connection conn = null;

        PreparedStatement st = null;

        ResultSet rs = null;

        try {

            //获取一个数据库连接

             conn = JdbcUtils.getConnection();

            //要执行的SQL模板，SQL中的参数使用?作为占位符

             String sql = "select * from users where id=?";

            //通过conn对象获取负责执行SQL命令的prepareStatement对象

            st = conn.prepareStatement(sql);

            st.setInt(1, 1);

            rs = st.executeQuery();

            if (rs.next()){

                System.out.println(rs.getString("name"));

            }

        } catch (SQLException e) {

            e.printStackTrace();

        }finally{

            JdbcUtils.release(conn, st, rs);

        }

    }

}

相关文章