tjoindao.java

招标网站

package com.jblack.dao;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.jblack.model.Tjoin;
import com.jblack.tool.DBConnection;

public class TjoinDAO {
	private DBConnection conn = new DBConnection();
	
	public int save(Tjoin j) {
		String sql ="insert into Tjoin (TC_id,TP_id,TJ_status) values(" +
				j.getTcid()+","+j.getTpid()+","+j.getTjstatus() + ")";
		int num = conn.insertAndGetPKKey(sql);
		conn.close();
		return num;
				
	}
	
	public List<Tjoin> query(int tcid) {
		List<Tjoin> list = new ArrayList<Tjoin>();
		ResultSet rs = conn.executeQuery("select * from Tjoin where TC_id=" + tcid);
		try {
			while(rs.next()) {
				list.add(new Tjoin(rs.getInt("TJ_id"),rs.getInt("TC_id"),
						rs.getInt("TP_id"),rs.getInt("TJ_status")));
			}
		}catch(SQLException e) {
			e.printStackTrace();
		}finally {
			conn.close();
		}
		return list;
		
	}
	
	public List<Tjoin> aquery(String sql) {
		List<Tjoin> list = new ArrayList<Tjoin>();
		ResultSet rs = conn.executeQuery(sql);
		if (rs != null) {
			try {
				while (rs.next()) {
					list.add(new Tjoin(rs.getInt("TJ_id"), rs.getInt("TC_id"),
							rs.getInt("TP_id"),rs.getInt("TJ_status")));
					
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		conn.close();
		return list;
		
	}
}