BBS论坛管理.zip_BBS论坛_BBS论坛开发_longerj98

package com.DAO; import java.sql.*; import java.util.ArrayList; import java.util.List; import com.Bean.BbsBean; public class BbsDAO { //连接数据库 Connection con =null; Statement st =null; ResultSet rs =null; String url="jdbc:mysql://localhost:3306/bbs"; String dbuser ="root"; String dbpass ="123456"; //帖子增加 public int addbbs(String username, String bbstitle, String bbscontent, String datetime, String bbshot) { int n = 0; //1.加载数据库的驱动 try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } try { //2.创建con对象 con = DriverManager.getConnection(url,dbuser,dbpass); //3.创建st对象 st = con.createStatement(); //4.创建rs对象 String sql = "insert into bbs_bbs (username,bbstitle,bbscontent,datetime,bbshot) value('"+username+"','"+bbstitle+"','"+bbscontent+"','"+datetime+"','"+bbshot+"')"; n = st.executeUpdate(sql); //5.关闭数据库 st.close(); con.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return n; } //帖子查询 public List<BbsBean> findAll() { List<BbsBean> list = new ArrayList<BbsBean>(); //1.加载数据库的驱动 try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } try { //2.创建con对象 con = DriverManager.getConnection(url,dbuser,dbpass); //3.创建st对象 st = con.createStatement(); //4.创建rs对象 String sql = "select * from bbs_bbs"; rs = st.executeQuery(sql); while(rs.next()){ BbsBean bbs = new BbsBean(); int id =rs.getInt("bbsid"); String username =rs.getString("username"); String bbstitle = rs.getString("bbstitle"); String bbscontent =rs.getString("bbscontent"); String datetime =rs.getString("datetime"); String bbshot =rs.getString("bbshot"); bbs.setBbsid(id); bbs.setUsername(username); bbs.setBbstitle(bbstitle); bbs.setBbscontent(bbscontent); bbs.setDatetime(datetime); bbs.setBbshot(bbshot); list.add(bbs); } //关闭数据库 rs.close(); st.close(); con.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } //根据id查找该帖子 public BbsBean findBbsByID(String id) { BbsBean bbs = new BbsBean(); int i =Integer.parseInt(id); //1.加载数据库的驱动 try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } try { //2.创建con对象 con = DriverManager.getConnection(url,dbuser,dbpass); //3.创建st对象 st = con.createStatement(); //4.创建rs对象 String sql = "select * from bbs_bbs where bbsid = "+i; rs = st.executeQuery(sql); if(rs.next()){ int bbsid=rs.getInt("bbsid"); String bbstitle = rs.getString("bbstitle"); String bbscontent =rs.getString("bbscontent"); bbs.setBbsid(bbsid); bbs.setBbstitle(bbstitle); bbs.setBbscontent(bbscontent); } //5.关闭数据库 rs.close(); st.close(); con.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return bbs; } //帖子修改 public int updateBbs(String id, String bbstitle, String bbscontent) { int n = 0; //1.加载数据库的驱动 try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } try { //2.创建con对象 con = DriverManager.getConnection(url,dbuser,dbpass); //3.创建st对象 st = con.createStatement(); //4.创建rs对象 String sql = "update bbs_bbs set bbstitle='"+bbstitle+"' ,bbscontent='"+bbscontent+"' where bbsid="+id; n = st.executeUpdate(sql); //5.关闭数据库 st.close(); con.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return n; } }