菜单

Java之JDBC

2018年11月17日 - MySQL

JDBC的简约介绍

JDBC简单以

public static void main(String[] args) throws SQLException {
    // 1. 注册驱动
    Class.forName("com.mysql.jdbc.Driver");
    // 2. 获取链接Connection
    Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/yiyousu","root","mysqlmysql");
    // 3. 得到执行SQL语句的对象Satatement
    Statement stmt = (Statement) conn.createStatement();
    // 4. 执行SQL语句,并返回结果
    ResultSet rs = stmt.executeQuery("select * from `user`");
    // 5. 处理结果
    while (rs.next()) {
        System.out.println(rs.getObject(1));
        System.out.println(rs.getObject(2));
        System.out.println(rs.getObject(3));
        System.out.println(rs.getObject(4));
        System.out.println(rs.getObject(6));
        System.out.println("----------------");
    }
    // 6. 关闭资源
    rs.close();// 关闭结果集
    stmt.close();// 关闭读取器
    conn.close();// 关闭数据库链接
    }
}

// 增删改语句
public static void main(String[] args) throws Exception {
    // 1. 注册驱动
    Class.forName("com.mysql.jdbc.Driver");
    // 2. 获取链接Connection
    Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/yiyousu", "root", "mysqlmysql");
    // 3. 得到执行SQL语句的对象Satatement
    Statement stmt = conn.createStatement();
    // 4. 执行SQL语句,并返回结果
    int i = stmt.executeUpdate("INSERT INTO test (name,age) VALUES('test1',1)");
    // 5. 处理结果
    System.out.println(i);
    // 6. 关闭资源
    stmt.close();// 关闭读取器
    conn.close();// 关闭数据库链接
}

概念

霎时入门

自己用的凡jdk10及mysql-connector-java-5.1.45-bin.jar。

步骤:

  1. 导入驱动jar包
    • 色根本目录创建文件夹libs。
    • 将mysql-connector-java-5.1.45-bin.jar复制到libs目录下
    • 右击libs下,Add as Library将jar包导入项目中
  2. 登记驱动
  3. 获取数据库连接对象(Collection)
  4. 定义sql
  5. 博执行sql语句的目标 Statement
  6. 履sql,接受返回结果(ResultSet)
  7. 处理结果
  8. 释放资源

     // 2. 注册驱动
     Class.forName("com.mysql.jdbc.Driver");
     // 3. 获取连接对象Collection
     Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db1", "root", "nrblwbb7");
     // 4. 定义sql
     String sql = "UPDATE STUDENT SET AGE = 23 WHERE NAME = '王智'";
     // 5. 获取执行sql语句的对象 Statement
     Statement statement = conn.createStatement();
     // 6. 执行sql,接受返回结果(ResultSet)
     int result = statement.executeUpdate(sql);
     // 7. 处理结果
     System.out.println(result);
     // 8. 释放资源
     statement.close();
     conn.close();
    

详解各个对象

  1. DriverManager:驱动管理对象
  2. Connection:数据库连接对象
  3. Statement:执行sql对象
  4. ResultSet:结果集对象
  5. PreparedStatement :执行sql对象
DriverManager

功能:

  1. 登记驱动:告诉程序该用啊一个数据库让jar

    • 下的计:static void registerDriver(Driver driver)
      :注册与给定的驱动程序 DriverManager 。
    • 形容代码用:Class.forName(“com.mysql.jdbc.Driver”);
    • 透过翻源码发现:在com.mysql.jdbc.Driver类中设有静态代码块

         static {
                try {
                    java.sql.DriverManager.registerDriver(new Driver());
                } catch (SQLException E) {
                    throw new RuntimeException("Can't register driver!");
                }
         }
      

      小心:mysql5之后的让jar包可以省略注册驱动的步子。

  2. 获取数据库连接

    • 方法:static Connection getConnection(String url, String user,
      String password)
    • 参数:
      • url:指定连接的路线
        • 语法:jdbc:mysql://ip地址(域名):端口号/数据库名称
        • 例子:jdbc:mysql://localhost:3306/db
        • 细节:如果总是的凡本机mysql服务器,并且mysql服务默认端口是3306,则url可以简写为:jdbc:mysql:///数据库名称
        • jdbc是接连数据库的情商,mysql是接连mysql数据库的子协议
      • user:用户名
      • password:密码
Collection连接对象

功能:

  1. 获得执行sql的靶子
    • Statement createStatement()
    • PreparedStatement prepareStatement(String sql)
  2. 治本事务
    • 打开事务:setAutoCommit(boolean autoCommit)
      :调用该法设置参数为false,即开事务
    • 交给业务:commit()
    • 回滚事务:rollback()
Statement执行静态sql对象

功能:

  1. 执行sql
    • boolean execute(String sql) :可以实施任意的sql (了解)
    • int executeUpdate(String sql)
      :执行DML(insert、update、delete)语句、DDL(create,alter、drop)语句

      • 返回值:影响的行数,可以由此这影响之行数判断DML语句是否履行成功
        返回值>0底则执行成功,反之,则败。
    • ResultSet executeQuery(String sql) :执行DQL(select)语句

插举例:

 public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        try {
            // 1. 加载驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 2. 获取连接对象
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db3?useSSL=true", "root", "nrblwbb7");
            // 3. 创建sql
            String sql = "INSERT INTO ACCOUNT VALUES (NULL,'网址',2000)";
            // 4. 获取执行sql对象
            stmt = conn.createStatement();
            // 5. 执行sql
            int count = stmt.executeUpdate(sql);
            // 6. 处理结果
            System.out.println("影响的行数为:" + count);
            if(count > 0){
                System.out.println("插入成功");
            }else{
                System.out.println("操作失败");
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // 7. 释放资源
            if(stmt != null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(conn != null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }

        }
  }

修改举例:

 public static void main(String[] args) {
        /**
         * 由于Connection和Statement实现了AutoCloseable接口,所以可以使用自动关闭
         */
        try(
                // 2.获取Connection对象
                Connection conn = DriverManager.getConnection(
                        "jdbc:mysql://localhost:3306/db3?useSSL=true",
                        "root",
                        "nrblwbb7") ;
                // 3. 获取Statement对象
                Statement stmt = conn.createStatement()
                ){
            // 1.加载驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 4. 创建sql
            String sql = "UPDATE ACCOUNT SET BALANCE = 1500 WHERE NAME = '网址'";
            // 5. 执行sql
            int count = stmt.executeUpdate(sql);
            // 6. 处理结果
            System.out.println(count);
            if(count > 0){
                System.out.println("修改成功");
            }else{
                System.out.println("操作失败或者记录未更改");
            }
            // 7. 关闭连接,由于try..with..resource会自动关闭,所以无须担心
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }

去举例:

 public static void main(String[] args) {
        /**
         * 由于Connection和Statement实现了AutoCloseable接口,所以可以使用自动关闭
         */
        try(
                // 2.获取Connection对象
                Connection conn = DriverManager.getConnection(
                        "jdbc:mysql://localhost:3306/db3?useSSL=true",
                        "root",
                        "nrblwbb7") ;
                // 3. 获取Statement对象
                Statement stmt = conn.createStatement()
                ){
            // 1.加载驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 4. 创建sql
            String sql = "DELETE FROM ACCOUNT WHERE NAME = '网址'";
            // 5. 执行sql
            int count = stmt.executeUpdate(sql);
            // 6. 处理结果
            System.out.println(count);
            if(count > 0){
                System.out.println("删除成功");
            }else{
                System.out.println("删除失败");
            }
            // 7. 关闭连接,由于try..with..resource会自动关闭,所以无须担心
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
ResultSet:结果和对象,封装查询结果

功能:

  1. 包裹查询结果:
    • boolean next():
      游标向下活动一行,判断时行是不是是终极一履最终(是否发生数量),如果是,则回false,如果非是虽然赶回true
    • getXxx(参数):获取数据
      • Xxx:代表数据类型 如: int getInt() , String getString()
      • 参数:
        1. int:代表列的号,从1起来 如: getString(1)
        2. String:代表列名称。 如: getDouble(“balance”)
    • 注意:
      • 运手续:
        1. 游标向下活动一行
        2. 看清是否发数据
        3. 获取数据

推个简单例子:

 @Test
    public void selectDemo(){
        try {
            // 1.加载驱动
            Class.forName("com.mysql.jdbc.Driver");
            // 2.创建sql语句
            String sql = "select * from account";
            try(
                    // 3.获取连接对象
                    Connection conn = DriverManager.getConnection(
                            "jdbc:mysql://localhost:3306/db3?useSSL=true",
                            "root",
                            "root");
                    // 4.获取执行sql语句对象
                    Statement stmt = conn.createStatement()
            ){
                // 5.执行sql
                ResultSet rs = stmt.executeQuery(sql);
                // 6.处理结果集
                while(rs.next()){
                    // 获取id
                    int id = rs.getInt("id");
                    // 获取姓名
                    String name = rs.getString("name");
                    // 获取账户余额
                    double balance = rs.getDouble("balance");
                    // 正确的处理应该是封装为对象,进行处理,这就简单展示下
                    System.out.println("id = " + id + ", name = " + name + ", balance = " + balance);
                }

            } catch (SQLException e) {
                e.printStackTrace();
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }

    }
PreparedStatement:执行动态sql的靶子

功能:

  1. 实行动态的sql
    1. SQL注入问题:在拼接sql时,有一些sql的出格重要性字与字符串的拼凑。会导致安全性问题
      1. 输入用户无论,输入密码:a’ or ‘a’ = ‘a
      2. sql:select * from user where username = ‘fhdsjkf’ and
        password = ‘a’ or ‘a’ = ‘a’
    2. 釜底抽薪sql注入问题:使用PreparedStatement对象来化解
    3. 预编译的SQL:参数使用?作为占位符
    4. 步骤:
      1. 导入驱动jar包 mysql-connector-java-5.1.45-bin.jar
      2. 注册驱动
      3. 获取数据库连接对象 Connection
      4. 定义sql
        • 小心:sql的参数使用?作为占位符。 如:select * from
          user where username = ? and password = ?;
      5. 收获执行sql语句的对象 PreparedStatement
        Connection.prepareStatement(String sql)
      6. 给?赋值:
        • 方法: setXxx(参数1,参数2)
          • 参数1:?的职编号 从1 开
          • 参数2:?的值
      7. 行sql,接受返回结果,不需传递sql语句
      8. 处理结果
      9. 自由资源
    5. 小心:后期还见面采用PreparedStatement来好增删改查的具备操作
      1. 足预防SQL注入
      2. 频率还胜似

打包工具类

src下db.properties的信息:

# 驱动
driver=com.mysql.jdbc.Driver
# url
url=jdbc:mysql://127.0.0.1:3306/db3?useSSL=true
# 用户
username=root
# 密码
password=root

卷入的工具类如下:

public class JDBCUtils {

    private static String driver;
    private static String url;
    private static String username;
    private static String password;

    static{
        try {
            // 读取配置文件
            InputStream inputStream = JDBCUtils.class.getClassLoader().getResourceAsStream("db.properties");
            Properties pro = new Properties();
            pro.load(inputStream);
            // 静态变量赋值
            driver = pro.getProperty("driver");
            url = pro.getProperty("url");
            username = pro.getProperty("username");
            password = pro.getProperty("password");
            // 注册驱动
            Class.forName(driver);
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }

    /**
     * 获取连接对象
     * @return 返回连接对象
     */
    public static Connection getConn() throws SQLException {
        return DriverManager.getConnection(url,username,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 rs
     * @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();
            }
        }
    }

}

事务管理

  1. 工作:一个暗含多独步骤的政工操作。如果是事情操作让事务管理,则立刻多只步骤要么以打响,要么同时失败。
  2. 操作:
    1. 展事务
    2. 付业务
    3. 回滚事务
  3. 运用Connection对象来保管工作

    • 开启事务:setAutoCommit(boolean autoCommit)
      :调用该法设置参数为false,即打开事务

      • 以实施sql之前被事务
    • 交付业务:commit()
      • 当所有sql都施行了提交业务
    • 回滚事务:rollback()
      • 以catch中回滚事务

    测试:

     public static void main(String[] args) {
         Connection conn = null;
         PreparedStatement pstmt1 = null;
         PreparedStatement pstmt2 = null;
         try {
             // 1.创建sql,转账的sql
             String sql1 = "UPDATE ACCOUNT SET BALANCE = BALANCE - ? WHERE ID = ?";
             String sql2 = "UPDATE ACCOUNT SET BALANCE = BALANCE + ? WHERE ID = ?";
             // 2.获取连接对象
             conn = JDBCUtils.getConn();
    
             // 开启事务
             conn.setAutoCommit(false);
    
             // 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) {
             if(conn != null) {
                 try {
                     // 事务回滚
                     conn.rollback();
                 } catch (SQLException e1) {
                     e1.printStackTrace();
                 }
             }
             e.printStackTrace();
         } finally {
             JDBCUtils.close(pstmt1,conn);
             JDBCUtils.close(pstmt2,null);
         }
     }
    

相关文章

发表评论

电子邮件地址不会被公开。 必填项已用*标注

网站地图xml地图