JDBC

概述

1、JDBC（Java DataBase Connectivity）java 数据库连接
2、是一种用于执行SQL语句的java API ，可以为多种关系型数据库提供统一访问，它由一组java语言编写的类和接口组成。
JDBC API:
供程序员调用的接口与类，集成在java.sql 包中
DriverManager类作用：管理各种不同的jdbc驱动；
Connection 接口 与特定数据库的连接
Statement 接口 执行sql
PreparedStatement 接口 执行sql
ResultSet 接口 接收查询结果

获取连接的方式

我们这里直接给出最终版的通用的连接方式：

首相我们需要有一个文件存放用户名，密码，以及连接地址和JDBC下MySQL下的driver

这个文件包含下面内容：

代码：
下面展示一些 内联代码片。

// 1 读取配置文件中 的 4个基本信息
        InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties");
        Properties pros = new Properties();
        pros.load(is);
        String user = pros.getProperty("user");
        String password = pros.getProperty("password");
        String url = pros.getProperty("url");
        String driverClass = pros.getProperty("driverClass");
        // 2 加载驱动
        Class.forName(driverClass);
        // 3 获取连接
        Connection conn = DriverManager.getConnection(url, user, password);

这就成功连接到了数据库

进行封装使用

我们可以把连接数据库和资源关闭这些代码进行封装：

进行封装之后便可以直接调用：
实例如下：

//查询

        //1 获取连接
        Connection conn = Utility.getConnection();
        //2 预编译
        String sql="select id,username,password from admin where id=5 ";
        PreparedStatement ps = conn.prepareStatement(sql);
        //执行
        ResultSet rs = ps.executeQuery();
        if(rs.next()) {
            int id = rs.getInt(1);
            String username = rs.getString(2);
            String password = rs.getString(3);
            User user=new User(id,username,password);
            System.out.println(user);
        }
        //3 关闭资源
        Utility.closeResources(conn,ps,rs);

运行结果：

封装升级版查询返回一个集合

1:使用ORM编程思想，写出一个通用的方法，方便后期做查询使用

 public static <T> List<T> getTargetList(Class<T> calzz,String sql, Object... args){
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            //1获取连接
            conn = Utility.getConnection();
            //2预编译sql
            ps = conn.prepareStatement(sql);
            //3填充占位符
            for (int i = 0; i < args.length; i++) {
                ps.setObject(i + 1, args[i]);
            }
            //4 执行
            rs = ps.executeQuery();
            //获取结果集的元数据：ResultSetmetaDate
            ResultSetMetaData rsmd = rs.getMetaData();
            //通过ResultSetMetaData获取结果集中的列数
            int columnCount = rsmd.getColumnCount();
            ArrayList<T> list = new ArrayList<>();
            while (rs.next()) {
                T t = calzz.newInstance();
                //处理结果集中每一行数据的每个列
                for (int i = 0; i < columnCount; i++) {
                    Object columnClassvalue = rs.getObject(i + 1);
                    //获取每个列名
                    String columnName = rsmd.getColumnName(i + 1);
                    //给User对象 columnClassName属性赋值，赋值为columnClassvalue ：通过反射
                    Field  field = calzz.getDeclaredField(columnName);
                    field.setAccessible(true);
                    field.set(t, columnClassvalue);
                }
                list.add(t);
            }
            return list;
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            Utility.closeResources(conn, ps, rs);
        }
        return null;
    }
}

2：实例：调用查询方法

运行如下代码:

 String sql2="select id,username,password from admin where id>?";
        List<User> list = Utility.getTargetList(User.class, sql2, 4);
        list.forEach(System.out::println);

先看数据库中数据：

运行上述代码得出：

总结步骤

1. 获取连接，连接到数据库
2. 预编译Sql语句
3. 填充占位符
4. 执行
   1. 获取结果集的元数据：ResultSetmetaDate
   2. 通过ResultSetMetaData获取结果集中的列数
   3. 处理结果集中每一行数据的每个列
   4. 获取每个列名
   5. 给实例化对象的columnName属性赋值，赋值为columnValue ：通过反射
   6. 把对象添加到集合中
   7. 返回一个集合
5. 关闭资源

总结：两个字 “ 绝 ”