JDBC连接数据库

JDBC连接数据库

共六步
1.Class.forName()加载数据库连接驱动
2.DriverManager.getConnection()获取数据连接对象
3.根据SQL获取sq|会话对象
4.执行SQL，执行SQL前如果有参数值就设置参数值setXXX()
5.处理结果集
6.释放资源

0.前期工作

0.0文件jar包下载，配置，删除

目前常用的驱动版本就是5或者8(根据自己的数据库版本判断)-5和8的数据库驱动下载地址

1.建一个lib文件夹与src同级，把对应的jar包放进从（CV就行）

2.右击jar包->Add as Library

3.Name可以自己改，正常默认ok就行

4.出现下面这样就添加成功了

5.删除的方法
File->roject Structure->Libraries，然后在中间找到要删除的，点击减号就行，记得别忘了Apply->OK(我喜欢两步个人习惯，直接点OK也行)

下面这4步可以不写，写他的好处是为了方便修改

0.1、声明驱动

1. //5版本
2. private static String driver = "com.mysql.jdbc.Driver";
3. //8版本
4. private static String driver = "com.mysql.cj.jdbc.Driver";

复制代码

他们的区别就是8版本比5版本多了一层.cj，这里只是看看，实际用的时候不要解压

0.2、声明用户名

正常情况下是root，如果修改了话根据你的实际情况而定

1. private static String username = "root";

复制代码

0.3、声明密码

根据自身情况而定

1. private static String password = "123456";

复制代码

0.4、数据库完整地址

用127.0.0.1、localhost（无网）或者本地IP（有网）
jdbc:mysql://localhost:3306不写后面的数据库名也不会报错多用于测试

useSSL:不建议在没有服务器身份验证的情况下建立SSL连接。如果不设置显式选项，则必须建立默认的SSL连接。需要通过设置useSSL=false来显式禁用SSL，或者设置useSSL=true并为服务器证书验证提供信任存储。所以建议设置useSSL为false，有时遇到的问题可以这样来考虑

characterEncoding:设置字符集

timeZone:设置时区，这个如果设置错了，在处理时间问题时候显示的时间会跟自己想象的不太一样
举个例子：日本时间比中国早一个小时

1. private static String url = "jdbc:mysql://localhost:3306/数据库名字?useSSL=false&characterEncoding=utf8&timeZone=UTC";

复制代码

一、Class.forName()加载数据库连接驱动

会让处理异常，这里直接try{}catch{}

1. Class.forName(driver);

复制代码

二、DriverManager.getConnection()获取数据连接对象

1. DriverManager.getConnection(url, username, password);

复制代码

三、根据SQL获取sq|会话对象

有2种方式Statement、PreparedStatement 建议用PreparedStatement,用Statement连接的话容易被sql注入

1. private PreparedStatement pstm;
2. //?是要传入的数据，有几个写几个
3. String sql = "SELECT * FROM user WHERE id = ?;";
4. pstm = conn.prepareStatement(sql);

复制代码

四、执行SQL，执行SQL前如果有参数值就设置参数值setXXX()

1. //查询用这个
2. private ResultSet rs= null;
3. //如上面第三步需要一个int类型的数据id
4. pstm.setInt(1,id);
5. rs = pstm.executeQuery();
6. //其他的增删改,不需要返回结果集，他们返回一个整数，代表改变了几条数据
7. n = pstm.executeUpdate();

复制代码

五、处理结果集

1. //在查询的时候使用处理结果
2. //找下一个，通常写在while中
3. rs.next()
4. //获取
5. rs.getString()

复制代码

六、释放资源

1. //这里我封装起来了省的来回写一大堆
2. //正着写，倒着关
3. //查询关三个
4. ResultSet.close;
5. PreparedStatement.close;
6. Connection.close;
7. //其他关两个
8. PreparedStatement.close;
9. Connection.close;

复制代码

七、案例

案例一二六

整个可以直接全部复制，改改参数就行

1. import java.sql.*;
3. /**
4. * @Auther QY
5. * @Date 2023/11/16
6. */
7. public class DBTools {
8.     //(1)声明驱动
9.     //我这里用的是8版本的
10.     private static String driver = "com.mysql.cj.jdbc.Driver";
11.     //(2)声明用户名
12.     private static String username = "root";
13.     //(3)声明密码
14.     private static String password = "qy666";
15.     //(4)数据库的完整地址
16.     private static String url = "jdbc:mysql://localhost:3306/数据库名字?useSSL=false&characterEncoding=utf8&timeZone=UTC";
18.     public static Connection ConnDB() {
19.         Connection connection = null;
20.         try {
21.             //一、Class.forName()加载数据库连接驱动
22.             Class.forName(driver);
23.             //二、DriverManager.getConnection()获取数据连接对象
24.             connection = DriverManager.getConnection(url, username, password);
25.         } catch (ClassNotFoundException e) {
26.             e.printStackTrace();
27.         } catch (SQLException throwables) {
28.             throwables.printStackTrace();
29.         }
30.         return connection;
31.     }
33.     //六、释放资源
34.     public static void closeDB(Connection connection, PreparedStatement preparedStatement, ResultSet resultSet) {
35.         //(1)关闭连接对象
36.         if (connection != null) {
37.             try {
38.                 connection.close();
39.             } catch (SQLException throwables) {
40.                 throwables.printStackTrace();
41.             }
42.         }
43.         //(2)关闭数据操作对象
44.         if (preparedStatement != null) {
45.             try {
46.                 preparedStatement.close();
47.             } catch (SQLException throwables) {
48.                 throwables.printStackTrace();
49.             }
50.         }
51.         //(3)关闭结果集对象
52.         if (resultSet != null) {
53.             try {
54.                 resultSet.close();
55.             } catch (SQLException throwables) {
56.                 throwables.printStackTrace();
57.             }
58.         }
59.     }
60. }

复制代码

案例三四五

这里可以看看大概结构，部分代码可以复制

1. public class UserDaoImpl implements UserDao {
2.     //声明数据库连接对象
3.     private Connection conn = DruidTools.getConn();
4.     //声明数据库操作对象
5.     private PreparedStatement pstm;
6.     //声明结果集对象
7.     private ResultSet rs= null;
9.     /**
10.      * 通过id号查一个用户
11.      * @param id
12.      * @return
13.      */
14.     @Override
15.     public User selectUserById(int id) {
16.         //声明User
17.         User user = null;
18.         //写sql
19.         String sql = "SELECT * FROM user WHERE id = ?;";
20.         try {
21.             pstm = conn.prepareStatement(sql);
22.             //设置参数的值
23.             pstm.setInt(1,id);
24.             rs = pstm.executeQuery();
25.             if (rs.next()){
26.                 user = new User();
27.                 String username = rs.getString("username");
28.                 String password = rs.getString("password");
29.                 user.setId(id);
30.                 user.setUsername(username);
31.                 user.setPassword(password);
32.             }
33.         } catch (SQLException throwables) {
34.             throwables.printStackTrace();
35.         }
36.         //查不到返回null
37.         return user;
38.     }
40.     /**
41.      * 查询所有对象
42.      * @return
43.      */
44.     @Override
45.     public List<User> selectUsers() {
46.         List<User> users = new ArrayList<>();
47.         //写sql语句
48.         String sql = "select * FRom user;" ;
49.         User user;
50.         try {
51.             pstm = conn.prepareStatement(sql);
52.             rs = pstm.executeQuery();
53.             while (rs.next()){
54.                 //跟实体类对应
55.                 int id = rs.getInt("id");
56.                 String username = rs.getString("username");
57.                 String password = rs.getString("password");
58.                 user = new User();
59.                 user.setId(id);
60.                 user.setUsername(username);
61.                 user.setPassword(password);
62.             }
63.         } catch (SQLException throwables) {
64.             throwables.printStackTrace();
65.         }
66.         return users;
67.     }
69.     /**
70.      * 添加用户
71.      * @param user
72.      * @return
73.      */
74.     @Override
75.     public int insertUser(User user) {
76.         //声明变量
77.         int n = 0;
78.         String sql = "INSERT INTO user(username,password,realname,gender,address,email,regdate) " +
79.                 "VALUES(?,?,?,?,?,?,?);";
80.         try {
81.             pstm = conn.prepareStatement(sql);
82.             pstm.setString(1,user.getUsername());
83.             pstm.setString(2,user.getPassword());
84.             pstm.setString(3,user.getRealname());
85.             pstm.setString(4,user.getGender());
86.             pstm.setString(5,user.getAddress());
87.             pstm.setString(6,user.getEmail());
88.             pstm.setTimestamp(7,user.getRegdate());
89.             //执行添加
90.             n = pstm.executeUpdate();
91.         } catch (SQLException throwables) {
92.             throwables.printStackTrace();
93.         }
94.         return n;
95.     }
97.     @Override
98.     public Integer selectUserByUsername(String username) {
99.         //声明对象
100.         Integer temp = null;
101.         //写sql
102.         String sql = "SELECT id FROM user WHERE username = ?;";
103.         //创建对象
104.         try {
105.             pstm = conn.prepareStatement(sql);
106.             pstm.setString(1,username);
107.             rs = pstm.executeQuery();
108.             if (rs.next()){
109.                 temp = rs.getInt("id");
110.             }
111.         } catch (SQLException throwables) {
112.             throwables.printStackTrace();
113.         }
114.         return temp;
115.     }
117.     /**
118.      * 修改密码
119.      * @param username
120.      * @param newPassword
121.      * @return
122.      */
123.     @Override
124.     public int updateUser(String username, String newPassword) {
125.         int n = 0;
126.         String sql = "UPDATE user SET password = ? WHERE username = ?;";
127.         try {
128.             pstm = conn.prepareStatement(sql);
129.             pstm.setString(2,username);
130.             pstm.setString(1,newPassword);
131.             //执行修改
132.             n = pstm.executeUpdate();
133.         } catch (SQLException throwables) {
134.             throwables.printStackTrace();
135.         }
136.         return n;
137.     }
139.     @Override
140.     public int deleteUser(String username) {
141.         int n = 0;
142.         String sql = "DELETE FROM user WHERE username = ?;";
143.         try {
144.             pstm = conn.prepareStatement(sql);
145.             pstm.setString(1,username);
146.             //执行修改
147.             n = pstm.executeUpdate();
148.         } catch (SQLException throwables) {
149.             throwables.printStackTrace();
150.         }
151.         return n;
152.     }
153. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！