reply.java~15~

来自「用户的注册 用户的登陆 发布用户的相关信息 浏览网站介绍的其他酒店的」· JAVA~15~ 代码 · 共 161 行

package dao;

import java.util.*;

import domain.*;
import java.sql.Connection;
import tool.Conn;
import java.sql.Statement;
import tool.SQLCode;
import tool.EidetSql;
import java.sql.SQLException;
import java.sql.ResultSet;
import tool.DateTime;

public class Reply implements ReplyDao {
    EidetSql eidetSql = new EidetSql();
    public Reply() {
    }


    /*******************************************
     * method name:delete
     * method function :删除数据
     * return type:int
     * datetime : 2007-09-17
     *******************************************/

    public int delete(ReplyForm re) {
        Connection con = null;
        Statement st = null;
        Conn cn = new Conn();
        int row = 0;
        SQLCode sqlCode = new SQLCode();
        String sql = sqlCode.getSQLCode("sql.reply.delete");
        sql = eidetSql.editSqlInt(sql, re.getId());
        try {
            con = cn.getConnection();
            st = con.createStatement();
            row = st.executeUpdate(sql);
            st.close();
            con.close();
        } catch (SQLException ex) {
            System.out.println("回复表deleteSql:" + ex.getMessage());
        } catch (ClassNotFoundException ex) {
            System.out.println("回复表delete类加载:" + ex.getMessage());
        }
        return row;
    }

    /*******************************************
     * method name:eidSelect
     * method function :根据企业编号查询回复
     * return type:Collection
     * datetime : 2007-09-17
     *******************************************/
    public Collection eidSelect(ReplyForm re) {
        Connection con = null;
        Statement st = null;
        ResultSet rs = null;
        Conn cn = new Conn();
        Collection list = new ArrayList();
        SQLCode sqlCode = new SQLCode();
        String sql = sqlCode.getSQLCode("sql.reply.eidselect");
        sql = eidetSql.editSqlInt(sql, re.getEid());
        try {
            con = cn.getConnection();
            st = con.createStatement();
            rs = st.executeQuery(sql);
            while (rs.next()) {
                re = new ReplyForm();
                re.setId(rs.getInt(1));
                re.setEid(rs.getInt(2));
                re.setContent(rs.getString(3));
                re.setTime(rs.getString(4));
                list.add(re);
            }
            rs.close();
            st.close();
            con.close();
        } catch (SQLException ex) {
            System.out.println("企业回复表eidSelect sql:" + ex.getMessage());
        } catch (ClassNotFoundException ex) {
            System.out.println("企业回复表类eidSelect加载:" + ex.getMessage());
        }
        return list;
    }

    /*******************************************
     * method name:insert
     * method function :插入数据
     * return type:Collection
     * datetime : 2007-09-17
     *******************************************/

    public int insert(ReplyForm re) {
        Connection con = null;
        Statement st = null;
        Conn cn = new Conn();
        DateTime time = new DateTime();
        int row = 0;
        SQLCode sqlCode = new SQLCode();
        String sql = sqlCode.getSQLCode("sql.reply.insert");
        sql = eidetSql.editSqlInt(sql, re.getEid());
        sql = eidetSql.editSqlInt(sql, re.getAid());
        sql = eidetSql.editSqlStr(sql, re.getContent());
        sql = eidetSql.editSqlStr(sql, time.getYMD());
        try {
            con = cn.getConnection();
            st = con.createStatement();
            row = st.executeUpdate(sql);
            st.close();
            con.close();
        } catch (SQLException ex) {
            System.out.println("企业回复表insertSql:" + ex.getMessage());
        } catch (ClassNotFoundException ex) {
            System.out.println("企业回复表insert类加载:" + ex.getMessage());
        }
        return row;
    }

    /*******************************************
     * method name:select
     * method function :根据反馈编号查询数据
     * return type:Collection
     * datetime : 2007-09-17
     *******************************************/

    public Collection select(ReplyForm re) {
        Connection con = null;
        Statement st = null;
        ResultSet rs = null;
        Conn cn = new Conn();
        Collection list = new ArrayList();
        SQLCode sqlCode = new SQLCode();
        String sql = sqlCode.getSQLCode("sql.reply.aidselect");
        sql = eidetSql.editSqlInt(sql, re.getAid());
        try {
            con = cn.getConnection();
            st = con.createStatement();
            rs = st.executeQuery(sql);
            while (rs.next()) {
                re = new ReplyForm();
                re.setId(rs.getInt(1));
                re.setEid(rs.getInt(2));
                re.setContent(rs.getString(3));
                re.setTime(rs.getString(4));
                list.add(re);
            }
            rs.close();
            st.close();
            con.close();
        } catch (SQLException ex) {
            System.out.println("企业回复表eidSelect sql:" + ex.getMessage());
        } catch (ClassNotFoundException ex) {
            System.out.println("企业回复表类eidSelect加载:" + ex.getMessage());
        }
        return list;

    }
}