tcompanydao.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.Tcompany;
import com.jblack.tool.DBConnection;

public class TcompanyDAO {
	protected DBConnection conn = new DBConnection();
	
	public List<Tcompany> query(String sql) {
		List<Tcompany> list = new ArrayList<Tcompany>();
		ResultSet rs = conn.executeQuery(sql);
		try {
			while (rs.next()) {
				list.add(new Tcompany(rs.getInt("TC_id"), rs
								.getString("TC_username"), rs
								.getString("TC_name"), rs
								.getString("TC_password"), rs
								.getString("TC_company_id"), rs
								.getString("TC_telephone"), rs
								.getString("TC_address"), rs
								.getString("TC_pwd_question"), rs
								.getString("TC_pass_answer"), rs
								.getInt("TC_status"), rs.getString("TC_email")));
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			conn.close();
		}
		return list;
	}

	public List<Tcompany> queryAll() {
		List<Tcompany> list = new ArrayList<Tcompany>();
		ResultSet rs = conn.executeQuery("select * from TCompany");
		try {
			while (rs.next()) {
				list.add(new Tcompany(rs.getInt("TC_id"), rs
								.getString("TC_username"), rs
								.getString("TC_name"), rs
								.getString("TC_password"), rs
								.getString("TC_company_id"), rs
								.getString("TC_telephone"), rs
								.getString("TC_address"), rs
								.getString("TC_pwd_question"), rs
								.getString("TC_pass_answer"), rs
								.getInt("TC_status"), rs.getString("TC_email")));
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			conn.close();
		}
		return list;
	}

	public int saveOrUpdate(Tcompany s) {
		int num = 0;
		ResultSet rs = conn.executeQuery("select * from TCompany where TC_id="
				+ s.getTcid());
		try {
			if (rs.next()) {
				num = conn.executeUpdate("update Tcompany set tc_username='"
						+ s.getTcusername() + "', tc_name='" + s.getTcname()+ "', tc_password='" + s.getTcpassword()
						+ "', tc_company_id='" + s.getTccompanyid() + "', tc_telephone='"
						+ s.getTctelephone() + "', tc_address='" + s.getTcaddress()
						+ "', tc_pwd_question='" + s.getTcpwdquestion() + "', tc_pass_answer='" + s.getTcpassanswer()
						+"', tc_status=" + s.getTcstatus() +", tc_email='" + s.getTcemail() + "' where TC_id='" + s.getTcid() + "'");
			} else {
				num = conn
						.executeUpdate("insert into TCompany" +
								"(TC_id,TC_username,TC_name,TC_password," +
								"TC_company_id,TC_telephone,TC_address," +
								"TC_pwd_question,TC_pass_answer,TC_status,TC_email) values ("
								+ s.getTcid()
								+ ", '"
								+ s.getTcusername()
								+ "', '"
								+ s.getTcname()
								+ "', '"
								+ s.getTcpassword()
								+ "', '"
								+ s.getTccompanyid()
								+ "', '"
								+ s.getTctelephone()
								+ "', '"
								+ s.getTcaddress()
								+ "', '"
								+ s.getTcpwdquestion()
								+ "', '"
								+ s.getTcpassanswer()
								+ "', "
								+ s.getTcstatus()
								+ ", '"
								+ s.getTcemail()
								+ "')");
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			conn.close();
		}
		return num;
	}
	
	

	public int save(Tcompany s) {
		String sql = "insert into TCompany(TC_id,TC_username,TC_name,TC_password," +
				"TC_company_id,TC_telephone,TC_address,TC_pwd_question," +
				"TC_status,TC_email) values ( '"
								+ s.getTcid()
								+ ", '"
								+ s.getTcusername()
								+ "', '"
								+ s.getTcname()
								+ "', '"
								+ s.getTcpassword()
								+ "', '"
								+ s.getTccompanyid()
								+ "', '"
								+ s.getTctelephone()
								+ "', '"
								+ s.getTcaddress()
								+ "', '"
								+s.getTcpwdquestion()
								+ "', '"
								+ s.getTcpassanswer()
								+ "', "
								+ s.getTcstatus()
								+ ", '"
								+ s.getTcemail()
								+ "')";
		int num = conn.insertAndGetPKKey(sql);
		conn.close();
		return num;
	}

	public Tcompany get(int no) {
		Tcompany s = null;
		ResultSet rs = conn
				.executeQuery("select * from TCompany where TC_id=" + no);
		try {
			while (rs.next()) {
				s = new Tcompany(rs.getInt("TC_id"), rs
						.getString("TC_username"), rs
						.getString("TC_name"), rs
						.getString("TC_password"), rs
						.getString("TC_company_id"), rs
						.getString("TC_telephone"), rs
						.getString("TC_address"), rs
						.getString("TC_pwd_question"), rs
						.getString("TC_pass_answer"), rs
						.getInt("TC_status"),rs
						.getString("TC_email"));
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			conn.close();
		}
		return s;
	}

	public Tcompany getpub(String username) {
		Tcompany s = null;
		ResultSet rs = conn
				.executeQuery("select * from TCompany where TC_username = '" + username+"'");
		try {
			while (rs.next()) {
				s = new Tcompany(rs.getInt("TC_id"), rs
						.getString("TC_username"), rs
						.getString("TC_name"), rs
						.getString("TC_password"), rs
						.getString("TC_company_id"), rs
						.getString("TC_telephone"), rs
						.getString("TC_address"), rs
						.getString("TC_pwd_question"), rs
						.getString("TC_pass_answer"), rs
						.getInt("TC_status"),rs
						.getString("TC_email"));
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			conn.close();
		}
		return s;
	}

	

	public void delete(int no) {
		conn.executeUpdate("delete from TCompany where TC_id=" + no);
		conn.close();
	}
}