Java中使用原始jdbc方式连接数据库

骑猪看日落 2023-09-28 11:21 5阅读 0赞

#### 引言 ####

目前正在巩固之前所学的java知识，在巩固过程中发现遗忘了初始的JDBC连接数据库如何操作，所以经过查阅资料后分享如下：

主要步骤：

1.  加载JDBC驱动（mysql8和5的驱动有点不一样）
2.  获取数据库连接
3.  创建一个Statement语句对象
4.  执行SQL语句
5.  处理结果集
6.  关闭资源（注意先后顺序）

#### 实现 ####

1. 需要引入的依赖或jar包
 
 第一个依赖为必须依赖，后面两个按照需求增加
 
 > * mysql-connector-java-8.0.28.jar
 > * lombok-1.18.22.jar
 > * junit-4.10.jar
 
 如果是Maven项目，直接引入依赖即可
 
 如果是普通java项目，依照以下方式导入jar包
 
 1. File -> Project Structure -> Modules ->Dependencies
 
 ![image-20220620142912689][]
 2. 点击下方的+号
 
 ![image-20220620142949770][]
 3. 选择下载的jar包，点击ok
 
 ![image-20220620143025432][]
 4. 将框框的勾勾上，然后点击ok
 
 ![image-20220620143059250][]
 5. 然后在这里就可以看到你导入的jar包了
 
 ![image-20220620143133462][]
2. 编写实体类
 
 /**
 * 
 *用户表
 * 
 *
 * @author:lzj
 * @date:2022/6/19
 */
 @Data
 @AllArgsConstructor
 @NoArgsConstructor
 public class User {
 
 //用户id
 private int id;
 //用户名
 private String name;
 //用户密码
 private String password;
 }
3. 编写BaseDao
 
 > 相当于封装工具类，自动加载驱动、连接数据库、封装查询、增加、修改、删除的方法，封装关闭资源的方法。
 > 
 > 连接数据库的url可能会有异常，若出现异常百度解决即可
 
 import java.sql.*;
 import java.util.List;
 
 public abstract class BaseDao <T>{
 
 
 protected Connection conn;
 protected PreparedStatement pst;
 protected ResultSet ret;
 
 public abstract List<T> resultSetToList(ResultSet ret);
 
 public BaseDao(){
 
 try {
 
 //加载驱动
 Class.forName("com.mysql.cj.jdbc.Driver");
 //连接数据库
 conn= DriverManager.getConnection("jdbc:mysql://localhost:3306/order_system","root","root");
 
 
 } catch (ClassNotFoundException e) {
 
 e.printStackTrace();
 } catch (SQLException e) {
 
 e.printStackTrace();
 }
 }
 
 //查询数据库---有参查询--select
 public List<T> query(String sql, Object[] params){
 
 try {
 
 //预编译sql
 pst= conn.prepareStatement(sql);
 //遍历参数数组，传参
 if(params!=null&&params.length>0){
 
 for(int i=0;i<params.length;i++){
 
 pst.setObject(i+1,params[i]);
 }
 }
 System.out.println(pst.toString());
 //执行编译完成的sql,得到结果集
 ret= pst.executeQuery();
 } catch (SQLException e) {
 
 e.printStackTrace();
 }
 return resultSetToList(ret);
 
 }
 
 //执行dml的方法 ---insert update delete
 public int dml(String sql ,Object[] params){
 
 int ret=0;
 try {
 
 //预编译sql
 pst= conn.prepareStatement(sql);
 //遍历参数数组，传参
 if(params!=null&&params.length>0){
 
 for(int i=0;i<params.length;i++){
 
 pst.setObject(i+1,params[i]);
 }
 }
 //执行dml
 System.out.println(pst.toString());
 ret= pst.executeUpdate();
 } catch (SQLException e) {
 
 e.printStackTrace();
 }
 return ret;
 }
 
 //关闭资源
 public void closeResouce(Connection conn,ResultSet rs,PreparedStatement pstmt){
 
 if (conn!=null){
 
 try {
 
 conn.close();
 } catch (SQLException throwables) {
 
 throwables.printStackTrace();
 }
 }
 if(rs!=null){
 
 try {
 
 rs.close();
 } catch (SQLException throwables) {
 
 throwables.printStackTrace();
 }
 }
 if(pstmt!=null){
 
 try {
 
 pstmt.close();
 } catch (SQLException throwables) {
 
 throwables.printStackTrace();
 }
 }
 }
 
 }
4. 编写UserDao
 
 import com.lyq.entity.User;
 
 import java.util.List;
 
 /**
 * 
 *
 * 
 *
 * @author:lzj
 * @date:2022/6/19
 */
 public interface UserDao {
 
 
 /**
 * 根据用户输入的用户名查询用户信息
 * @param name 用户名
 * @return 用户数据
 */
 User queryUserByName(String name);
 }
5. 编写UserDaoImpl
 
 > 继承封装好的BaseDao，User为实体类对象，实现UserDao接口
 
 import com.lyq.dao.BaseDao;
 import com.lyq.dao.UserDao;
 import com.lyq.entity.User;
 
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.util.ArrayList;
 import java.util.List;
 
 /**
 * 
 *
 * 
 *
 * @author:lzj
 * @date:2022/6/19
 */
 public class UserDaoImpl extends BaseDao<User> implements UserDao {
 
 @Override
 public List<User> resultSetToList(ResultSet ret) {
 
 User user=null;
 List list = new ArrayList();
 try {
 
 while (ret.next()){
 
 Integer id=ret.getInt("id");
 String username=ret.getString("name");
 String password=ret.getString("password");
 user =new User(id,username,password);
 list.add(user);
 }
 } catch (SQLException throwables) {
 
 throwables.printStackTrace();
 } finally {
 
 closeResouce(conn,ret,pst);
 }
 return list;
 }
 
 
 @Override
 public User queryUserByName(String name) {
 
 String sql="select * from user where name=?";
 Object[] param={
 name};
 List<User> query = query(sql, param);
 //返回查询出来的集合的第一个对象
 return query.get(0);
 }
 
 
 }
6. 测试访问
 
 public class UserDaoTest {
 
 UserDao userDao=new UserDaoImpl();
 
 @Test
 public void queryUserByName(){
 
 System.out.println(userDao.queryUserByName("lyq"));
 }
 }
 
 \}
7. 测试访问
 
 public class UserDaoTest {
 
 UserDao userDao=new UserDaoImpl();
 
 @Test
 public void queryUserByName(){
 
 System.out.println(userDao.queryUserByName("lyq"));
 }
 }
 
 ![image-20220620142643781][]

[image-20220620142912689]: https://img-blog.csdnimg.cn/img_convert/20a13effeaca3d83623f58378d6e34d3.png
[image-20220620142949770]: https://img-blog.csdnimg.cn/img_convert/ff7cb7245ec9422b7c90c8581df728e3.png
[image-20220620143025432]: https://img-blog.csdnimg.cn/img_convert/3432eb1304b462d976cfe652503eef82.png
[image-20220620143059250]: https://img-blog.csdnimg.cn/img_convert/953a859bc12d56015959fc7893b8df64.png
[image-20220620143133462]: https://img-blog.csdnimg.cn/img_convert/938238be716e6fb95538cf614c745a28.png
[image-20220620142643781]: https://img-blog.csdnimg.cn/img_convert/cf2fcffd1b5f95366f369e3dc5eef03c.png