room.java~26~

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

package dao;

import java.util.*;

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

public class Room implements RoomDao {
    EidetSql eidetSql = null;
    public Room() {
        eidetSql = new EidetSql();
    }

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

    public int delete(RoomForm room) {
        Connection con = null;
        Statement st = null;
        Conn cn = new Conn();
        int row = 0;
        SQLCode sqlCode = new SQLCode();
        String sql = sqlCode.getSQLCode("sql.room.delete");
        sql = eidetSql.editSqlInt(sql, room.getEid());
        sql = eidetSql.editSqlStr(sql, room.getType());
        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:insert
     * method function :插入数据
     * return type:int
     * datetime : 2007-09-17
     *******************************************/
    public int insert(RoomForm room) {
        Connection con = null;
        Statement st = null;
        Conn cn = new Conn();
        int row = 0;
        SQLCode sqlCode = new SQLCode();
        String sql = sqlCode.getSQLCode("sql.room.insert");
        sql = eidetSql.editSqlInt(sql, room.getEid());
        sql = eidetSql.editSqlStr(sql, room.getType());
        sql = eidetSql.editSqlFloat(sql, room.getPrice());
        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:int
     * datetime : 2007-09-17
     *******************************************/

    public Collection select(RoomForm room,int page) {
        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.room.select");
        sql = eidetSql.editSqlInt(sql, room.getEid());
        try {
            con = cn.getConnection();
            st = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
                                     ResultSet.CONCUR_READ_ONLY);
            rs = st.executeQuery(sql);
            int tip = 6 * (page - 1);
           try {
               if (tip <= 0) {
                   rs.beforeFirst();
               } else {
                   if (!rs.absolute(tip)) {
                       rs.beforeFirst();
                   }
               }
           } catch (SQLException ex1) {
               System.out.println("tip" + ex1.getMessage());
           }
           for (int i = 1; rs.next() && i <= 6; i++) {

                room = new RoomForm();
                room.setEid(rs.getInt(1));
                room.setType(rs.getString(2));
                room.setPrice(rs.getFloat(3));
                list.add(room);
            }
            rs.close();
            st.close();
            con.close();
        } catch (SQLException ex) {
            System.out.println("房间类型表selectSql:" + ex.getMessage());
        } catch (ClassNotFoundException ex) {
            System.out.println("房间类型表insert加载:" + ex.getMessage());
        }
        return list;
    }

    /*******************************************
     * method name:update
     * method function :更新数据
     * return type:int
     * datetime : 2007-09-17
     *******************************************/

    public int update(RoomForm room) {
        Connection con = null;
        Statement st = null;
        Conn cn = new Conn();
        int row = 0;
        SQLCode sqlCode = new SQLCode();
        String sql = sqlCode.getSQLCode("sql.room.update");
        sql = eidetSql.editSqlFloat(sql, room.getPrice());
        sql = eidetSql.editSqlInt(sql, room.getEid());
        sql = eidetSql.editSqlStr(sql, room.getType());
        try {
            con = cn.getConnection();
            st = con.createStatement();
            row = st.executeUpdate(sql);
            st.close();
            con.close();
        } catch (SQLException ex) {
            System.out.println("房间类型表updateSql:" + ex.getMessage());
        } catch (ClassNotFoundException ex) {
            System.out.println("房间类型表update类加载:" + ex.getMessage());
        }
        return row;
    }
}