tableaccess.java

来自「Athena酒店小组_Athena酒店管理系统」· Java 代码 · 共 100 行

/*
 * TableAccess.java
 *
 * Created on 2007年6月18日, 上午3:26
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package dennis;
import java.util.*;
import java.sql.*;

import plugin.*;
/**
 *
 * @author dennis
 */
public class TableAccess {
    private IDBResource dbRes;
    
    /** Creates a new instance of TableAccess */
    public TableAccess(IDBResource dbRes) 
    {
        this.dbRes = dbRes;
    }
    public TableInfo getTableById(String tableId)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "SELECT * FROM DeptInfo WHERE TableId = ?";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ps.setString(1, tableId);
	    ResultSet rs = ps.executeQuery();
	    ArrayList<TableInfo> tables = new ArrayList<TableInfo>();
	    if(rs.next())
	    {
		TableInfo table = new TableInfo();
		table.setTableId(rs.getString("TableId"));
		table.setTableName(rs.getString("TableName"));
		table.setTableType(rs.getString("TableType"));	
                table.setUseInfo("UseInfo");
		return table;
	    }	    
	    return null;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return null;
	}		
    }  
    
    public int update(String tableId,String mes)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "UPDATE TableInfo SET UseInfo = ? WHERE TableId = ?";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ps.setString(1, mes);
	    ps.setString(2, tableId);
	    int rs = ps.executeUpdate();	    
	    return rs;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return -1;
	}    
    }
   public ArrayList<TableInfo> getAllTables()
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "SELECT * FROM TableInfo";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ResultSet rs = ps.executeQuery();
	    ArrayList<TableInfo> tables = new ArrayList<TableInfo>();
	    while(rs.next())
	    {
		TableInfo table = new TableInfo();
		table.setTableId(rs.getString("TableId"));
		table.setTableName(rs.getString("TableName"));
		table.setTableType(rs.getString("TableType"));
                table.setUseInfo(rs.getString("UseInfo"));
		tables.add(table);
	    }
	    return tables;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return null;
	}		
    }
}