commondao.java

oa rar it is the jsp

package com.accp.oa.dao.imple;

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

import com.accp.oa.common.*;

import java.sql.*;

public class commonDAO {
	public int tatolpage;

	public int tatolrows;

	public int pagenumber = 1;

	public int pagerows = 5;

	public ArrayList list = null;

	public static commonDAO common = null;

	public commonDAO() {
	}

	public static commonDAO GetcomonDAO() {
		if (common == null) {
			common = new commonDAO();
		}
		return common;
	}

	public int getpagenumber() {
		return pagenumber;
	}

	public void setpagenumber(int pagenumber) {
		this.pagenumber = pagenumber;
	}

	public ArrayList getList() {
		return list;
	}

	public void setList(ArrayList list) {
		this.list = list;
	}

	public int getpagerows() {
		return pagerows;
	}

	public void setpagerows(int pagerows) {
		this.pagerows = pagerows;
	}

	public int gettatolrows() {
		return tatolrows;
	}

	public void settatolrows(int tatolrows) {
		this.tatolrows = tatolrows;
	}

	public int gettatolpage() {
		return tatolpage;
	}

	public void settatolpage(int tatolpage) {
		this.tatolpage = tatolpage;
	}

	public void GetSTotalrows(String tablename ,String id) {
		StringBuffer sql = new StringBuffer();
		String sql1 = "";
		sql.append(Constants.CLIENT_COUNT);
		sql.append(tablename);
		if (tablename == "tb_client")
		{
			sql1 = sql.toString();
		}
		if (tablename == "tb_Stcokadd") {
			sql.append(Constants.STOCK_COUNT);
			sql.append(id);
			sql1 = sql.toString();
		}
		if (tablename == "tb_Follw") {
			sql.append(Constants.FOLLOW_COUNT);
			sql.append(id);
			sql1 = sql.toString();
		}
		if (tablename == "tb_Call") {
			sql.append(Constants.CALL_COUNT);
			sql.append(id);
			sql1 = sql.toString();
		}
		if (tablename == "tb_Need") {
			sql.append(Constants.NEED_COUNT);
			sql.append(id);
			sql1 = sql.toString();
		}
		Statement stmt = null;
		ResultSet rs = null;
		Connection con = null;
		try {
			con = DbUtil.connectToDB();
		} catch (Exception e1) {
			e1.printStackTrace();
		}
		try {
			stmt = con.createStatement();
			rs = stmt.executeQuery(sql1);
			if (rs.next()) {
				 this.settatolrows((rs.getInt(1)));
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			try {
				if (rs != null)
					rs.close();
				if (stmt != null) {
					stmt.close();
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	// 得到总页数
	public void getTotalpage(String tablename,String id) {
		GetSTotalrows(tablename,id);

		if (this.tatolrows % this.pagerows == 0) {
			this.tatolpage = this.tatolrows / pagerows;
		} else {
			this.tatolpage = tatolrows / pagerows + 1;
		}
	}

	// 得到sql语句
	public String getSQL(int number, String tablename, String selectname) {
		getTotalpage(tablename,selectname);
		StringBuffer buffer = new StringBuffer();
		buffer.append(Constants.FENYE1);
		buffer.append(this.tatolrows - (number - 1) * this.pagerows);
		if (tablename == "tb_client"
				&& (selectname == null || selectname == "")) {
			buffer.append(Constants.SELECT_CLIENT);
		}

		if (tablename == "tb_client"
				&& (selectname != null && selectname != "")) {
			buffer.append(Constants.SELECT1_CLIENT);
			buffer.append(selectname);
			buffer.append(Constants.SELECT2_CLIENT);
			buffer.append(selectname);
			buffer.append(Constants.COMMON1);
		}
		int selectid = 0;
		if (tablename != "tb_client" && (selectname != null && selectname != ""))
			selectid = Integer.parseInt(selectname);
		if (tablename == "tb_Stcokadd") {
			buffer.append(Constants.SELECT_Stcokadd);
			buffer.append(selectid);
			buffer.append(Constants.SELECT_STCOKADD1);
			buffer.append(selectid);
			buffer.append(Constants.COMMON);
		}
		if (tablename == "tb_Follw") {
			buffer.append(Constants.SELECT_Follw);
			buffer.append(selectid);
			buffer.append(Constants.SELECT_Follw1);
			buffer.append(selectid);
			buffer.append(Constants.COMMON);
		}
		if (tablename == "tb_Call") {
			buffer.append(Constants.SELECT_Call);
			buffer.append(selectid);
			buffer.append(Constants.SELECT_Call1);
			buffer.append(selectid);
			buffer.append(Constants.COMMON);
		}
		if (tablename == "tb_Need") {
			buffer.append(Constants.SELECT_Need);
			buffer.append(selectid);
			buffer.append(Constants.SELECT_Need1);
			buffer.append(selectid);
			buffer.append(Constants.COMMON);
		}
		return buffer.toString();
	}

	// 获得每页的信息
	public void GetAllInfo(String num, String tablename, String selectname) {
		Statement stmt = null;
		ResultSet rs = null;
		int number = Integer.parseInt(num);
		String sql = getSQL(number, tablename, selectname);
		ArrayList list1 = new ArrayList();

		Connection con = null;
		try {
			con = DbUtil.connectToDB();
		} catch (Exception e1) {
			e1.printStackTrace();
		}
		try {
			stmt = con.createStatement();
			rs = stmt.executeQuery(sql);

			while (rs.next()) {

			}
			this.setList(list1);
			this.setpagenumber(number);
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			try {
				if (rs != null)
					rs.close();
				if (stmt != null) {
					stmt.close();
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	public int getTatolpage() {
		return tatolpage;
	}

	public void setTatolpage(int tatolpage) {
		this.tatolpage = tatolpage;
	}

	public int getTatolrows() {
		return tatolrows;
	}

	public void setTatolrows(int tatolrows) {
		this.tatolrows = tatolrows;
	}
}