基本步骤

导入MySQL驱动jar包 mysql-connector-java-8.0.15.zip
注册驱动
获取数据库连接对象Connection
定义sql
获取执行sql语句的对象Statement
执行sql，接收返回结果
处理结果
释放资源

代码实现

//1. 导入MySQL驱动jar包

//2.注册驱动

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

//3.获取数据库连接对象

Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/dbname", "root", "password");

//4.定义sql语句

String sql = "update account set balance = 500 where id = 1";

//5.获取执行sql的对象 Statement

Statement stmt = conn.createStatement();

//6.执行sql

int count = stmt.executeUpdate(sql);

//7.处理结果

System.out.println(count);

//8.释放资源

stmt.close();

conn.close();

URL写法

驱动
- MySQL5
  - com.mysql.jdbc.Driver
- MySQL5以上
  - com.mysql.cj.jdbc.Driver
JDBC
- jdbc:mysql://IP地址:端口号/数据库名字

MySQL时区问题的两种解决方法

MySQL\MySQL Server 8.0\my.ini末尾添加 default-time_zone = '+8:00'
JDBC的URL末尾添加 ?serverTimezone=UTC

SQL注入

在拼接sql时，有一些sql的特殊关键字参与字符串的拼接。会造成安全性问题。简单解决方法：使用 PreparedStatement 对象

简单JDBCUtils工具类

public class JDBCUtils {

    /*

     * db.properties文件内容

     * driver=com.mysql.cj.jdbc.Driver

     * url=jdbc:mysql://localhost:3306/user

     * user=root

     * password=mysql

     */

    private static String url;

    private static String user;

    private static String password;

    private static String driver;

    static{

        //读取资源文件，获取值。

        try {

            //1. 创建Properties集合类。

            Properties pro = new Properties();

            //获取src路径下的文件的方式--->ClassLoader 类加载器

            ClassLoader classLoader = JDBCUtils.class.getClassLoader();

            URL res  = classLoader.getResource("db.properties");

            String path = res.getPath();

            pro.load(new FileReader(path));

            //3. 获取数据，赋值

            url = pro.getProperty("url");

            user = pro.getProperty("user");

            password = pro.getProperty("password");

            driver = pro.getProperty("driver");

            //4. 注册驱动

            Class.forName(driver);

        } catch (IOException e) {

            e.printStackTrace();

        } catch (ClassNotFoundException e) {

            e.printStackTrace();

        }

    }

    /**

     * 获取连接

     * @return 连接对象

     */

    public static Connection getConnection() throws SQLException {

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

    }

    /**

     * 释放资源

     * @param stmt

     * @param conn

     */

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

        if( stmt != null){

            try {

                stmt.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

        if( conn != null){

            try {

                conn.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

    }

    /**

     * 释放资源

     * @param stmt

     * @param conn

     */

    public static void close(ResultSet rs,Statement stmt, Connection conn){

        if( rs != null){

            try {

                rs.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

        if( stmt != null){

            try {

                stmt.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

        if( conn != null){

            try {

                conn.close();

            } catch (SQLException e) {

                e.printStackTrace();

            }

        }

    }

}

JDBC控制事务

事务：一个包含多个步骤的业务操作。如果这个业务操作被事务管理，则这多个步骤要么同时成功，要么同时失败。
操作：
1. 开启事务
2. 提交事务
3. 回滚事务
使用Connection对象来管理事务
1. 开启事务：setAutoCommit(boolean autoCommit) ：调用该方法设置参数为false，即开启事务
  - 在执行sql前开启事务
2. 提交事务：commit()
  - 当所有sql都执行完提交事务
3. 回滚事务：rollback()
  - 在catch中回滚事务

示例

 public static void main(String[] args) {

     Connection conn = null;

     PreparedStatement pstmt1 = null;

     PreparedStatement pstmt2 = null;

     try {

         //1.获取连接

         conn = JDBCUtils.getConnection();

         //开启事务

         conn.setAutoCommit(false);

         //2.定义sql

         //2.1 张三 - 500

         String sql1 = "update account set balance = balance - ? where id = ?";

         //2.2 李四 + 500

         String sql2 = "update account set balance = balance + ? where id = ?";

         //3.获取执行sql对象

         pstmt1 = conn.prepareStatement(sql1);

         pstmt2 = conn.prepareStatement(sql2);

         //4. 设置参数

         pstmt1.setDouble(1,500);

         pstmt1.setInt(2,1);

         pstmt2.setDouble(1,500);

         pstmt2.setInt(2,2);

         //5.执行sql

         pstmt1.executeUpdate();

         // 手动制造异常

         int i = 3/0;

         pstmt2.executeUpdate();

         //提交事务

         conn.commit();

     } catch (Exception e) {

         //事务回滚

         try {

             if(conn != null) {

                 conn.rollback();

             }

         } catch (SQLException e1) {

             e1.printStackTrace();

         }

         e.printStackTrace();

     }finally {

         JDBCUtils.close(pstmt1,conn);

         JDBCUtils.close(pstmt2,null);

     }

 }

数据库连接池

实现

标准接口：DataSource javax.sql包
方法
- 获取连接：getConnection()
- 归还连接：Connection.close() 从连接池获取的连接对象不是关闭连接而是归还对象

两种连接池技术C3P0、Druid

C3P0
- 步骤
  1. 导入两个jar包 c3p0-0.9.5.2.jar、mchange-commons-java-0.2.11.jar
  2. 定义配置文件：
    - 名称：c3p0.properties 或者 c3p0-config.xml
    - 路径：src目录下
  3. 创建核心对象数据库连接池对象 ComboPooledDataSource
  4. 获取连接：getConnection
- 代码
```
  DataSource ds = new ComboPooledDataSource();

  Connection conn = ds.getConnection();
```

Druid

步骤
1. 导入jar包 druid 中文wiki
2. 定义及加载配置文件
3. 获取数据库连接池对象 DruidDataSourceFactory
4. 获取连接：getConnection

代码

  //加载配置文件

  Properties pro = new Properties();

  InputStream is = DruidDemo.class.getClassLoader().getResourceAsStream("druid.properties");

  pro.load(is);

  //获取连接池对象

  DataSource ds = DruidDataSourceFactory.createDataSource(pro);

  //获取连接

  Connection conn = ds.getConnection();

定义工具类JDBCUtils

  public class JDBCUtils {

      //1.定义成员变量 DataSource

      private static DataSource ds ;

      static{

          try {

              //1.加载配置文件

              Properties pro = new Properties();

              pro.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));

              //2.获取DataSource

              ds = DruidDataSourceFactory.createDataSource(pro);

          } catch (IOException e) {

              e.printStackTrace();

          } catch (Exception e) {

              e.printStackTrace();

          }

      }

      /**

       * 获取连接

       */

      public static Connection getConnection() throws SQLException {

          return ds.getConnection();

      }

      /**

       * 获取连接池方法

       */

      public static DataSource getDataSource(){

          return  ds;

      }

      /**

       * 释放资源

       */

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

         close(null,stmt,conn);

      }

      public static void close(ResultSet rs , Statement stmt, Connection conn){

          if(rs != null){

              try {

                  rs.close();

              } catch (SQLException e) {

                  e.printStackTrace();

              }

          }

          if(stmt != null){

              try {

                  stmt.close();

              } catch (SQLException e) {

                  e.printStackTrace();

              }

          }

          if(conn != null){

              try {

                  conn.close();//归还连接

              } catch (SQLException e) {

                  e.printStackTrace();

              }

          }

      }

  }

Spring JDBC

Spring框架对JDBC的简单封装。提供了一个JDBCTemplate对象简化JDBC的开发
步骤：
1. 导入jar包
2. 创建JdbcTemplate对象。依赖于数据源DataSource
  - JdbcTemplate template = new JdbcTemplate(ds);
3. 调用JdbcTemplate的方法来完成CRUD的操作
  - update():执行DML语句。增、删、改语句
  - queryForMap():查询结果将结果集封装为map集合，将列名作为key，将值作为value 将这条记录封装为一个map集合
    - 注意：这个方法查询的结果集长度只能是1
  - queryForList():查询结果将结果集封装为list集合
    - 注意：将每一条记录封装为一个Map集合，再将Map集合装载到List集合中
  - query():查询结果，将结果封装为JavaBean对象
    - query的参数：RowMapper
      - 使用BeanPropertyRowMapper实现类。可以完成数据到JavaBean的自动封装
      - new BeanPropertyRowMapper<类型>(类型.class)
  - queryForObject：查询结果，将结果封装为对象
    - 一般用于聚合函数的查询

巴特西

JavaWeb笔记（一）JDBC

基本步骤

代码实现

URL写法

MySQL时区问题的两种解决方法

SQL注入

简单JDBCUtils工具类

JDBC控制事务

数据库连接池

实现

两种连接池技术C3P0、Druid

Spring JDBC

最新文章

热门文章