Java之JDBC数据库连接+实体层和数据访问层（一）

傷城~ 2022-05-18 01:17 213阅读 0赞

**目录**

1.新建Web Project 项目，建立Util工具包，新建JDBCUtil类，导入jdbc-connector-java包

2.编写JDBCUtil类的相关内容

3.右键JDBC类->运行方式->Java应用程序，测试是否连接成功

4.新建entity实体包，编写对应的实体类

5.新建Dao层，创建UserDao接口

6.新建DaoImp层，创建UserDaoImp类，实现UserDao接口方法

7.创建单元测试类

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

### 工具：MyEclipse 2017 CI ###

JDBC驱动下载：链接：[https://pan.baidu.com/s/1I90tu8pO\_0lnx996k4\_S0A][https_pan.baidu.com_s_1I90tu8pO_0lnx996k4_S0A]   密码：pdax

项目源码：链接：[https://pan.baidu.com/s/1YFKtQc6REI7IWiyNXFzjmA][https_pan.baidu.com_s_1YFKtQc6REI7IWiyNXFzjmA] 密码：c6oy

### 1.新建Web Project 项目，建立Util工具包，新建JDBCUtil类，导入jdbc-connector-java包 ###

![70][]

### 2.编写JDBCUtil类的相关内容 ###

package com.ly.util;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    
    public class JDBCUtil {
    	public static Connection getConnection(){
    		try {
    			//反射的技术将驱动加进来
    			Class.forName("com.mysql.jdbc.Driver");
    			//第二步：
    			Connection conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/shop?characterEncoding=utf-8&useSSL=true", "root", "root");
    			System.out.println("数据库连接成功！");
    			return conn;
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    		return null;
    	}
    	
    	
    	/**
    	 * 
    	 * @param args
    	 * 关闭相关的资源
    	 * 
    	 */
    	public static void closeAll(ResultSet  rs,PreparedStatement  pstm,Connection conn){
    		
    		try{
    			
    			if(rs!=null){rs.close();}
    			if(pstm!=null){pstm.close();}
    			if(conn!=null){conn.close();}
    		}catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    	
    	 public static void main(String[] args) {
    		   getConnection();
    	}
    
    }

### 3.右键JDBC类->运行方式->Java应用程序，测试是否连接成功 ###

有人可能会问，这不是WebProject吗？怎么可以用Java应用程序方式来运行，这是因为在JDBCUtil中加了main函数。加了main函数的类是可以直接用Java应用程序方式来运行的。这也可以当作测试来用，当然最好是用Java的单元测试来验证是否连接成功。

![70 1][]

## 4.新建entity实体包，编写对应的实体类 ##

一般情况下都是一张数据表对应一个实体类。

先看一下数据库中的user表：

![70 2][]

编写实体类：

package com.ly.entity;
    /***
     * 
     * @author HDLB601T1
     *  封装用户数据
     */
    public class User {
       
    	 private int id;
    	 private String  username;
    	 private String pwd;
    	 private int status;
    	 private int role;
    	 
    	public User() {
    		super();
    	}
    	public User(int id, String username, String pwd, int status, int role) {
    		super();
    		this.id = id;
    		this.username = username;
    		this.pwd = pwd;
    		this.status = status;
    		this.role = role;
    	}
    	public int getId() {
    		return id;
    	}
    	public void setId(int id) {
    		this.id = id;
    	}
    	public String getUsername() {
    		return username;
    	}
    	public void setUsername(String username) {
    		this.username = username;
    	}
    	public String getPwd() {
    		return pwd;
    	}
    	public void setPwd(String pwd) {
    		this.pwd = pwd;
    	}
    	public int getStatus() {
    		return status;
    	}
    	public void setStatus(int status) {
    		this.status = status;
    	}
    	public int getRole() {
    		return role;
    	}
    	public void setRole(int role) {
    		this.role = role;
    	}
    	@Override
    	public String toString() {
    		return "User [id=" + id + ", username=" + username + ", pwd=" + pwd + ", status=" + status + ", role=" + role
    				+ "]";
    	}
    }

此时的项目结构：

![70 3][]

### 5.新建Dao层，创建UserDao接口 ###

package com.ly.dao;
    
    import java.util.List;
    
    import com.ly.entity.User;
    
    
    public interface UserDao {
    	   
    	/**
    	 * 插入一条数据:
    	 * 返回值：int
    	 * 参数：User
    	 * insert  into user values(7,'qq','123',1,2);
    	 */
    	public  int  insertUser(User u);
    	
    	
    	/**
    	 * 
    	 * @param id
    	 * @return  
    	 * 删除用户
    	 */
    	public  int   deleteUser(int id );
    	
    
    	/***
         * 
         * @param u
         * @return
         * 修改用户
         * 
         */
    	public int  updateUser(User u);
    	
    	/**
    	 * 
    	 *根据页码进行查询
    	 *返回值：
    	 *参数：page  ,index
    	 *
    	 */
    	public  List<User>   listByPage(int index,int pageSize);
    	
    	/***
    	 *登录的业务
    	 *查找：
    	 *select * from user where user=?  and pwd=?
    	 *参数：
    	 *返回值：
    	 */
    	public  User  findUserByNamePwd(String username,String pwd);
    	
    	
    	public User findUserById(int id);
    	
    	
    }

### 6.新建DaoImp层，创建UserDaoImp类，实现UserDao接口方法 ###

package com.ly.daoimp;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.util.ArrayList;
    import java.util.List;
    
    import com.ly.dao.UserDao;
    import com.ly.entity.User;
    import com.ly.util.JDBCUtil;
    
    public class UserDaoImp implements UserDao {
    
    	@Override
    	public int insertUser(User u) {
    		// 连接数据库
    		Connection conn = JDBCUtil.getConnection();
    		PreparedStatement pstm = null;
    		// 创建一个查询窗口
    		try {
    			String sql = "insert into user values(?,?,?,?,?)";
    			pstm = conn.prepareStatement(sql);
    			// 需要设置真正的值insert into user values(7,'qq','123',1,2);
    			pstm.setInt(1, u.getId());
    			pstm.setString(2, u.getUsername());
    			pstm.setString(3, u.getPwd());
    			pstm.setInt(4, u.getStatus());
    			pstm.setInt(5, u.getRole());
    
    			// 执行sql
    			int num = pstm.executeUpdate();
    			return num;
    
    		} catch (SQLException e) {
    			e.printStackTrace();
    		} finally {
    			JDBCUtil.closeAll(null, pstm, conn);
    		}
    		return 0;
    	}
    
    	@Override
    	public int deleteUser(int id) {
    
    		Connection connection = JDBCUtil.getConnection();
    		PreparedStatement pstm = null;
    		try {
    			String sqlString = "delete from user where id=?";
    			pstm = connection.prepareStatement(sqlString);
    			pstm.setInt(1, id);
    			int num = pstm.executeUpdate();
    			return num;
    		} catch (SQLException e) {
    			e.printStackTrace();
    		} finally {
    			JDBCUtil.closeAll(null, pstm, connection);
    		}
    		return 0;
    	}
    
    	@Override
    	public int updateUser(User u) {
    		Connection connection=JDBCUtil.getConnection();
    		PreparedStatement pstm=null;
    		try {
    			String sqlString="update user set user=?,pwd=? ,status=?, role=? where id=? ";
    			pstm=connection.prepareStatement(sqlString);
    			pstm.setString(1, u.getUsername());
    			pstm.setString(2, u.getPwd());
    			pstm.setInt(3, u.getStatus());
    			pstm.setInt(4, u.getRole());
    			pstm.setInt(5, u.getId());
    			
    			int num=pstm.executeUpdate();
    			return num;
    			
    		} catch (SQLException e) {
    			e.printStackTrace();
    		}
    		finally {
    			JDBCUtil.closeAll(null, pstm, connection);
    		}
    		return 0;
    	}
    
    	@Override
    	public List<User> listByPage(int index, int pageSize) {
    		Connection connection=JDBCUtil.getConnection();
    		PreparedStatement pstm=null;
    		ResultSet rs=null;
    		List<User> uList=new ArrayList<User>();
    	    try {
    			String sqlString="select * from user limit ?,?";
    			pstm=connection.prepareStatement(sqlString);
    			pstm.setInt(1, (index-1)*pageSize);
    			pstm.setInt(2, pageSize);
    			rs=pstm.executeQuery();
    			
    			while (rs.next()) {
    			     User user=new User(rs.getInt(1),rs.getString(2),rs.getString(3),rs.getInt(4),rs.getInt(5));
    			     uList.add(user);
    			}
    			
    			return uList;
    		} catch (Exception e) {
    			e.printStackTrace();
    		}finally {
    			JDBCUtil.closeAll(rs, pstm, connection);
    		}
    		
    		return null;
    	}
    
    	@Override
    	public User findUserByNamePwd(String username, String pwd) {
    		Connection connection=JDBCUtil.getConnection();
    		PreparedStatement pstm=null;
    		ResultSet rs=null;
    		User user=null;
    		
    		try {
    			
    			String sqlString="select * from user where user=?&&pwd=?";
    			pstm=connection.prepareStatement(sqlString);
    			pstm.setString(1, username);
    			pstm.setString(2, pwd);
    			
    			rs=pstm.executeQuery();
    			while (rs.next()) {
    				user=new User(rs.getInt(1),rs.getString(2),rs.getString(3),rs.getInt(4),rs.getInt(5));
    			}
    			
    			return user;	
    			
    		} catch (SQLException e) {
    			// TODO: handle exception
    		}finally {
    			JDBCUtil.closeAll(rs, pstm, connection);
    		}
    		return null;
    	}
    
    	@Override
    	public User findUserById(int id) {
    		Connection connection=JDBCUtil.getConnection();
    		PreparedStatement pstm=null;
    		ResultSet rs=null;
    		User user=null;
    		try {
    			String sqlstring="select * from user where id=?";
    			pstm=connection.prepareStatement(sqlstring);
    			pstm.setInt(1, id);
    			rs=pstm.executeQuery();
    			while (rs.next()) {
    				user=new User(rs.getInt(1),rs.getString(2),rs.getString(3),rs.getInt(4),rs.getInt(5));	
    			}
    			
    			return user;
    			
    		} catch (SQLException e) {
    			e.printStackTrace();
    		}finally {
    			JDBCUtil.closeAll(rs, pstm, connection);
    		}
    		return null;
    	}
    
    }

项目结构：

![70 4][]

### 7.创建单元测试类 ###

点击UserDaoImp类右建->新建->其他

![70 5][]![70 6][]

![70 7][]

![70 8][]

测试类代码：

package test;
    
    
    import java.util.List;
    
    import org.junit.Test;
    
    import com.ly.daoimp.UserDaoImp;
    import com.ly.entity.User;
    
    public class UserDaoImpTest {
    	
    	private UserDaoImp uDaoImp=new UserDaoImp();
    
    	@Test
    	public void testInsertUser() {
    		User user=new User();
    		user.setUsername("测试");
    		user.setPwd("123456");
    		user.setRole(1);
    		user.setStatus(0);
    		int num=uDaoImp.insertUser(user);
    		System.out.println(num);
    		if(num>0){
    			System.out.println("插入成功");
    		}
    	}
    
    	@Test
    	public void testDeleteUser() {
    		int num=uDaoImp.deleteUser(10);
    		if (num>0) {
    			System.out.println("删除数据成功");
    		}
    	}
    
    	@Test
    	public void testUpdateUser() {
    		User u=new User(4,"吴家伟","741852963",0,0);
    		int num=uDaoImp.updateUser(u);
    		if (num>0) {
    			System.out.println("更新数据成功");
    		}
    	}
    
    	@Test
    	public void testListByPage() {
    		
    		List<User> users=uDaoImp.listByPage(1, 5);
    	    for (User user : users) {
    	    	System.out.println(user);
    		}
    		
    		
    	}
    
    	@Test
    	public void testFindUserByNamePwd() {
    		User user=uDaoImp.findUserByNamePwd("ly", "123");
    		if (user!=null) {
    			System.out.println(user);
    		}
    	}
    
    	@Test
    	public void testFindUserById() {
    		User user=uDaoImp.findUserById(9);
    		if (user!=null) {
    			System.out.println(user);
    		}
    		 
    	}
    
    }

点击UserDaoImpTest类右建->运行方式->JUnit测试

说明连接数据库成功，可以通过JDBC驱动来操作Mysql的ti'a添加和删除

[https_pan.baidu.com_s_1I90tu8pO_0lnx996k4_S0A]: https://pan.baidu.com/s/1I90tu8pO_0lnx996k4_S0A
[https_pan.baidu.com_s_1YFKtQc6REI7IWiyNXFzjmA]: https://pan.baidu.com/s/1YFKtQc6REI7IWiyNXFzjmA
[70]: /images/20220518/b8779d14f43f4733ab04e8593b9b6757.png
[70 1]: /images/20220518/27424b35b8be4715b895fc18dee8b2a2.png
[70 2]: /images/20220518/d4c34020f0034511b95dda938230c4db.png
[70 3]: /images/20220518/0c22235a8181416ca6939e38b860adb6.png
[70 4]: /images/20220518/a3a17bc42c53490d9a75accc70cd95ea.png
[70 5]: https://img-blog.csdn.net/20180728142232479?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0RvY3Rvcl9MWQ==/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70
[70 6]: /images/20220518/30c3bdd67d9140f7baab2777d9e14703.png
[70 7]: /images/20220518/231918a8c6594224b07bc4e32e3895d7.png
[70 8]: /images/20220518/f8231d12c812486c85c12119aafcedda.png

发表评论取消回复

表情：

评论列表（有 0 条评论，213人围观）

还没有评论，来说两句吧...

相关阅读

相关《Mycat分布式数据库架构》之应用层连接mycat数据源

文章目录 1、添加maven依赖 2、添加配置文件 3、实体类

刺骨的言语ヽ痛彻心扉/ 2023年09月28日 19:59/ 0 赞/ 40 阅读

相关 java中表示层控制层业务逻辑层数据访问层

控制层（controller）：的职能是负责读取视图表现层的数据，控制用户的输入，并调用业务层的方法；业务层（service）：需要根据系统的实际业务需求进行逻辑代码的编写

逃离我推掉我的手/ 2023年09月23日 17:05/ 0 赞/ 211 阅读

相关 MYSQL数据库访问层

`<?php / 数据访问层，仅处理MYSQL 包括 by:李勇 at:2009-01-19 / final class DalSplite{ public f

深藏阁楼爱情的钟/ 2022年09月19日 10:45/ 0 赞/ 230 阅读

相关中间件-数据访问层

单机情况下数据库在不同语言，不同平台都有各自数据库访问组件，各种类似odbc、jdbc的封装以及orm的处理都已经相当成熟。数据库压力越来越大，处理方法是优化应用，减少压力

浅浅的花香味﹌/ 2022年08月10日 05:53/ 0 赞/ 239 阅读

相关分布式数据访问层

数据库从单机到分布式的挑战和应对从应用使用单机数据库开始所有的业务数据都放在一个数据库中来管理 ![这里写图片描述][SouthEast] 数据库垂直/水

冷不防/ 2022年06月06日 10:06/ 0 赞/ 255 阅读

相关数据访问层搭建集成Druid连接池

我们在springboot中默认使用的数据连接池是tomcat中的数据连接池，使用的配置是这个默认启用的是tomcat的连接池 spring.dataso

小鱼儿/ 2022年05月21日 23:39/ 0 赞/ 188 阅读

相关 Java之JDBC数据库连接+实体层和数据访问层（一）

目录 1.新建Web Project 项目，建立Util工具包，新建JDBCUtil类，导入jdbc-connector-java包 2.编写JDBCUtil类的相关内容

傷城~/ 2022年05月18日 01:17/ 0 赞/ 214 阅读

相关【JDBC】一、JDBC连接数据库

[【JDBC】一、JDBC连接数据库][JDBC_JDBC] 1 package com.jdbc; 2 3 import java.sql

朱雀/ 2022年04月24日 04:44/ 0 赞/ 338 阅读

相关根据实体类生成持久层、控制层、服务层、实现层

最近写个java web 程序，用的spring boot、spring data jpa 由于数据库表较多、逆向工程生成的实体类也比较多，重复性工作就很多也很枯燥，今天

客官°小女子只卖身不卖艺/ 2022年03月20日 09:56/ 0 赞/ 386 阅读

相关数据库访问层中间件Zebra

数据库访问层中间件Zebra zebra是一个基于JDBC API协议上开发出的高可用、高性能的数据库访问层解决方案。类似阿里的tddl，zebra是一个smar

古城微笑少年丶/ 2021年12月10日 03:15/ 0 赞/ 510 阅读