DAO设计模式
DAO设计模式简介: DAO设计模式可以减少代码量，增强程序的可移植性，提高代码的可读性。
DAO(数据库操作对象)设计模式是 JavaEE 数据层的操作.主要由五部分组成：
1.数据库连接类：连接数据库并获取连接对象。
2.VO实体类：包含属性和表中字段完全对应的类。
3.DAO接口：提供了用户所有的操作方法（就如老师给学生提供一些学习方法）。
4.DAO实现类：实现DAO中所有的方法（就如老师给提供的方法看你如何去完成）。
5.DAO工厂类：为程序提供方法，如果要替换DAO实现类，只需要修改该Dao工厂类中的方法代码，
而不必邀修改所有的操作数据库代码（如代理人专门为需要的公司提供人才，也叫做服务层）。
下面以一个用户登录为例：
1.数据库建表：
2.数据库连接类 com.util(记得导入c3p0框架包)
package com.util; import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import javax.sql.DataSource;
import com.mchange.v2.c3p0.ComboPooledDataSource; public class C3P0Util {
// C3P0数据源
private static ComboPooledDataSource dataSource = new ComboPooledDataSource(); public static DataSource getDataSource() {
return dataSource;
} public static Connection getConn() {
Connection conne = null;
try {
conne = dataSource.getConnection();
} catch (Exception e) {
e.printStackTrace();
}
return conne;
} // 关闭资源
public static void closeAll(ResultSet rs, Statement st, Connection conne) {
try {
if (null != rs) {
rs.close();
}
} catch (Exception e) {
e.printStackTrace();
}
try {
if (null != st) {
st.close();
}
} catch (Exception e) {
e.printStackTrace();
}
try {
if (conne != null) {
conne.close();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
3.VO实体类 com.entity
package com.entity;
import java.io.Serializable;
public class Person implements Serializable {
private static final long serialVersionUID = 1L;
private int id;
private String name;
private String password;
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
}
4.DAO接口类 com.dao
package com.dao;
import com.entity.Person;
public interface PersonDao {
//根据对象查询
public Person findMaster(Person person);
}
5.DAO实现类 com.daoImpl
package com.daoImpl; import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet; import com.dao.PersonDao;
import com.entity.Person;
import com.util.C3P0Util; public class PersonDaoImpl implements PersonDao { @Override
public Person findMaster(Person person) {
Connection conne = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
Person person2 = null;
String sql = "SELECT * FROM person WHERE name = ? AND password = ?"; try {
conne = C3P0Util.getConn(); // 建立了到特定数据库的连接之后，就可用该连接发送 SQL 语句。
pstmt = conne.prepareStatement(sql);
pstmt.setString(1, person.getName());
pstmt.setString(2, person.getPassword());
rs = pstmt.executeQuery(); if (rs.next()) {
person2 = new Person();
person2.setId(rs.getInt("id"));
person2.setName(rs.getString("name"));
person2.setPassword(rs.getString("password"));
}
} catch (Exception e) {
e.printStackTrace();
} finally {
C3P0Util.closeAll(rs, pstmt, conne);
}
return person2;
} }
6.DAO工厂接口 com.service
package com.service;
import com.entity.Person;
public interface PersonService {
public boolean login (Person person);
}
7.DAO工厂实现类 com.serviceImpl
package com.serviceImpl; import com.dao.PersonDao;
import com.daoImpl.PersonDaoImpl;
import com.entity.Person;
import com.service.PersonService; public class PersonServiceImpl implements PersonService { @Override
public boolean login(Person person) {
boolean islogin = false;
PersonDao pd = new PersonDaoImpl();
Person ps2 = pd.findMaster(person);
if (null != ps2) {
islogin = true;
}
return islogin;
}
}
8.测试
package com.test; import java.util.Scanner; import org.junit.Test; import com.entity.Person;
import com.service.PersonService;
import com.serviceImpl.PersonServiceImpl; public class LoginTest {
@Test
public void loginTest() {
Scanner sc = new Scanner(System.in, "UTF-8");
System.out.println("请输入用户名");
String loginName = sc.next();
System.out.println("请输入密码");
String loginPassword = sc.next(); Person person = new Person();
person.setName(loginName);
person.setPassword(loginPassword); PersonService ps = new PersonServiceImpl();
boolean isLoginid = ps.login(person); if (isLoginid) {
System.out.println("登录成功");
} else {
System.out.println("用户名或密码错误");
}
}
}
运行结果如下：