JDBC（二）

  1 /**
  2  * @author only
  3  */
  4 public class testConnection {
  5 
  6     //连接数据库方式一
  7     @Test
  8     public void test1() throws SQLException {
  9         Driver driver = new com.mysql.jdbc.Driver();
 10         String url = "jdbc:mysql://localhost:3306/bjpowernode";
 11         Properties info = new Properties();
 12         info.setProperty("user","root");
 13         info.setProperty("password","111");
 14 
 15         Connection conn = driver.connect(url,info);
 16         System.out.println(conn);
 17     }
 18 
 19     //连接数据库方式二:对方式一的迭代：在如下的程序中不出现第三方的API，使得程序具有更好的可移植性
 20     @Test
 21     public void test2() throws Exception {
 22         //1.使用反射获取Driver实现类对象
 23         Class clazz = Class.forName("com.mysql.jdbc.Driver");
 24         Driver driver = (Driver) clazz.newInstance();
 25         //2.提供要连接的数据库
 26         String url = "jdbc:mysql://localhost:3306/bjpowernode";
 27         //3.将用户名和密码封装在properties中，使用properties对象提供需要的用户名和密码
 28         Properties info = new Properties();
 29         info.setProperty("user","root");
 30         info.setProperty("password","111");
 31         //4.获取连接
 32         Connection conn = driver.connect(url,info);
 33         System.out.println(conn);
 34     }
 35 
 36     //连接数据库方式三：使用DriverManager替换Driver
 37     @Test
 38     public void test3() throws Exception {
 39         //1.使用反射获取Driver实现类对象
 40         Class clazz = Class.forName("com.mysql.jdbc.Driver");
 41         Driver driver = (Driver) clazz.newInstance();
 42         //2.提供另外三个连接的基本信息：
 43         String url = "jdbc:mysql://localhost:3306/bjpowernode";
 44         String user = "root";
 45         String password = "111";
 46 
 47         //3.注册驱动
 48         DriverManager.registerDriver(driver);
 49         //4.获取连接(也可以传入properties对象)
 50         Connection conn = DriverManager.getConnection(url, user, password);
 51         System.out.println(conn);
 52     }
 53 
 54     //连接数据库方式四：可以仅加载驱动，而不用显示的注册驱动
 55     @Test
 56     public void test4() throws Exception {
 57         //1.提供另外三个连接的基本信息：
 58         String url = "jdbc:mysql://localhost:3306/bjpowernode";
 59         String user = "root";
 60         String password = "111";
 61 
 62         //2.可以仅使用反射加载驱动类，获取Driver实现类对象。无需再注册是因为，Driver的实现类中进行了注册操作。
 63         Class.forName("com.mysql.jdbc.Driver");
 64         //Driver driver = (Driver) clazz.newInstance();
 65         //注册驱动
 66         //DriverManager.registerDriver(driver);
 67 
 68         //3.获取连接(也可以传入properties对象)
 69         Connection conn = DriverManager.getConnection(url, user, password);
 70         System.out.println(conn);
 71     }
 72 
 73 
 74     /**连接数据库方式五（最终版）：将数据库连接的4个基本信息(第4个为数据库的驱动类名)声明在配置文件中，通过读取配置文件的方式，获取连接
 75      * 这种方式的好处？
 76      * 1.实现了数据与代码的分离（实现了数据和代码的解耦合）。防止硬编码（代码写死）。当需要更改时仅改配置文件即可。
 77      * 2.如果需要修改配置文件信息，可以避免程序重新打包。
 78      * */
 79     @Test
 80     public void test5() throws Exception {
 81         //1.读取配置文件中的4个基本信息
 82         //类的加载器下的主要方法getResourceAsStream()获取类路径下的指定文件的输入流
 83         InputStream is = testConnection.class.getClassLoader().getResourceAsStream("jdbc.properties");
 84         Properties pros = new Properties();
 85         pros.load(is);
 86         String user = pros.getProperty("user");
 87         String password = pros.getProperty("password");
 88         String url = pros.getProperty("url");
 89         String driverClass = pros.getProperty("driverClass");
 90 
 91         //2.可以仅使用反射加载驱动类，获取Driver实现类对象。无需再注册是因为，Driver的实现类中进行了注册操作。
 92         Class.forName("com.mysql.jdbc.Driver");
 93         //Driver driver = (Driver) clazz.newInstance();
 94         //注册驱动
 95         //DriverManager.registerDriver(driver);
 96 
 97         //3.获取连接(也可以传入properties对象)
 98         Connection conn = DriverManager.getConnection(url, user, password);
 99         System.out.println(conn);
100     }
101 }

 1     //使用PreparedStatement实现通用的增删改操作，将重复步骤封装起来
 2     @Test
 3     public void updateTest() throws Exception {
 4         //删除
 5         String sql = "delete from customers where id = ?";
 6         update(sql,3);
 7 
 8         //改，由于表名‘order’与 sql语句中的关键字order重复，需要加着重符''；
 9         String sql = "update 'order' set name= ?,where id = ?";
10         update(sql,"牛顿",5); //由于sql语句中有两个占位符，所以第二个可变形参args需要传两个参数
11 
12     }
13 
14     //通用的增删改操作,用到可变形参。（可以传任意多个形参）
15     public void update(String sql,Object ...args){ //sql中的占位符个数要与args长度一致,args是一个数组类型
16         Connection conn = null;
17         PreparedStatement ps = null;
18         try {
19             //1.获取数据库连接
20             conn = getConnection();
21             //2.预编译sql语句，返回PreparedStatement实例
22             ps = conn.prepareStatement(sql);
23             //3.填充占位符
24             for (int i=0; i<args.length; i++){
25                 ps.setObject(i+1,args[i]); //注意setObject从 1 开始填充
26             }
27             //4.执行
28             ps.execute();
29         } catch (Exception e) {
30             e.printStackTrace();
31         }
32         //5.资源的关闭
33         closeResource(conn,ps);
34     }
35 
36     //获取数据库连接
37     public Connection getConnection() throws Exception{
38         //1.读取配置文件中的4个基本信息
39         InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties");
40         Properties pros = new Properties();
41         pros.load(is);
42         String user = pros.getProperty("user");
43         String password = pros.getProperty("password");
44         String url = pros.getProperty("url");
45         String driverClass = pros.getProperty("driverClass");
46 
47         //2.可以仅使用反射加载驱动类，获取Driver实现类对象。无需再注册是因为，Driver的实现类中进行了注册操作。
48         Class.forName("com.mysql.jdbc.Driver");
49 
50         //3.获取连接(也可以传入properties对象)
51         Connection conn = DriverManager.getConnection(url, user, password);
52         return conn;
53     }
54 
55     //关闭连接和Statement操作
56     public void closeResource(Connection conn, PreparedStatement ps){
57         try {
58             if(conn!=null)
59                 conn.close();
60         }catch (Exception e){
61             e.printStackTrace();
62         }
63         try {
64             if(ps!=null)
65                 ps.close();
66         }catch (Exception e){
67             e.printStackTrace();
68         }
69     }

 1     //测试查询操作
 2     @Test
 3     public void queryTest(){
 4         String sql = "select id cid, name cname, email cemail from customer where id < ?";
 5         List<Customer> customer = query(Customer.class, sql, 10);
 6         System.out.println(customer);
 7     }
 8 
 9     //实现通用的查询操作,返回查找到数据的对象
10     @Test
11     public <T> List<T> query(Class<T> clazz, String sql, Object ...args){
12         Connection conn = null;
13         PreparedStatement ps = null;
14         ResultSet rs = null;
15         try {
16             //1.获取数据库连接
17             conn = getConnection();
18             //2.预编译sql语句，返回PreparedStatement实例
19             ps = conn.prepareStatement(sql);
20             //3.填充占位符
21             for (int i=0; i<args.length; i++){
22                 ps.setObject(i+1,args[i]); //注意setObject从 1 开始填充
23             }
24             //4.执行查询(注意这里不是execute了)并得到结果
25             rs = ps.executeQuery();
26             //5.获取结果的元数据，用于得到字段名，和列数
27             ResultSetMetaData rsmd =  rs.getMetaData();
28             int colnum = rsmd.getColumnCount();
29             List<T> ret = new ArrayList<>();
30             while(rs.next()){
31                 T t = clazz.newInstance();
32                 //处理结果集一行数据中的每一列
33                 for(int i=0; i<colnum; i++){
34                     //获取列值
35                     Object colvalue = rs.getObject(i+1);
36                     //获取列名(有别名则获取到别名)
37                     String collabel = rsmd.getColumnLabel(i+1);
38                     //通过反射，给t对象的coluname属性赋值为colvalue
39                     Field field = clazz.getDeclaredField(collabel);
40                     field.setAccessible(true);
41                     field.set(t,colvalue);
42                 }
43                 ret.add(t);
44             }
45             return ret;
46         } catch (Exception e) {
47             e.printStackTrace();
48         } finally {
49             //5.资源的关闭
50             closeResource(conn, ps, rs);
51         }
52         return null;
53     }