您的位置:威尼斯官方网站 > 威尼斯官方网站登录 > 举个大致例子

举个大致例子

发布时间:2019-10-15 03:30编辑:威尼斯官方网站登录浏览(166)

    JDBC的简约介绍

    概念

    • JDBC : Java Database Connectivity,java连接数据库,使用Java操作数据库的手艺。
    • 本质 : 其实正是sun集团定义的一套操作全部关系型数据库的条条框框,即接口。
      梯次数据库商家去落到实处那套接口,提供数据库操作驱动jar包,我们得以动用那套
      接口举行(JDBC)编制程序,真正举办的代码是驱动jar包的兑现类。

    急速入门

    本人使用的是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);
           }
       }
      

    本文由威尼斯官方网站发布于威尼斯官方网站登录,转载请注明出处:举个大致例子

    关键词:

上一篇:借使设置为无符号的

下一篇:没有了