day06_JDBC学习笔记

黑泽君

发布于 2018-10-11 11:14:28

6590

发布于 2018-10-11 11:14:28

文章被收录于专栏：黑泽君的专栏

============================================================

一、JDBC概述

　　为什么要使用JDBC？

　　JDBC：Java DataBase Connectivity，是SUN公司提供的一套操作数据库的标准规范(技术)。

　　JDBC与数据库驱动的关系：接口与实现的关系。

　　JDBC规范（掌握四个核心对象）：

　　　　DriverManager类：用于注册驱动(创建连接对象)。 java.sql.DriverManager;

　　　　Connection接口：表示与数据库创建的连接。java.sql.Connection;

　　　　Statement接口：操作数据库sql语句的对象，并返回相应结果的对象。 java.sql.Statement;

　　　　　　preparedStatement接口：预编译对象，是Statement对象的子类。用于解决sql的注入问题。实际用的是这个类。java.sql.PreparedStatement;

　　　　ResultSet接口：结果集或一张虚拟表(客户端存表数据的对象)。 java.sql.ResultSet;

　　开发一个JDBC程序的准备工作：

　　　　> JDBC规范在哪里：

　　　　 JDK中：

　　　　　　java.sql.*; // jdk自身带的包

　　　　　　javax.sql.*; // 扩展包(企业级开发)

　　　　> 数据库厂商提供的驱动：jar文件 (也即具体的实现)

　　　　*.jar

============================================================

二、开发一个JDBC程序（重要）

　　使用JDBC技术，通过java代码实现查询数据库中的数据并显示在java的控制台中。

　　1、先创建数据库表，并向表中添加测试数据。

　　create database day06;
　　use day06;
 
　　create table users (
   　　 id int primary key auto_increment,
    　　name varchar(40),
    　　password varchar(40),
    　　email varchar(60),
    　　birthday date
　　) character set utf8 collate utf8_general_ci;
 
　　insert into users(name, password, email, birthday) values('zs', '123456', 'zs@sina.com', '1980-12-04');
　　insert into users(name, password, email, birthday) values('lisi', '123456', 'lisi@sina.com', '1981-12-04');
　　insert into users(name, password, email, birthday) values('wangwu', '123456', 'wangwu@sina.com', '1979-12-04');

　　2、创建Java Project项目，添加数据库驱动(xxx.jar)。

　　3、实现JDBC操作。

============================================================

三、JDBC常用的类和接口详解

　　1、java.sql.Drivermanager类：注册驱动、建立连接

　　a、注册驱动

　　　　DriverManager.deregisterDriver(new com.mysql.jdbc.Driver()); // 不建议使用

　　　　原因有2个：

　　　　　　> 导致驱动被注册2次。

　　　　　　> 强烈依赖数据库的驱动jar包（若把奶瓶的Build Path给Remove掉，代码就会报错，就能看到效果）

　　　　解决办法：

　　　　　　Class.forName("com.mysql.jdbc.Driver"); // 把奶瓶的Build Path给Remove掉，代码也不会报错了

　　　　　　用到反射机制的知识：靠类的全路径来加载，解耦合了，不依赖数据库的驱动jar包了，以后会把上面的字符串放在配置文件里，更灵活了，便于后期维护。

　　b、与数据库建立连接

　　　　DriverManager类的静态方法：

　　　　　　public static Connection getConnection(String url, String user, String password) 试图建立到给定数据库 URL 的连接

　　　　　　DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");

　　　　　　URL:是SUN公司与数据库厂商之间的一种协议。

　　　　　　jdbc:mysql://localhost:3306/day06

　　　　　　协议子协议 IP 数据库端口号数据库名称

　　　　　　mysql:jdbc:mysql://localhost:3306/day14 或者

　　　　　　jdbc:mysql:///day14（默认连接本机的数据库）

　　　　　　oracle:jdbc:oracle:thin:@localhost:1521:sid 瘦客户端，比如：玩页游协议

　　　　　　子协议子子协议 IP 数据库端口号数据库名称

　　　　　　oracle:jdbc:oracle:thick:@localhost:1521:sid 胖客户端，比如：LOL、魔兽世界(需要下载软件)

　　　　与数据库建立连接的方式

　　　　第一种：

// public static Connection getConnection(String url, String user, String password)

　　　　　　 Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");

　　　　第二种:

　　　　　　// public static Connection getConnection(String url, Properties info)

Properties info = new Properties(); // 要参考数据库文档

info.setProperty("user", "root");

info.setProperty("password", "root");

Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", info);

　　　　第三种：

　　　　　　// public static Connection getConnection(String url)

Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day06?user=root&password=root");

// 模拟表单form提交的两种方式：GET和POST

　　　　实际开发常用第一种。

　　扩展内容：演示3个案例的话需要写3个main方法，所以有了快速测试的方法 ==> junit技术

　　　　package com.itheima.junitdemo;

　　　　public class Calc {

public int add(int a, int b) {

return a + b;

　　　　}

public double div(double a, int b) {

return a / b;

　　　　}

　　　　-------------------------------------------

　　　　package com.itheima.junitdemo;

　　　　import org.junit.Assert;

　　　　import org.junit.Test;

　　　　// 注：测试的方法有要求：不能有返回值，不能有参数。

　　　　public class TestCalc {

@Test

public void test1(){

　　　　Calc c = new Calc();

　　　　Assert.assertEquals(8, c.add(3, 5)); // assert 断言

　　　　}

@Test

public void test2(){

　　　　Calc c = new Calc();

　　　　Assert.assertEquals(3, c.div(10, 3),0.4);

　　　　}

-----------------------------------------------------------------------------

2、java.sql.Connection接口：一个连接(与数据库连接的一座桥梁)

　　该接口的实现在数据库驱动jar包中。所有与数据库交互都是基于连接对象的。

　　// 创建执行sql语句的对象Satement(接口)

　　// Connection(接口)的方法：Statement createStatement()

Statement stmt = conn.createStatement();

-----------------------------------------------------------------------------

3、java.sql.Statement接口：操作sql语句，并返回相应结果的对象(小货车)

　　该接口的实现在数据库驱动jar包中。用于执行静态 SQL 语句并返回它所生成结果的对象。

　　// 执行sql语句,该语句返回单个 ResultSet 结果集对象。

　　// Statement(接口)的方法：ResultSet executeQuery(String sql)

　　// 注意；该方法只能执行select语句。

ResultSet rs = stmt.executeQuery("select * from users");

　　// Statement(接口)的方法：int executeUpdate(String sql)

　　// 根据执行的 DML(insert update delete)语句，返回受影响的行数。

　　// 服务器端叫法：insert、delete、update、select （增删改查）

// 客户端的叫法：create、read、update、delete （CRUD）（增删改查）

　　int i = stmt.executeUpdate("INSERT INTO users VALUES (4, 'tom', '123','tom@163.com', '2015-09-28')");

　　int i = stmt.executeUpdate("UPDATE users SET NAME = 'jerry', PASSWORD = '333', email = 'jerry@163.com' WHERE id = 4");

　　int i = stmt.executeUpdate("DELETE FROM users WHERE id = 4");

　　// Statement(接口)的方法:boolean execute(String sql)

　　// 这个方法很奇葩！！！

　　// 此方法可以执行任意sql语句。返回boolean值，表示是否返回ResultSet结果集。

// 仅当执行select语句，且有返回结果时返回true, 其它语句都返回false。

-----------------------------------------------------------------------------

4、java.sql.ResultSet接口：结果集(客户端存表数据的对象)

　　a、封装结果集

　　　　提供一个游标，默认游标指向结果集第一行之前(即表头)。

　　　　调用一次boolean next()，游标向下移动一行。

　　　　提供一些getXxx()方法。

-------------------------------------------

　　　　将结果集中的数据封装到javaBean类中，javaBean就是一普通java类，该类中只有private类型的成员变量、无参构造方法和getter/setter方法。

　　　　java的数据类型与数据库中的类型的关系:

　　　　JAVA DB

　　　　byte tityint 1字节

　　　　short smallint 2字节

　　　　int int 4字节

　　　　long bigint 8字节

　　　　float float

　　　　double double

　　　　String char 或者 varchar

　　　　Date date

　　　-------------------------------------------

ResultSet结果集封装数据的方法：

　　　　　　Object getObject(int columnIndex) 根据序号取值，索引从1开始

　　　　　　Object getObject(String ColomnName) 根据列名取值

　　　　　　boolean next() 将光标从当前位置向下移动一行

　　　　　　int getInt(int colIndex) 以int 形式获取ResultSet结果集当前行指定列号值

　　　　　　int getInt(String colLabel) 以int 形式获取ResultSet结果集当前行指定列名值

　　　　　　float getFloat(int colIndex) 以float 形式获取ResultSet结果集当前行指定列号值

　　　　　　float getFloat(String colLabel) 以float形式获取ResultSet结果集当前行指定列名值

　　　　　　String getString(int colIndex) 以String 形式获取ResultSet结果集当前行指定列号值

　　　　　　String getString(String colLabel) 以String 形式获取ResultSet结果集当前行指定列名值

　　　　　　Date getDate(int columnIndex) 以Date 形式获取ResultSet结果集当前行指定列号值

　　　　　　Date getDate(String columnName) 以Date 形式获取ResultSet结果集当前行指定列名

　　　　　　void close() 关闭ResultSet 对象

-------------------------------------------

 1 package com.itheima.entitydemo;
 2 
 3 import java.util.Date;
 4 
 5 /*
 6  * 一般实体类的类名和数据库的表名一致。(注意：若数据库的表名单词带s的，则实体类名就去掉s)
 7  * 实体类的成员变量名和数据库表中的列名一致。(这是一个约定，网站开发的时候会提到)
 8  */
 9 public class User {
10     private int id;
11     private String name;
12     private String password;
13     private String email;
14     private Date birthday;
15 
16     public int getId() {
17         return id;
18     }
19 
20     public void setId(int id) {
21         this.id = id;
22     }
23 
24     public String getName() {
25         return name;
26     }
27 
28     public void setName(String name) {
29         this.name = name;
30     }
31 
32     public String getPassword() {
33         return password;
34     }
35 
36     public void setPassword(String password) {
37         this.password = password;
38     }
39 
40     public String getEmail() {
41         return email;
42     }
43 
44     public void setEmail(String email) {
45         this.email = email;
46     }
47 
48     public Date getBirthday() {
49         return birthday;
50     }
51 
52     public void setBirthday(Date birthday) {
53         this.birthday = birthday;
54     }
55 
56     @Override
57     public String toString() {
58         return "User [id=" + id + ", name=" + name + ", password=" + password + ", email=" + email + ", birthday="
59                 + birthday + "]";
60     }
61 
62 }

  1 package com.itheima.entitydemo;
  2 
  3 import java.sql.Connection;
  4 import java.sql.DriverManager;
  5 import java.sql.ResultSet;
  6 import java.sql.Statement;
  7 import java.util.ArrayList;
  8 import java.util.List;
  9 
 10 import org.junit.Test;
 11 
 12 /* 
 13  * 服务器端叫法：insert、delete、update、select （增删改查）
 14  * 客户端的叫法：create、read、update、delete （CRUD）（增删改查）
 15  */
 16 public class TestCRUD {
 17 
 18     @Test
 19     public void testSelect() throws Exception {
 20         // 加载驱动
 21         Class.forName("com.mysql.jdbc.Driver");
 22         
 23         // 获取连接对象Connection(注意：能用接口的就不用实现类，多态=>对象上传=>向上转型=>里氏替换，利于后期代码扩展)
 24         Connection conn =  DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");
 25         
 26         // 获取执行sql语句的对象Statement 
 27         Statement stmt = conn.createStatement();
 28         
 29         // 执行sql的查询语句，并返回结果
 30         ResultSet rs = stmt.executeQuery("select * from users");
 31         
 32         // 把取到的数据装到集合中
 33         List<User> list = new ArrayList<User>();
 34         
 35         // 处理结果
 36         User u = null;
 37         while (rs.next()) {
 38             u = new User();
 39             u.setId(rs.getInt("id"));
 40             u.setName(rs.getString("name"));
 41             u.setPassword(rs.getString("password"));
 42             u.setEmail(rs.getString("email"));
 43             u.setBirthday(rs.getDate("birthday"));
 44             list.add(u); // 把对象添加到集合中去
 45         }
 46         
 47         // 遍历集合(增强for)
 48         for (User user : list) {
 49             System.out.println(user);
 50         }
 51         
 52         // 关闭资源
 53         rs.close();
 54         stmt.close();
 55         conn.close();
 56     }
 57     
 58     @Test
 59     public void testInsert() throws Exception {
 60         // 加载驱动
 61         Class.forName("com.mysql.jdbc.Driver");
 62         
 63         // 获取连接对象Connection(注意；能用接口的就不用实现类，多态=>对象上传=>向上转型=>里氏替换，利于后期代码扩展)
 64         Connection conn =  DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");
 65         
 66         // 获取执行sql语句的对象Statement 
 67         Statement stmt = conn.createStatement();
 68         
 69         // 执行sql的插入语句，并返回结果
 70         int i = stmt.executeUpdate("INSERT INTO users VALUES (4, 'tom', '123','tom@163.com', '2015-09-28')");
 71         
 72         // 处理返回的结果
 73         if (i > 0) {
 74             System.out.println("success");
 75         }
 76         
 77         // 关闭资源
 78         stmt.close();
 79         conn.close();
 80     }
 81     
 82     @Test
 83     public void testUpdate() throws Exception {
 84         // 加载驱动
 85         Class.forName("com.mysql.jdbc.Driver");
 86         
 87         // 获取连接对象Connection(注意；能用接口的就不用实现类，多态=>对象上传=>向上转型=>里氏替换，利于后期代码扩展)
 88         Connection conn =  DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");
 89         
 90         // 获取执行sql语句的对象Statement 
 91         Statement stmt = conn.createStatement();
 92         
 93         // 执行sql的更新语句，并返回结果
 94         int i = stmt.executeUpdate("UPDATE users SET NAME = 'jerry', PASSWORD = '333', email = 'jerry@163.com' WHERE id = 4");
 95         
 96         // 处理返回的结果
 97         if (i > 0) {
 98             System.out.println("success");
 99         }
100         
101         // 关闭资源
102         stmt.close();
103         conn.close();
104     }
105     
106     @Test
107     public void testDelete() throws Exception {
108         // 加载驱动
109         Class.forName("com.mysql.jdbc.Driver");
110         
111         // 获取连接对象Connection(注意；能用接口的就不用实现类，多态=>对象上传=>向上转型=>里氏替换，利于后期代码扩展)
112         Connection conn =  DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");
113         
114         // 获取执行sql语句的对象Statement 
115         Statement stmt = conn.createStatement();
116         
117         // 执行sql的删除语句，并返回结果
118         int i = stmt.executeUpdate("DELETE FROM users WHERE id = 4");
119         
120         // 处理返回的结果
121         if (i > 0) {
122             System.out.println("success");
123         }
124         
125         // 关闭资源
126         stmt.close();
127         conn.close();
128     }
129     
130 }

　　b、可移动游标的方法(现在很少用了，只有next()还常用)

　　　　ResultSet结果集的方法：

　　　　　　boolean next() 将光标从当前位置向前移一行

　　　　　　boolean previous() 将光标移动到此 ResultSet 对象的上一行

　　　　　　boolean absolute(int row) 参数是当前行的索引，从1开始，根据行的索引定位移动的指定索引行

　　　　　　void afterLast() 将光标移动到末尾，正好位于最后一行之后

　　　　　　void beforeFirst() 将光标移动到开头，正好位于第一行之前（即表头）

-----------------------------------------------------------------------------

　　5、释放资源

　　　　资源有限，要正确关闭。

　　　　原则：在使用对象之前，先判断对象是否为空。

　　　　把某一部分代码加上try...catch...的快捷键：Alt + Shift + Z

 1 package com.itheima.jdbcdemo;
 2 
 3 import java.sql.Connection;
 4 import java.sql.DriverManager;
 5 import java.sql.ResultSet;
 6 import java.sql.SQLException;
 7 import java.sql.Statement;
 8 
 9 /*
10  * 使用JDBC技术，通过java代码实现查询数据库中的数据并显示在java的控制台中。
11  * 
12  *         演示正确释放资源。
13  * 
14  *         把某一部分代码加上try...catch...的快捷键：Alt + Shift + Z
15  */
16 public class Demo4 {
17     
18     public static void main(String[] args) {
19         // 获取连接对象Connection
20         Connection conn = null;
21         // 获取执行sql语句的对象Statement
22         Statement stmt = null;
23         // 执行sql查询语句，并返回结果
24         ResultSet rs = null;
25         try {
26             // 加载驱动
27             Class.forName("com.mysql.jdbc.Driver");
28             conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");
29             stmt = conn.createStatement();
30             rs = stmt.executeQuery("select * from users");
31             // 处理返回的结果
32             while (rs.next()) {
33                 // 根据列名取值，顺序自己定，更灵活
34                 System.out.println(rs.getObject("id"));
35                 System.out.println(rs.getObject("name"));
36                 System.out.println(rs.getObject("password"));
37                 System.out.println(rs.getObject("email"));
38                 System.out.println(rs.getObject("birthday"));
39             }
40         } catch (Exception e) {
41             e.printStackTrace();
42         } finally {
43             // 关闭资源
44             if (rs != null) {
45                 try {
46                     rs.close();
47                 } catch (SQLException e) {
48                     e.printStackTrace();
49                 }
50             }
51             if (stmt != null) {
52                 try {
53                     stmt.close();
54                 } catch (SQLException e) {
55                     e.printStackTrace();
56                 }
57             }
58             if (conn != null) {
59                 try {
60                     conn.close();
61                 } catch (SQLException e) {
62                     e.printStackTrace();
63                 }
64             }    
65         }
66     }
67 }

============================================================

四、使用JDBC实现CRUD操作

　　注意：

　　　　* 一般实体类的类名和数据库的表名一致。(注意：若数据库的表名单词带s的，则实体类名就去掉s)

　　　　* 实体类的成员变量名和数据库表中的列名一致。(这是一个约定，网站开发的时候会提到)

　　　　后续演示代码的实体类的类名为User。

　　　　其实名字可以随意起的，但是一般要求我们做到见名知意。

============================================================

五、实现一个用户登录的功能

============================================================

六、解决SQL注入问题：preparedStatement(预编译语句)

　　preparedStatement(接口)：预编译对象，是Statement(接口)对象的子类。

　　　　特点：（安全高效，防止恶义SQL语法）

　　　　1、性能要高；PreparedStatement 实例包含已编译的 SQL 语句，所以其执行速度要快于 Statement 对象。

　　　　2、会把sql语句先编译。

　　　　3、sql语句中的参数会发生变化，过滤掉用户输入的关键字。

package com.itheima.service;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

import com.itheima.entity.User;
import com.itheima.util.DBUtils;

public class DoLogin {

    /**
     * 根据姓名和密码查询用户信息
     * @param name
     * @param password
     * @return User
     */
    public User findUser(String name, String password) {
        Connection conn = null;
        // Statement stmt = null;
        PreparedStatement stmt = null;
        ResultSet rs = null;
        User u = null;

        try {
            conn = DBUtils.getConnection();
            
            // stmt = conn.createStatement();
            // String sql = "select * from users where name = '" + name + "' and password = '" + password + "'";
            // rs = stmt.executeQuery(sql);
            
            String sql = "select * from users where name = ? and password = ?";
            stmt = conn.prepareStatement(sql);
            stmt.setString(1, name); // 给?赋值
            stmt.setString(2, password); // 给?赋值
            rs = stmt.executeQuery();
            
            if (rs.next()) {
                u = new User();
                u.setId(rs.getInt("id"));
                u.setName(rs.getString("name"));
                u.setPassword(rs.getString("password"));
                u.setEmail(rs.getString("email"));
                u.setBirthday(rs.getDate("birthday"));
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            DBUtils.closeAll(rs, stmt, conn);
            
        }

        return u;
    }
}

============================================================

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2018-04-29 ，如有侵权请联系 cloudcommunity@tencent.com 删除

其他

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

其他

登录后参与评论

0 条评论

热度