美文网首页
JDBC入门

JDBC入门

作者: _琳哥 | 来源:发表于2017-11-10 11:04 被阅读86次

    JDBC连接数据库
    • 三种连接数据库方式
    import org.junit.Test;
    
    import java.sql.Connection;
    import java.sql.Driver;
    import java.sql.DriverManager;
    import java.util.Properties;
    
    public class Test_JDBC_Connect {
    
        /*
                             jdbc协议:数据库子协议://主机:端口/连接的数据库
         */
        private String url = "jdbc:mysql://192.168.64.131:3306";
        // 用户名
        private String user = "root";
        // 密码
        private String password = "mysql";
    
        /**
         * 第一种方法
         *
         * @throws Exception e
         */
        @Test
        public void testJDBC1() throws Exception {
    
            //1.创建驱动程序类对象
            Driver driver = new com.mysql.jdbc.Driver(); //新版本
            //Driver driver = new org.gjt.mm.mysql.Driver(); //旧版本
    
            //设置用户名和密码
            Properties props = new Properties();
            props.setProperty("user", user);
            props.setProperty("password", password);
    
            //2.连接数据库,返回连接对象
            Connection conn = driver.connect(url, props);
    
            System.out.println(conn);
        }
    
        /**
         * 使用驱动管理器类连接数据库(注册了两次,没必要)
         *
         * @throws Exception e
         */
        @Test
        public void testJDBC2() throws Exception {
            Driver driver = new com.mysql.jdbc.Driver();
            //Driver driver2 = new com.oracle.jdbc.Driver();
            //1.注册驱动程序(可以注册多个驱动程序)
            DriverManager.registerDriver(driver);
            //DriverManager.registerDriver(driver2);
    
            //2.连接到具体的数据库
            Connection conn = DriverManager.getConnection(url, user, password);
            System.out.println(conn);
    
        }
    
        /**
         * (推荐使用这种方式连接数据库)
         * 推荐使用加载驱动程序类  来 注册驱动程序
         *
         * @throws Exception 异常
         */
        @Test
        public void testJDBC3() throws Exception {
            //通过得到字节码对象的方式加载静态代码块,从而注册驱动程序
            Class.forName("com.mysql.jdbc.Driver");
            Connection conn = DriverManager.getConnection(url, user, password);
            System.out.println(conn);
        }
    }
    
    JDBC接口核心的API
    java.sql.*   和  javax.sql.*
    
    • Driver接口: 表示java驱动程序接口。所有的具体的数据库厂商要来实现此接口。

      • connect(url, properties): 连接数据库的方法。
        • url: 连接数据库的URL
        • URL语法: jdbc协议:数据库子协议://主机:端口/数据库
        • user: 数据库的用户名
        • password: 数据库用户密码
    • DriverManager类: 驱动管理器类,用于管理所有注册的驱动程序

      • registerDriver(driver) : 注册驱动类对象
      • Connection getConnection(url,user,password); 获取连接对象
    • Connection接口: 表示java程序和数据库的连接对象。

      • Statement createStatement() : 创建Statement对象
      • PreparedStatement prepareStatement(String sql) 创建PreparedStatement对象
      • CallableStatement prepareCall(String sql) 创建CallableStatement对象
    • Statement接口: 用于执行静态的sql语句

      • int executeUpdate(String sql) : 执行静态的更新sql语句(DDL,DML)
      • ResultSet executeQuery(String sql) :执行的静态的查询sql语句(DQL)
    • PreparedStatement接口:用于执行预编译sql语句

      • int executeUpdate() : 执行预编译的更新sql语句(DDL,DML)
        -ResultSet executeQuery() : 执行预编译的查询sql语句(DQL)
    • CallableStatement接口:用于执行存储过程的sql语句(call xxx)

      • ResultSet executeQuery() : 调用存储过程的方法
    • ResultSet接口:用于封装查询出来的数据

      • boolean next() : 将光标移动到下一行
      • getXX() : 获取列的值
    使用Statement执行DML语句
        /**
         * 增加数据 (更新和删除只是sql的不同)
         */
        public void testInsert(){
            Connection conn = null;
            Statement statement = null;
            try{
                conn = JDBCUtil.getConnection();    //获取Connection从前文中有方法
                // 3.创建Statement
                statement = conn.createStatement();
    
                // 4.准备SQL
                String sql = "INSERT INTO student(name,gender) VALUES ('李四','男')";
    
                // 5.执行sql语句
                int count = statement.executeUpdate(sql);
    
                System.out.println(count);
            }catch(Exception e){
                e.printStackTrace();
            }finally{
                // 6.关闭连接(顺序:后打开的先关闭)
                JDBCUtil.close(conn, statement);
            }
        }
    
    使用Statement执行DQL语句(查询操作)
        public void testSelect(){
            Connection conn = null;
            Statement statement = null;
            try{
                conn = JDBCUtil.getConnection();
                // 3.创建Statement
                statement = conn.createStatement();
    
                // 4.准备SQL
                String sql = "SELECT * FROM student";
    
                // 5.执行sql语句
                ResultSet resultSet = statement.executeQuery(sql);
    
                while(resultSet.next()){
                    System.out.println("id = " + resultSet.getInt("id"));
                    System.out.println("name = " + resultSet.getString("name"));
                    System.out.println("gender = " + resultSet.getString("gender"));
                }
            }catch(Exception e){
                e.printStackTrace();
            }finally{
                // 6.关闭连接(顺序:后打开的先关闭)
                JDBCUtil.close(conn, statement);
            }
        }
    
    使用PreparedStatement执行sql语句
    
        /**
         * 增加 (更新,删除,查询都是相同的)
         */
        @Test
        public void testInsert() {
            Connection conn = null;
            PreparedStatement stmt = null;
            try {
                //1.获取连接
                conn = JdbcUtil.getConnection();
                
                //2.准备预编译的sql
                String sql = "INSERT INTO student(name,gender) VALUES(?,?)"; //?表示一个参数的占位符
                
                //3.执行预编译sql语句(检查语法)
                stmt = conn.prepareStatement(sql);
                
                //4.设置参数值
                /**
                 * 参数一: 参数位置  从1开始
                 */
                stmt.setString(1, "李四");
                stmt.setString(2, "男");
                
                //5.发送参数,执行sql
                int count = stmt.executeUpdate();
                
                System.out.println("影响了"+count+"行");
                
            } catch (Exception e) {
                e.printStackTrace();
                throw new RuntimeException(e);
            } finally {
                JdbcUtil.close(conn, stmt);
            }
        }
    
    PreparedStatement 与 Statment 的对比
    1. 语法不同:PreparedStatement可以使用预编译的sql,而Statment只能使用静态的sql
    2. 效率不同: PreparedStatement可以使用sql缓存区,效率比Statment高
    3. 安全性不同: PreparedStatement可以有效防止sql注入,而Statment不能防止sql注入。

    相关文章

      网友评论

          本文标题:JDBC入门

          本文链接:https://www.haomeiwen.com/subject/vtcymxtx.html