JDBC

建立数据库连接

          //1.使用Driver连接数据库，创建Driver实现类对象
    Driver driver = new Driver();
    
    //2.准备连接数据库的基本信息
    String url = "jdbc:mysql://127.0.0.1:3306/test";
    Properties info = new Properties();
    
    info.put("user", "root");
    info.put("password", "root");
    
    //3.调用Driver的接口connect（url， info） 获取数据库连接
    Connection connection = driver.connect(url, info);

简化连接不同数据库，将连接数据库信息存储到文件中

    InputStream in = TestJDBC.class.getClassLoader().getResourceAsStream("jdbc.properties");
    Properties properties = new Properties();
    properties.load(in);
    driverClass = properties.getProperty("driver");
    jdbcUrl = properties.getProperty("jdbcUrl");
    user = properties.getProperty("user");
    password = properties.getProperty("password");

    Driver driver = (Driver)Class.forName(driverClass).newInstance();
    
    Properties info = new Properties();
    info.put("user", user);
    info.put("password", password);
    
    Connection connection = driver.connect(jdbcUrl, info);

通过获取驱动连接数据库，可同时获得多个驱动

    Class.forName(driverClass);
    Connection connection = DriverManager.getConnection(jdbcUrl, user, password);

执行Sql语句

insert，update， delete操作

    //1.获取数据库连接
    Connection conn = getConnection();
    
    //2.准备sql语句
    String sql = "insert into customers(name, email, birth) Values('Wayne', 'wayne@gmail.com', '1993-03-16');";
    
    //3.执行插入
    //获取Statement对象
    Statement statement = conn.createStatement();
    //执行sql语句，只能是insert，update，delete
    statement.executeUpdate(sql);
    
    //4.关闭连接，在finally中关闭
    statement.close();
    conn.close();

select操作

• 通过调用 Statement 对象的 excuteQuery() 方法创建该对象

• ResultSet 对象以逻辑表格的形式封装了执行数据库操作的结果集

• ResultSet 对象维护了一个指向当前数据行的游标，初始的时候，游标在第一行之前，可以通过 ResultSet 对象的 next() 方法移动到下一行

    //1.获取数据库连接
    Connection conn = getConnection();
    
    //2.获取Statement
    Statement statement = conn.createStatement();
    
    //3.准备sql语句
    String sql = "select * from customers";
    
    //4.执行查询
    ResultSet rs = statement.executeQuery(sql);
    
    //5.处理ResultSet
    while(rs.next()){
        int id = rs.getInt(1);
        String name = rs.getString("name");
        String email = rs.getString(3);
        Date birth = rs.getDate(4);
        
        System.out.println(id + " " + name + " " + email + " " + birth);
    }
  

PreparedStatement

• 提高性能

• 防止sql注入

• 便捷sql语句拼写
  //1.创建PreparedStatement
  String sql = "insert into customers(name, email, birth) Values(?,?,?);";
  PreparedStatement ps = conn.prepareStatement(sql);

    //2.赋值
    ps.setString(1, "Luke");
    ps.setString(2, "Luke@gmail.com");
    ps.setDate(3, new Date(new java.util.Date().getTime()));
    
    //3.执行
    ps.executeUpdate();
  

使用ResultSetMetaData和反射，简化查询，构造方法完成对不同表查询，结果生成不同对象

public static <T> T testResultSetMetaData(Class<T> clazz, String sql, Object...objects) throws Exception{
    //1.建立连接
    Connection conn = getConnection();
    
    //2.获取PreparedStatement
    PreparedStatement ps = conn.prepareStatement(sql);
    
    //3.赋值
    for (int i = 0; i<objects.length; i++){
        ps.setObject(i+1, objects[i]);
    }
    
    //4.执行，并使用ResultSet接受
    ResultSet re = ps.executeQuery();
    
    
    if(re.next()){
        //5.创建clazz对象
        T t = clazz.newInstance();
        
        //6、获取ResultSetMetaData，并放入对象
        ResultSetMetaData rsmd = re.getMetaData();
        for(int i=0; i<rsmd.getColumnCount(); i++){
            String columnLable = rsmd.getColumnLabel(i+1);
            Object columnValue = re.getObject(i+1);
            
            //为对象属性赋值
            Field field = clazz.getDeclaredField(columnLable);
            field.setAccessible(true);
            field.set(t, columnValue);
            
        }
        return t;
    } else {
        return null;
    }
    
}

存储过程

    //1.建立连接 
    Connection conn = getConnection();

    //2.获取CallableStatement
    String sql = "{? = call sum_salary(?,?)}";
     CallableStatement callableStatement = conn.prepareCall(sql);

    //3.注册参数
    callableStatement.registerOutParameter(1,Types.NUMERTIC);
    callableStatement.registerOutParameter(3,Types.NUMERTIC);

    //4.给参数赋值
    callableStatement.setInt(2,80);

    //5.执行
    callableStatement.execute();

    //6.获取执行结果
    double sunSalary = callableStatement.getDouble(1);
    long empCount = callableStatement.getLong(3);

小结

• java.sql.DriverManager用来装载驱动程序，获取数据库连接。
• java.sql.Connection完成对某一指定数据库的联接
• java.sql.Statement在一个给定的连接中作为SQL执行声明的容器，他包含了两个重要的子类型。
  • Java.sql.PreparedSatement 用于执行预编译的sql声明
  • Java.sql.CallableStatement用于执行数据库中存储过程的调用
    java.sql.ResultSet对于给定声明取得结果的途径