package dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import util.DBConn;
import entity.Message;
import entity.Revert;
public class MessageDAO {
private Connection conn;
private PreparedStatement ps;
private Statement stmt;
private ResultSet rs;
/*
* 功能表示用户添加新留言
*/
public int saveMessage(Message message, String sql) {
conn=DBConn.getConn();
try {
ps=conn.prepareStatement(sql);
ps.setString(1,message.getSendName());
ps.setString(2, message.getTitle());
ps.setString(3, message.getContent());
//ps.setInt(4,message.getRevertNum());
//ps.setString(5,message.getSendTime());
int num=ps.executeUpdate();
return num;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return -1;
}
finally{
DBConn.closeSt(ps);
DBConn.closeConn(conn);
}
}
/*
* 修改留言表的回复次数
*/
public int updateMessage(String sql){
conn=DBConn.getConn();
try {
ps=conn.prepareStatement(sql);
int num=ps.executeUpdate();
return num;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return -1;
}
finally{
DBConn.closeSt(ps);
DBConn.closeConn(conn);
}
}
/*
* 功能表示通过MESSAGES表的id字段查询单个留言记录
*/
public Message getMessage(String sql) {
conn=DBConn.getConn();
try {
ps=conn.prepareStatement(sql);
rs=ps.executeQuery();
Message me = null;
if(rs.next()){
me=new Message();
me.setId(rs.getInt(1));
me.setSendName(rs.getString(2));
me.setTitle(rs.getString(3));
me.setContent(rs.getString(4));
me.setRevertNum(rs.getInt(5));
me.setSendTime(rs.getString(6));
}
return me;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return null;
}
finally{
DBConn.closeRs(rs);
DBConn.closeSt(ps);
DBConn.closeConn(conn);
}
}
/*
* 功能表示查询所有留言记录
*/
public List getMessages(String sql) {
List list = new ArrayList();
conn=DBConn.getConn();
try {
ps=conn.prepareStatement(sql);
rs=ps.executeQuery();
while(rs.next()){
Message me=new Message();
me.setId(rs.getInt(1));
me.setSendName(rs.getString(2));
me.setTitle(rs.getString(3));
me.setContent(rs.getString(4));
me.setRevertNum(rs.getInt(5));
me.setSendTime(rs.getString(6));
list.add(me);
}
return list;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return null;
}
finally{
DBConn.closeRs(rs);
DBConn.closeSt(ps);
DBConn.closeConn(conn);
}
}
private int num;//总条数
private int rowsInPage=5;//每页所显示有几条数据
private int allPage;//总页数
public int getNum() {
return num;
}
public void setNum(int num) {
this.num = num;
}
//查询所有数据
public void getCount(String sql){
conn=DBConn.getConn();
try {
stmt=conn.createStatement();
rs=stmt.executeQuery(sql);
if(rs.next()){
num=rs.getInt(1);
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally{
DBConn.closeRs(rs);
DBConn.closeSt(ps);
DBConn.closeConn(conn);
}
}
public List nextPage(String sql,int page){
conn=DBConn.getConn();
try {
stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
rs=stmt.executeQuery(sql);
if(page==1){
rs.beforeFirst();//游标定位到最前
}else
{
rs.absolute((page-1)*rowsInPage);
}
List list = new ArrayList();
for(int i=0;i<rowsInPage&&rs.next();i++){
Message me=new Message();
me.setId(rs.getInt(1));
me.setSendName(rs.getString(2));
me.setTitle(rs.getString(3));
me.setContent(rs.getString(4));
me.setRevertNum(rs.getInt(5));
me.setSendTime(rs.getString(6));
list.add(me);
}
return list;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return null;
}
finally{
DBConn.closeRs(rs);
DBConn.closeSt(ps);
DBConn.closeConn(conn);
}
}
/*
* 功能表示用户或管理员查询留言记录,页面显示的条数，分页显示。
*/
public List getMessages(String sql, int pageStart, int pageNum) {
conn=DBConn.getConn();
try {
stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
rs=stmt.executeQuery(sql);
if(pageStart==1){
rs.beforeFirst();//游标定位到最前
}else
{
rs.absolute((pageStart-1)*pageNum);
}
List list = new ArrayList();
for(int i=0;i<pageNum&&rs.next();i++){
Message me=new Message();
me.setId(rs.getInt(1));
me.setSendName(rs.getString(2));
me.setTitle(rs.getString(3));
me.setContent(rs.getString(4));
me.setSendTime(rs.getString(5));
list.add(me);
}
return list;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return null;
}
finally{
DBConn.closeRs(rs);
DBConn.closeSt(ps);
DBConn.closeConn(conn);
}
}
/*
* 功能表示管理员删除所有留言，该方法首先调用public int deleteRevert(String
sql){}，然后在删除所有留言。（后台设计）
*/
public int deleteAllMessage(String sql,String sql1) {
this.deleteAllRevert(sql1);
conn=DBConn.getConn();
try {
ps=conn.prepareStatement(sql);
int num=ps.executeUpdate();
return num;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return -1;
}
finally{
DBConn.closeSt(ps);
DBConn.closeConn(conn);
}
}
/*
* 功能表示管理员根据id删除一条留言，该方法首先调用public int deleteRevert(String sql,int
status){}，然后在删除该条留言。（后台设计）
*/
public int deleteMessage(String sql,String sql1, int status) {
this.deleteRevert(sql1, status);
return this.deleteAllRevert(sql);
// conn=DBConn.getConn();
// try {
// ps=conn.prepareStatement(sql);
// int num= ps.executeUpdate();
// return num;
// } catch (SQLException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// return -1;
// }
// finally{
// DBConn.closeSt(ps);
// DBConn.closeConn(conn);
// }
}
/*
* 功能表示用户或管理员添加回复留言
*/
public int saveRevert(Revert revert, String sql) {
conn=DBConn.getConn();
try {
ps=conn.prepareStatement(sql);
ps.setInt(1, revert.getMessageId());
ps.setString(2, revert.getSendName());
ps.setString(3, revert.getTitle());
ps.setString(4, revert.getContent());
int num=ps.executeUpdate();
return num;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return -1;
}
finally{
DBConn.closeSt(ps);
DBConn.closeConn(conn);
}
}
public Revert getRevert(String sql){
conn=DBConn.getConn();
try {
ps=conn.prepareStatement(sql);
rs=ps.executeQuery();
Revert revert=null;
if(rs.next()){
revert=new Revert();
revert.setId(rs.getInt(1));
revert.setMessageId(rs.getInt(2));
revert.setSendName(rs.getString(3));
revert.setTitle(rs.getString(4));
revert.setContent(rs.getString(5));
revert.setSendTime(rs.getString(6));
}
return revert;
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
return null;
}
finally{
DBConn.closeRs(rs);
DBConn.closeSt(ps);
DBConn.closeConn(conn);
}
}
/*
* 功能表示查询所有回复留言记录
*/
public List getReverts(String sql) {
conn=DBConn.getConn();
try {
ps=conn.prepareStatement(sql);
rs=ps.executeQuery();
List list
BBS论坛项目全部源代码-MYSQL数据库 （221个子文件） 
.mymetadata.bak 291B MessageDAO.class 9KB ProductDAO.class 6KB MessageService.class 5KB UsersDAO.class 3KB ProductService.class 3KB GetAllnews.class 2KB Product.class 2KB GetnewsDao.class 2KB DBConn.class 2KB Userdao.class 2KB GetnewService.class 2KB Message.class 1KB Revert.class 1KB UsersService.class 1KB User.class 1KB News.class 1KB Userservice.class 1KB GetAllnewservice.class 833B Liaoinfo.class 804B .classpath 670B org.eclipse.wst.common.component 458B org.eclipse.wst.jsdt.ui.superType.container 49B css.css 4KB dw.dwt 6KB
no_photo.gif 3KB tg-8.gif 2KB tg-6.gif 2KB tg-9.gif 2KB tg-3.gif 2KB bookbg.gif 2KB an5.gif 2KB tg-5.gif 1KB tg-4.gif 1KB tg-7.gif 1KB T_bottomright.gif 1KB qq.gif 1KB f1.gif 1KB QQonline.gif 1KB f3.gif 1KB post.gif 1001B back.gif 996B titlemu_2.gif 888B T_bottomleft.gif 886B kefu_down.gif 759B f2.gif 740B title.gif 718B T_right.gif 672B T_left.gif 575B sigline.gif 572B kefu_middle.gif 484B titlemu_1.gif 413B titlemu_3.gif 410B iboy.gif 125B igirl.gif 124B icon_arrow_r.gif 85B T_bottombg.gif 84B
left.html 3KB jia.html 731B quan.html 611B right.html 247B
mysql-connector-java-5.1.6-bin.jar 687KB sqljdbc.jar 247KB MessageDAO.java 11KB MessageService.java 7KB ProductDAO.java 6KB ProductService.java 2KB UsersDAO.java 2KB DBConn.java 2KB Product.java 1KB GetAllnews.java 1KB GetnewsDao.java 1KB GetnewService.java 1KB Message.java 1KB Revert.java 1KB Userdao.java 1KB News.java 983B UsersService.java 982B User.java 979B Userservice.java 595B GetAllnewservice.java 544B Liaoinfo.java 457B
tu.jpg 163KB 31.jpg 95KB d_r1_c1_z.jpg 40KB welcome.jpg 34KB d_r1_c1.jpg 21KB ch_r3_c2.jpg 17KB 111.jpg 14KB 1111.jpg 13KB botton-tj.jpg 10KB botton-cz.jpg 10KB d_r11_11_r1_c1.jpg 9KB cg1_r10_c1.jpg 9KB d_r13_c1.jpg 8KB js2.jpg 7KB d_r11_11_r1_c21.jpg 7KB d_r11_10_r1_c1.jpg 6KB sj1_r1_c5.jpg 6KB d_r11_13_r1_c1.jpg 6KB共 221 条
- 1
- 2
- 3
资源评论
精分的小逗比2018-02-08挺好的，但是是商城啊
辉大侠2015-05-19挺不错的，就是有点小问题的
大吉2015-03-26资源很好，对我很有用- aiku9302092019-04-15品红商城。。。。简直了。。
