?? projectdao.java
字號:
package com.runwit.bugreport.services.dao;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import com.runwit.bugreport.model.BugStatusModel;
import com.runwit.bugreport.model.GroupModel;
import com.runwit.bugreport.model.ProjectModel;
import com.runwit.bugreport.services.IProjectServices;
import com.runwit.common.db.DbDAO;
public class ProjectDAO extends DbDAO implements IProjectServices {
@Override
public Object mapRowToModel(ResultSet rs) throws SQLException {
ProjectModel model = new ProjectModel();
model.setProjectId(rs.getInt("projectId"));
model.setName(rs.getString("name"));
model.setOwner(rs.getString("owner"));
model.setRemark(rs.getString("remark"));
model.setCreateTime(rs.getLong("createTime"));
return model;
}
public boolean create(ProjectModel model) {
String sql = "insert into project(name, owner, remark, createTime) values(?, ?, ?, ?)";
String querySql = "select max(projectid) from project";
try
{
openConnection();
conn.setAutoCommit(false);
openPreparedStatement(sql);
pstmt.setString(1, model.getName());
pstmt.setString(2, model.getOwner());
pstmt.setString(3, model.getRemark());
pstmt.setLong(4, System.currentTimeMillis());
int iRet = pstmt.executeUpdate();
closePreparedStatement();
openPreparedStatement(querySql);
rs = pstmt.executeQuery();
if(rs.next()) {
model.setProjectId(rs.getInt(1));
}
closeResultSet();
closePreparedStatement();
conn.commit();
return true;
}catch(SQLException ex) {
ex.printStackTrace();
return false;
}
finally{
closeConnection();
}
}
public boolean set(ProjectModel model) {
String sql = "update project set name=?, owner=?, remark=? where projectid=?";
try
{
openConnection();
openPreparedStatement(sql);
pstmt.setString(1, model.getName());
pstmt.setString(2, model.getOwner());
pstmt.setString(3, model.getRemark());
pstmt.setInt(4, model.getProjectId());
int iRet = pstmt.executeUpdate();
return iRet == 1;
}catch(SQLException ex) {
ex.printStackTrace();
return false;
}
finally{
closePreparedStatement();
closeConnection();
}
}
public boolean remove(ProjectModel model) {
String sql = "delete from project where projectid=" + model.getProjectId();
try{
return updateBySql(sql) == 1;
}catch(SQLException ex) {
ex.printStackTrace();
return false;
}
}
private List listBySql(String sql) {
try {
return queryBySql(sql);
}catch(SQLException ex) {
ex.printStackTrace();
return null;
}
}
public List list() {
return listBySql("select * from project");
}
public ProjectModel get(int projectId) {
List models = listBySql("select * from project where projectid="+projectId);
if(models != null && models.size() > 0)
return (ProjectModel)models.get(0);
return null;
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -