noncurrentliabilityaccess.java

Athena酒店小组_Athena酒店管理系统

/*
 * NonCurrentLiabilityAccess.java
 *
 * Created on 2007年6月19日, 上午5:32
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package minco;

import java.util.*;
import java.sql.*;
import plugin.*;
import helper.*;

/**
 *
 * @author mj
 */
public class NonCurrentLiabilityAccess 
{
    private IDBResource dbRes;
    
    /** Creates a new instance of CurrentLiabilityAccess */
    public  NonCurrentLiabilityAccess(IDBResource dbRes)
    {
	this.dbRes = dbRes;
    }
    
    public int insert(NonCurrentLiability nonCurrentLiability)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "INSERT INTO NonCurrentLiability(LiabilityTime, LongTermLoan, BondPayables, OtherLongTermLiablity) " +
		    " VALUES(?, ?, ?, ?)";
	    PreparedStatement ps = conn.prepareStatement(sql);
            ps.setObject(1, nonCurrentLiability.getLiabilityTime());
	    ps.setDouble(2, nonCurrentLiability.getLongTermLoan());
	    ps.setDouble(3, nonCurrentLiability.getBondPayables());
	    ps.setDouble(4, nonCurrentLiability.getOtherLongTermLiablity());
	    int rs = ps.executeUpdate();	    
	    return rs;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return -1;
	}		
    }
    
    public int update(NonCurrentLiability nonCurrentLiability)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "UPDATE NonCurrentLiability SET LongTermLoan = ?, BondPayables = ?, OtherLongTermLiablity = ? WHERE LiabilityTime = ?";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ps.setDouble(1, nonCurrentLiability.getLongTermLoan());
	    ps.setDouble(2, nonCurrentLiability.getBondPayables());
	    ps.setDouble(3, nonCurrentLiability.getOtherLongTermLiablity());
            ps.setObject(4, nonCurrentLiability.getLiabilityTime());
	    int rs = ps.executeUpdate();	    
	    return rs;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return -1;
	}		
    }
    
    public int delete(NonCurrentLiability nonCurrentLiability)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "DELETE FROM NonCurrentLiability WHERE LiabilityTime = ?";
	    PreparedStatement ps = conn.prepareStatement(sql);	   
            ps.setObject(1, nonCurrentLiability.getLiabilityTime());
	    int rs = ps.executeUpdate();	    
	    return rs;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return -1;
	}		
    }
    
    public NonCurrentLiability getCurrentLiabilityByTime(java.util.Date liabilityTime)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "SELECT * FROM NonCurrentLiability WHERE liabilityTime = ?";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ps.setObject(1, liabilityTime);
	    ResultSet rs = ps.executeQuery();
	    ArrayList<NonCurrentLiability> nonCurrentLiability = new ArrayList<NonCurrentLiability>();
	    readData(nonCurrentLiability, rs);
	    if (nonCurrentLiability.size() != 1)
	    {
		return null;
	    }
	    return nonCurrentLiability.get(0);
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return null;
	}
    }
    
    /**
     * 返回 CurrentLiability表的所有信息
     * @return 所有非流动负债信息
     */
    public ArrayList< NonCurrentLiability> getAllCurrentLiability()
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "SELECT * FROM NonCurrentLiability";
	    PreparedStatement ps = conn.prepareStatement(sql);
	    ResultSet rs = ps.executeQuery();
	    ArrayList<NonCurrentLiability> nonCurrentLiability = new ArrayList<NonCurrentLiability>();
	    readData(nonCurrentLiability, rs);
	    return nonCurrentLiability;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return null;
	}
    }
    
    /**
     * 根据条件查询CurrentLiability表的信息
     * @param names 条件的名称
     * @param values 条件的值
     * @return 查询到的非流动负债信息
     */
    public ArrayList<NonCurrentLiability> getCurrentLiabilityByCondition(ArrayList<String> names, ArrayList<Object> values)
    {
	try
	{
	    Connection conn = dbRes.getConnection();
	    String sql = "SELECT * FROM NonCurrentLiability " + SQLHelper.createCondition(names);
	    PreparedStatement ps = conn.prepareStatement(sql);
	    for(int i = 0; i < values.size(); i++)
	    {
		ps.setObject(i+1, values.get(i));
	    }
	    ResultSet rs = ps.executeQuery();
	    ArrayList<NonCurrentLiability> nonCurrentLiability = new ArrayList<NonCurrentLiability>();
	    readData(nonCurrentLiability, rs);
	    return nonCurrentLiability;
	}
	catch (SQLException ex)
	{
	    ex.printStackTrace();
	    return null;
	}
    }
    
    //读取数据
    private void readData(ArrayList<NonCurrentLiability> nonCurrentLiability, ResultSet rs) throws SQLException
    {
	while(rs.next())
	{
	    NonCurrentLiability noncurrentLiabilities = new NonCurrentLiability();
	    noncurrentLiabilities.setLiabilityTime(rs.getDate("LiabilityTime"));
	    noncurrentLiabilities.setLongTermLoan(rs.getDouble("LongTermLoan"));
	    noncurrentLiabilities.setBondPayables(rs.getDouble("BondPayables"));
	    noncurrentLiabilities.setOtherLongTermLiablity(rs.getDouble("OtherLongTermLiablity"));
	    nonCurrentLiability.add(noncurrentLiabilities);
	}
    }
}