postdatabean.java

来自「采用j2ee架构做的bbs」· Java 代码 · 共 121 行

/*
 * 创建日期 2006-5-24
 *
 * TODO 要更改此生成的文件的模板，请转至
 * 窗口 － 首选项 － Java － 代码样式 － 代码模板
 */
package net.icefish.bean;

import java.sql.*;
import net.icefish.bean.Conn;
import net.icefish.bean.PostBean;

/**
 * @author LittleChild
 *
 * TODO 要更改此生成的类型注释的模板，请转至
 * 窗口 － 首选项 － Java － 代码样式 － 代码模板
 */
public class PostDataBean {
	
	private Connection conn;	
	//private ResultSet rs;
	
	public PostDataBean(){
		this.conn=Conn.connection();
	}

   
	public boolean addPost(PostBean postBean){
		boolean flag=false;
        
    	Statement stmt=null;
    	PreparedStatement pstmt1=null;
    	PreparedStatement pstmt2=null;
    	try{
    		//把相关信息存入表icefish_topic,并获得当前插入的topic的ID
    		stmt=conn.createStatement();
    		pstmt1=conn.prepareStatement("insert into icefish_topic(topic_boardid,topic_name,topic_user,topic_time) values(?,?,?,now())");
    		pstmt1.setString(1, postBean.getBoard_Id());
    		pstmt1.setString(2, postBean.getTopic_Name());
    		pstmt1.setString(3, postBean.getUser_Name());
    		int result1=pstmt1.executeUpdate();
    		if (result1 > 0){
                flag = true;
            }
            else{
                flag = false;
            }
    		
    		ResultSet rs=stmt.executeQuery("select @@identity as 'topic_id'");
    		while(rs.next()){
    			String topic_id=rs.getString("topic_id");
    	
    			//把相关信息存入表icefish_post
    			pstmt2=conn.prepareStatement("insert into icefish_post(post_topicid,post_content,post_boardid,post_user,post_time) values(?,?,?,?,now()) ");
    			pstmt2.setString(1, topic_id);
    			pstmt2.setString(2, postBean.getPost_Content());
    			pstmt2.setString(3, postBean.getBoard_Id());
    			pstmt2.setString(4, postBean.getUser_Name());
    			int result2=pstmt2.executeUpdate();  			
    			if (result2 > 0){
                    flag = true;
                }
                else{
                    flag = false;
                }
    			pstmt2.close();  
    		}
    		rs.close();
    		stmt.close();
    		pstmt1.close();
    		conn.close();
    	}
    	catch(SQLException e){
    		flag=false;
    		System.out.println(e.toString());
    	}
    	
        return flag;
	}
	   
	
	
	public boolean replyPost(PostBean postBean){
		boolean flag=false;
        
    	//Statement stmt=null;
    	PreparedStatement pstmt1=null;
    	try{
    			String topic_id=postBean.getTopic_Id();
    	
    			//把相关信息存入表icefish_post
    			pstmt1=conn.prepareStatement("insert into icefish_post(post_topicid,post_content,post_boardid,post_user,post_time) values(?,?,?,?,now()) ");
    			pstmt1.setString(1, topic_id);
    			pstmt1.setString(2, postBean.getPost_Content());
    			pstmt1.setString(3, postBean.getBoard_Id());
    			pstmt1.setString(4, postBean.getUser_Name());
    			int result2=pstmt1.executeUpdate();  			
    			if (result2 > 0){
                    flag = true;
                }
                else{
                    flag = false;
                }
    			pstmt1.close();  
    		
    		//rs.close();
    		//stmt.close();
    		pstmt1.close();
    		conn.close();
    	}
    	catch(SQLException e){
    		flag=false;
    		System.out.println(e.toString());
    	}
    	
        return flag;
	}

}