package com.sxdx.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 java.util.Map;
import util.DBConection;
import com.sxdx.dao.OperateDao;
import com.sxdx.entity.Page;
import com.sxdx.entity.Represent;
import com.sxdx.entity.Task;
import com.sxdx.entity.User;
/**
* 任务查询
* @author Administrator
*
*/
public class OperateDaoImpl implements OperateDao{
/**
* 查询任务信息
*/
public List<Represent> findAll() throws Exception{
List<Represent> reps = new ArrayList();
Connection conn = null;
PreparedStatement stat = null;
ResultSet rs = null;
try{
conn=DBConection.openConnection();
stat=conn.prepareStatement("select * from tb_represent");
rs=stat.executeQuery();
while (rs.next()) {
Represent rep = new Represent();
rep.setId(rs.getInt("id"));
rep.setTid(rs.getInt("tid"));
rep.setShortname(rs.getString("shortname"));
rep.setRepresent(rs.getString("represent"));
reps.add(rep);
}
}catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}finally{
DBConection.closeConnection(conn, stat, rs);
}
return reps;
}
/**
* 根据id查询任务信息
*/
public List<Represent> findTaskById(Page page) throws Exception{
List<Represent> reps = new ArrayList<Represent>();
Connection conn = null;
PreparedStatement stat = null;
ResultSet rs = null;
try{
conn=DBConection.openConnection();
page.setCountItem(countReps());
int index = (page.getCurrentPage()-1)*2;
stat=conn.prepareStatement("select * from tb_represent limit ?,?");
stat.setInt(1, index);
stat.setInt(2, page.getPageSize());
rs=stat.executeQuery();
while(rs.next()){
Represent rep = new Represent();
rep.setId(rs.getInt("id"));
rep.setTid(rs.getInt("tid"));
rep.setShortname(rs.getString("shortname"));
rep.setRepresent(rs.getString("represent"));
reps.add(rep);
}
}catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}finally{
DBConection.closeConnection(conn, stat, rs);
}
return reps;
}
/**
* 统计
*/
public int countReps(){
int countItem=0;
Connection conn = null;
PreparedStatement stat = null;
ResultSet rs = null;
try {
conn=DBConection.openConnection();
stat=conn.prepareStatement("select count(*) countItem from tb_represent ");
rs=stat.executeQuery();
if(rs.next()){
countItem=rs.getInt("countItem");
}
} catch (Exception e) {
e.printStackTrace();
}
return countItem;
}
/**
* 根据时间查询任务,获取represent对象集合
*
*/
public List<Represent> findTaskByTime(String str,Page page,Map<String, Object> session) {
Connection con = null;
PreparedStatement ps = null;
ResultSet rs = null;
List<Represent> reps = new ArrayList<Represent>();
try {
con = DBConection.openConnection();
//这里需要获取tb_task的pid值
User user = (User)session.get("session_user");
page.setCountItem(getCountOfTaskByTime(str,session));
int index = (page.getCurrentPage()-1)*2;
String sql = "select r.id,r.tid,r.shortname,r.represent from tb_task t,tb_represent r where t.id=r.tid and t.dtime=? and t.pid=? limit ?,?";
ps = con.prepareStatement(sql);
ps.setString(1, str);
ps.setInt(2, user.getId());
ps.setInt(3, index);
ps.setInt(4, page.getPageSize());
rs = ps.executeQuery();
while(rs.next()){
Represent rep = new Represent();
rep.setId(rs.getInt("id"));
rep.setTid(rs.getInt("tid"));
rep.setShortname(rs.getString("shortname"));
rep.setRepresent(rs.getString("represent"));
reps.add(rep);
}
} catch (Exception e) {
e.printStackTrace();
}finally{
DBConection.closeConnection(con, ps, rs);
}
return reps;
}
/**
* 根据日期查询任务,获取总条数
*/
public int getCountOfTaskByTime(String str,Map<String, Object> session){
Connection con = null;
PreparedStatement ps = null;
ResultSet rs = null;
int count = 0;
try {
con = DBConection.openConnection();
User user = (User)session.get("session_user");
String sql = "select count(*) count from tb_task t,tb_represent r where t.id=r.tid and t.dtime=? and t.pid=?";
ps = con.prepareStatement(sql);
ps.setString(1, str);
ps.setInt(2, user.getId());
rs = ps.executeQuery();
if(rs.next()){
count =rs.getInt("count");
}
} catch (Exception e) {
e.printStackTrace();
}finally{
DBConection.closeConnection(con, ps, rs);
}
return count;
}
/**
* 根据任务名称查询任务
*/
public List<Represent> findTaskByShortname(Page page, Represent represent,Map<String, Object> session) {
Connection con = null;
PreparedStatement ps = null;
ResultSet rs = null;
List<Represent> reps = new ArrayList<Represent>();
try {
con = DBConection.openConnection();
User user = (User)session.get("session_user");
page.setCountItem(getCountOfTaskByName(represent.getShortname(),session));
int index = (page.getCurrentPage()-1)*2;
String sql = "select r.id,r.tid,r.shortname,r.represent from tb_task t,tb_represent r where t.id=r.tid and r.shortname like ? and t.pid=? limit ?,?";
ps = con.prepareStatement(sql);
ps.setString(1, "%"+represent.getShortname()+"%");
ps.setInt(2, user.getId());
ps.setInt(3, index);
ps.setInt(4, page.getPageSize());
rs = ps.executeQuery();
while(rs.next()){
Represent rep = new Represent();
rep.setId(rs.getInt("id"));
rep.setTid(rs.getInt("tid"));
rep.setShortname(rs.getString("shortname"));
rep.setRepresent(rs.getString("represent"));
reps.add(rep);
}
} catch (Exception e) {
e.printStackTrace();
}finally{
DBConection.closeConnection(con, ps, rs);
}
return reps;
}
/**
* 根据日期查询任务,获取总条数
*/
public int getCountOfTaskByName(String str,Map<String, Object> session){
Connection con = null;
PreparedStatement ps = null;
ResultSet rs = null;
int count = 0;
try {
con = DBConection.openConnection();
User user = (User)session.get("session_user");
String sql = "select count(*) count from tb_task t,tb_represent r where t.id=r.tid and r.shortname like ? and t.pid=?";
ps = con.prepareStatement(sql);
ps.setString(1, "%"+str+"%");
ps.setInt(2, user.getId());
rs = ps.executeQuery();
if(rs.next()){
count =rs.getInt("count");
}
} catch (Exception e) {
e.printStackTrace();
}finally{
DBConection.closeConnection(con, ps, rs);
}
return count;
}
/**
*删除represent中的记录
*/
public int deleteRepresent(int id) {
Connection con = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
con = DBConection.openConnection();
String sql = "delete from tb_represent where id=?";
ps = con.prepareStatement(sql);
ps.setInt(1, id);
id = ps.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
}finally{
DBConection.closeConnection(con, ps, rs);
}
return id;
}
/**
* 根据id查找出需修改的任务
*/
public Represent findTaskById(Represent represent) {
Connection con = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
con = DBConection.openConnection();
String sql = "select r.id,r.tid,r.shortname,r.represent from tb_task t,tb_represent r where t.id=r.tid and r.id=?";
ps = con.prepareStatement(sql);
ps.setInt(1, represent.getId());
rs = ps.executeQuery();
while(rs.next()){
represent = new Represent();
represent.setId(rs.getInt("id"));
represent.setTid(rs.getInt("tid"));
represent.setShortname(rs.getString("shortname"));
represent.setRepresent(rs.getString(
没有合适的资源?快使用搜索试试~ 我知道了~
资源推荐
资源详情
资源评论
收起资源包目录
基于J2EE的个人时间管理系统的设计与实现 (166个子文件)
OperateDaoImpl.class 9KB
UserManageImpl.class 8KB
DiaryDaoImpl.class 8KB
OperateAction.class 5KB
RiliDiaryDaoImpl.class 5KB
DiaryAction.class 5KB
TaskManageImpl.class 4KB
UserMessageAction.class 3KB
RiliDiaryAction.class 3KB
ModifypwdAction.class 3KB
renwuAction.class 2KB
User.class 2KB
LoginAction.class 2KB
TixingAction.class 2KB
Page.class 2KB
dataBaseAction.class 2KB
DBConection.class 2KB
BaseAction.class 2KB
Diary.class 1KB
RiliDiary.class 1KB
RegistAction.class 1KB
Represent.class 1KB
OperateDao.class 1KB
Task.class 926B
DiaryDao.class 877B
UserManage.class 845B
TaskManage.class 691B
RiliDiaryDao.class 631B
CalendarManage.class 122B
.classpath 981B
org.eclipse.wst.jsdt.ui.superType.container 49B
admin.css 2KB
admin.css 2KB
wnl.css 2KB
Thumbs.db 25KB
admin_p.gif 4KB
label3.gif 1KB
login_6.gif 898B
bt_login.gif 300B
menu_icon.gif 64B
index.html 15KB
setclock.html 4KB
trymusic.html 3KB
xwork-core-2.1.6.jar 1.49MB
freemarker-2.3.15.jar 859KB
struts2-core-2.1.8.1.jar 738KB
mysql-connector-java-5.0.8-bin.jar 528KB
ognl-2.7.3.jar 234KB
commons-io-1.3.2.jar 86KB
commons-fileupload-1.2.1.jar 56KB
OperateDaoImpl.java 10KB
UserManageImpl.java 9KB
DiaryDaoImpl.java 9KB
RiliDiaryDaoImpl.java 5KB
OperateAction.java 5KB
TaskManageImpl.java 4KB
DiaryAction.java 3KB
UserMessageAction.java 2KB
RiliDiaryAction.java 2KB
User.java 2KB
renwuAction.java 2KB
ModifypwdAction.java 2KB
Page.java 2KB
LoginAction.java 2KB
TixingAction.java 1KB
OperateDao.java 1KB
DBConection.java 1KB
Diary.java 1KB
BaseAction.java 1KB
DiaryDao.java 1KB
dataBaseAction.java 1002B
RiliDiary.java 863B
Represent.java 858B
UserManage.java 812B
RegistAction.java 809B
TaskManage.java 664B
Task.java 639B
RiliDiaryDao.java 582B
CalendarManage.java 136B
renwu-back.jpg 194KB
renwu.jpg 139KB
sousuo.jpg 86KB
3.jpg 84KB
hh.jpg 79KB
wnl.jpg 73KB
body.jpg 68KB
hengfu.jpg 64KB
yonghu.jpg 58KB
renwu1.jpg 57KB
data.jpg 56KB
yonghuback.jpg 42KB
back.jpg 32KB
login_2.jpg 31KB
background.jpg 24KB
header_right.jpg 18KB
header_left.jpg 15KB
login_5.jpg 2KB
menu_bt.jpg 2KB
login_1.jpg 1KB
login_4.jpg 718B
共 166 条
- 1
- 2
资源评论
- faith翼2013-12-18还是比较复杂的
- qq_296520512018-05-31还没看,不知道怎么样
- Slong2014-03-16垃圾,不能用啊,坑爹!
霸气o外漏
- 粉丝: 49
- 资源: 69
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功