如果对三层架构有什么不理解的:
请戳我哦
改进了那些地方:
1、加入接口(面向接口开发)
我们在实际开发中一般都是先有一个大致的框架,然后在后期实现各个模块的功能。
先接口 -- > 再实现类。
2、DBUtil
通用的数据库帮助类，可以简化Dao层的代码量
帮助类 一般建议写在 xxx.util包
接口与实现类的命名规范:
接口：interface， 起名 I实体类Service IStudentService
IStudentDao
实现类：implements 起名 实体类ServiceImpl StudentServiceImpl
StudentDaoImpl
接口： I实体类层所在包名 IStudentService、IStudentDao
接口所在的包： xxx.service xx.dao
实现类： 实体类层所在包名Impl StudentServiceImpl、StudentDaoImpl
实现类所在的包：xxx.service.impl xx.dao.impl
以后使用接口/实现类时，推荐写法：
接口 x = new 实现类();
IStudentDao studentDao = new StudentDaoImpl();
效果如图:
Code:
本次代码是在上一个介绍中进行有优化,在此只展现修改的代码,其他的的部分可参考:
三层架构模式实现简单的学生管理系统(内含数据库)
interface IStudentDao:
package org.dao;
import java.util.List;
import org.entity.Student;
// 接口:更加贴近设计要求,一般都先有一个大概,然后通过实现类实现各个方法
public interface IStudentDao {
// 判断该用户是否存在
public boolean isExist(int sno) ;
// 添加新用户
public boolean addStudent(Student student);
// 根据学生学号修改学生信息
public boolean updateStudentBySno(int sno,Student student) ;
// 删除用户
public boolean deleteStudentBySno(int sno) ;
// 通过学号查询学生信息(返回值是一个学生,如果学生不存在返回 Null)
public Student queryStudentBySno(int sno);
public List<Student> queryAllStudents();
}
interface IStudentService:
package org.service;
import java.util.List;
import org.entity.Student;
//接口:更加贴近设计要求,一般都先有一个大概,然后通过实现类实现各个方法
public interface IStudentService {
public Student queryStudentBySno(int sno);
// 查询所有用户信息
public List<Student> queryAllStudents();
// 更新用户(更新用户之前需要先判断用户是否已经存在)
public boolean updateStudent(int sno,Student student);
// 删除用户(删除用户之前需要先判断用户是否已经存在)
public boolean deleteStudent(int sno) ;
// 增加用户(增加用户之前需要先判断用户是否已经存在
public boolean addStudent(Student student);
}
DBUtil：
package org.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
/*
* 数据库帮助类:可以简化代码(将每个模块中重复的代码弄到一个方法中,增加代码复用)
* DBUtil: 简化 Dao 层的代码
*
* */
public class DBUtil {
private static final String URL = "jdbc:mysql://localhost:3306/sqltest";
private static final String User = "root";
private static final String Password = "root";
public static Connection conn = null;
public static PreparedStatement pstam = null;
public static ResultSet rs = null;
// 用于加载驱动和与驱动建立连接
public static Connection getConnection() throws ClassNotFoundException, SQLException {
Class.forName("com.mysql.jdbc.Driver") ;
return DriverManager.getConnection( URL,User,Password ) ;
}
// 操作数据库,执行 sql 语句
// Object 数组用来存储 ? (占位符所代表的信息),因为 ? 所代表的数据类型不一致,所以用 Object
// 静态方法,方便直接调用 --> 类名.方法
public static PreparedStatement createPreParedStatement(String sql,Object[] params) throws ClassNotFoundException, SQLException {
// 预处理
pstam = getConnection().prepareStatement(sql) ;
// 防止出现空指针
if(params!=null ) {
for(int i=0;i<params.length;i++) {
pstam.setObject(i+1, params[i]);
}
}
// 返回一个 PreparedStatement 对象,与原先操作数据库类似
return pstam;
}
// update 操作: 增加、删除、更新(通用代码,只是 Sql 语句不一样,所以我们只需要传递不同的 sql 语句
// 和占位符所代表的意义即可)
public static boolean exeucateUpdate(String sql,Object[] pstams) {
int result = 0;
try {
pstam = createPreParedStatement(sql,pstams);
result = pstam.executeUpdate();
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
try {
if(rs != null) rs.close();
if(pstam != null) pstam.close();
if(conn != null) conn.close();
} catch(SQLException e) {
e.printStackTrace();
}
}
if(result > 0) return true;
else return false;
}
// 查询时的通用代码: 因为我们是面对所用用户的,不同的用户所对应的字段有所不同,所以我们在这里只能
// 返回一个结果集,剩下的交给其他地方进行处理。
public static ResultSet excucateQuery(String sql, Object[] pstams) {
try {
pstam = createPreParedStatement(sql,pstams);
rs = pstam.executeQuery();
return rs;
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
}
StudentDaoImpl:
package org.dao.impl;
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 org.dao.IStudentDao;
import org.entity.Student;
import org.util.DBUtil;
/*
* 我们将冗余的一部分代码放到 DBUtil 中,其次我们将 DBUtil 中的方法设置成 static
* 那我们我们就可以直接在这个项目的方法其他地方进行 类名.方法 进行调用
*
* 由于 增加、删除、修改 操作只是 sql 语句不同,所以我们每次只需要传递不同的 sql 语句即可。
* 由于 每种功能对应的 sql 语句中的 占位符数量及数据类型也是不同的,所以我们可以将 所有的
* 占位符所代表的意义存储到 一个 Object 数组中,一起传递到 DBUtil 中。
*
* */
public class StudentDaoImpl implements IStudentDao {
// 判断该用户是否存在
public boolean isExist(int sno) {
// 查询该学生的学号是否存在,存在就返回true,不存在则返回 false
return queryStudentBySno(sno) == null ? false : true;
}
// 添加新用户
public boolean addStudent(Student student) {
String sql = "insert into student values (?,?,?,?,?)";
Object[] params = { student.getSno(), student.getName(), student.getAge(), student.getSex(), student.getSad() };
return DBUtil.exeucateUpdate(sql, params);
}
// 根据学生学号修改学生信息
public boolean updateStudentBySno(int sno, Student student) {
String sql = "update student set sname = ?,sage = ?,ssex = ?,sad = ? where sno = ?";
Object[] params = { student.getName(), student.getAge(), student.getSex(), student.getSad(), sno };
return DBUtil.exeucateUpdate(sql, params);
}
// 删除用户
public boolean deleteStudentBySno(int sno) {
String sql = "delete from student where sno = ?";
Object[] params = { sno };
return DBUtil.exeucateUpdate(sql, params);
}
// 查询所有用户
public List<Student> queryAllStudents() {
Connection conn = null;
PreparedStatement pstam = null;
ResultSet rs = null;
List<Student> students = new ArrayList<>();
Student student = null;
try {
String sql = "select * from student";
rs = DBUtil.excucateQuery(sql, null);
while (rs.next()) {
int no = rs.getInt("sno");
String name = rs.getString("sname");
int age = rs.getInt("sage");
String sex = rs.getString("ssex");
String sad = rs.getString("sad");
student = new Student(no, name, age, sex, sad);
students.add(student);
}
return students;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
} finally {
if (rs != null)
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if (conn != null) {
try {
DBUtil.conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if (pstam != null) {
try {
DBUtil.pstam.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
return null;
}
// 通过学号查询学生信息(返回值是一个学生,如果学生不存在返回 Null)
public Student queryStudentBySno(int sno) {
ResultSet rs = null;
Student student = null;
try {
String sql = "select * from student where sno = ?";
Object[] pstams = {sno};
rs = DBUtil.excucateQuery(sql, pstams);
if(rs.next()) {
int no = rs.getInt("sno");
String name = rs.getString("sname");
int age = rs.getInt("sage");
String sex = rs.getString("ssex");
String sad = rs.getString("sad");
student = new Student(no,name,age,sex,sad);
return student;
} else {
return null;
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
} finally {
if(rs != null )
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
return null;
}
}
客官留步:
如果疑问,可随时联系ME.
如需要源代码,欢迎随时联系ME.
