자바 레이 어 링 개발 중인 BaseDao
13159 단어 --------1.1ORACLE--------2.3Java
1. BaseDao 의 표기 법
package dao;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
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 utils.DbHelper;
public class BaseDao {
private Connection conn = null;
private PreparedStatement ps = null;
private ResultSet rs = null;
/**
* 查询符合条件的记录数
*
* @param sql
* 要执行的sql语句
* @param args
* 给sql语句中的？赋值的参数列表
* @return 符合条件的记录数
*/
public long getCount(String sql, Object... args) {
conn = DbHelper.getConn();
try {
ps = conn.prepareStatement(sql);
for (int i = 0; i < args.length; i++) {
ps.setObject(i + 1, args[i]);
}
rs = ps.executeQuery();
if (rs.next()) {
return rs.getLong(1);
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
DbHelper.closeConn(conn, ps, rs);
}
return 0L;
}
/**
* 查询实体对象的，并封装到一个集合
*
* @param
* 要查询的对象的集合
* @param sql
* 要执行的sql语句
* @param clazz
* 要查询的对象的类型
* @param args
* 给sql语句中的？赋值的参数列表
* @return 要查询的类的集合，无结果时返回null
*/
public List executeQuery(String sql, Class clazz, Object... args) {
conn = DbHelper.getConn();
List list = new ArrayList();
try {
ps = conn.prepareStatement(sql);
for (int i = 0; i < args.length; i++) {
ps.setObject(i + 1, args[i]);
}
rs = ps.executeQuery();
Field[] fs = clazz.getDeclaredFields();
String[] colNames = new String[fs.length];
String[] rTypes = new String[fs.length];
Method[] methods = clazz.getMethods();
while (rs.next()) {
for (int i = 0; i < fs.length; i++) {
Field f = fs[i];
String colName = f.getName().substring(0, 1).toUpperCase()
+ f.getName().substring(1);
colNames[i] = colName;
String rType = f.getType().getSimpleName();
rTypes[i] = rType;
}
Object object = (T) clazz.newInstance();
for (int i = 0; i < colNames.length; i++) {
String colName = colNames[i];
String methodName = "set" + colName;
// 查找并调用对应的setter方法赋
for (Method m : methods) {
if (methodName.equals((m.getName()))) {
// 如果抛了参数不匹配异常，检查JavaBean中该属性类型，并添加else分支进行处理
if ("int".equals(rTypes[i])
|| "Integer".equals(rTypes[i])) {
m.invoke(object, rs.getInt(colName));
} else if ("Date".equals(rTypes[i])) {
m.invoke(object, rs.getDate(colName));
} else if ("Timestamp".equals(rTypes[i])) {
m.invoke(object, rs.getTimestamp(colName));
} else {
m.invoke(object, rs.getObject(colName));
}
break;
}
}
}
list.add(object);
}
return list;
} catch (Exception e) {
e.printStackTrace();
} finally {
DbHelper.closeConn(conn, ps, rs);
}
return null;
}
/**
* 以对象的形式保存或更新一个实体
*
* @param sql
* 要执行的sql语句
* @param object
* 要保存或更新的实体对象
* @param args
* 不需要赋值的列标组成的数组，例如sql语句
* "insert into tbl_user values(seq_user.nextval,?,?,?)"应为1
* @return 操作结果，1 成功，0 失败
*/
public int saveEntity(String sql, Object object, int... args) {
conn = DbHelper.getConn();
try {
ps = conn.prepareStatement(sql);
Class c = object.getClass();
Field[] fields = object.getClass().getDeclaredFields();
int temp = 1;// 正赋值的？的下标，最大下标为args的长度
int colIndex = 1;// SQL语句中的当前字段下标
int t = 0;// args数组的下标
for (int j = 0; j < fields.length; j++) {
Field field = fields[j];// 得到某个声明属性
String methodName = "get"
+ field.getName().substring(0, 1).toUpperCase()
+ field.getName().substring(1);
Method method = c.getMethod(methodName);// 得到了当前类中的一个method
String rType = field.getType().getSimpleName().toString();
if (t < args.length && colIndex == args[t]) {
t++;
} else if ("int".equals(rType) || "INTEGER".equals(rType)) {
ps.setInt(temp++, (Integer) method.invoke(object));
} else {
ps.setObject(temp++, method.invoke(object));
}
colIndex++;// 更新索引下标
}
return ps.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
} finally {
DbHelper.closeConn(conn, ps, null);
}
return 0;
}
/**
* 执行可变参数的SQL语句，进行保存、删除或更新操作
*
* @param sql
* 要执行的sql语句，?的赋值顺序必须与args数组的顺序相同
* @param args
* 要赋值的参数列表
* @return 操作结果，正数 成功，0 失败
*/
public int saveOrUpdate(String sql, Object... args) {
conn = DbHelper.getConn();
try {
ps = conn.prepareStatement(sql);
for (int j = 0; j < args.length; j++) {
ps.setObject(j + 1, args[j]);
}
return ps.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
} finally {
DbHelper.closeConn(conn, ps, null);
}
return 0;
}
} 2. 데이터 베 이 스 를 연결 하 는 DbHelper 도구 클래스
package utils;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
/**
* 数据库工具类
*
* @author Jzl
*
*/
public class DbHelper {
/**
* 获得一个数据库连接
*
* @return
*/
public static Connection getConn() {
Connection conn = null;
try {
Class.forName("oracle.jdbc.driver.OracleDriver");
String url = "jdbc:oracle:thin:@localhost:1521:orcl";
conn = DriverManager.getConnection(url, "scott", "tiger");
} catch (Exception e) {
e.printStackTrace();
}
return conn;
}
/**
* 关闭数据库连接资源
*
* @param conn
* @param ps
* @param rs
*/
public static void closeConn(Connection conn, Statement ps, ResultSet rs) {
try {
if (rs != null) {
rs.close();
rs = null;
}
if (ps != null) {
ps.close();
ps = null;
}
if (conn != null) {
conn.close();
conn = null;
}
} catch (Exception e) {
e.printStackTrace();
}
}
}3. 이제 베이스 다 오 를 테스트 할 수 있 습 니 다.테스트 에 사용 할 User 실체 클래스:
package entity;
import java.sql.Date;
/**
* 用于测试的JavaBean，符合JavaBea命名规范
* @author Jzl
*
*/
public class User {
private int userId;
private String userName;
private String userPass;
private Date lastDate;
/**
* 无参构造函数，用于反射new一个实例（必须有）
*/
public User() {
}
public User(String userName, String userPass, Date lastDate) {
super();
this.userName = userName;
this.userPass = userPass;
this.lastDate = lastDate;
}
public int getUserId() {
return userId;
}
public void setUserId(int userId) {
this.userId = userId;
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
public String getUserPass() {
return userPass;
}
public void setUserPass(String userPass) {
this.userPass = userPass;
}
public Date getLastDate() {
return lastDate;
}
public void setLastDate(Date lastDate) {
this.lastDate = lastDate;
}
}4. 테스트 에 사용 되 는 UserDao
package dao;
import java.util.List;
import entity.User;
/**
* 用于测试的UserDao
* @author Jzl
*
*/
public class UserDao extends BaseDao {
public int addUser1(User user) {
return super.saveEntity(
"insert into tbl_user values(seq_user.nextval,?,?,?)", user, 1);
}
public int addUser2(User user) {
return super.saveOrUpdate(
"insert into tbl_user values(seq_user.nextval,?,?,?)",
user.getUserName(), user.getUserPass(), user.getLastDate());
}
public int deleteUserById(int userId) {
return super
.saveOrUpdate("delete from tbl_user where userId=?", userId);
}
public int modUserById(int userId, User user) {
return super
.saveOrUpdate(
"update tbl_user set userName=?,userPass=?,lastDate=? where userId=?",
user.getUserName(), user.getUserPass(),
user.getLastDate(), userId);
}
public User getUser(int userId) {
return super.executeQuery("select * from tbl_user where userId=?",
User.class, userId).get(0);
}
public List getUserList() {
return super.executeQuery("select * from tbl_user", User.class);
}
public long getUserCount(){
return super.getCount("select count(*) from tbl_user");
}
} 5 、 UserDao 테스트 에 사용 되 는 테스트 클래스
package test;
import java.sql.Date;
import java.util.List;
import org.junit.Test;
import dao.UserDao;
import entity.User;
public class UserDaoTest {
private UserDao userDao = new UserDao();
@Test
public void testUserDao() {
testAdd1();
testAdd2();
testDeleteById();
testModById();
System.out.println(testGetById().getUserName());
List users = testGetList();
for (User user : users) {
System.out.println(user.getUserId() + "==" + user.getUserName());
}
System.out.println(testGetCount());
}
public int testAdd1() {
User user = new User("zs", "zs", new Date(System.currentTimeMillis()));
return userDao.addUser1(user);
}
public int testAdd2() {
User user = new User("zs", "zs", new Date(System.currentTimeMillis()));
return userDao.addUser2(user);
}
public int testDeleteById() {
return userDao.deleteUserById(104);
}
public User testGetById() {
return userDao.getUser(104);
}
public int testModById() {
User user = new User("ls", "ls", new Date(System.currentTimeMillis()));
return userDao.modUserById(104, user);
}
public List testGetList() {
return userDao.getUserList();
}
public long testGetCount() {
return userDao.getUserCount();
}
} 6. 테스트 에 사용 할 데이터베이스 시트 만 들 기
여기 서 Oracle 데이터 베 이 스 를 테스트 합 니 다. 표 문 구 는 다음 과 같 습 니 다.
--创建测试表
create table tbl_user
(
userId number(8) primary key not null,
userName varchar2(20),
userPass varchar2(20),
lastDate Date
);
create sequence seq_user;이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Oacle 감청 시작, 정지, 명령 보기그리고 모니터 를 시작 합 니 다. lsnrctl start 는 시작 에 성공 한 화면 을 볼 수 있 습 니 다. Oacle 데이터베이스 의 안전 은 두 부분 을 포함 합 니 다: oracle 소프트웨어 자체 의 안...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
