clientserverdaoimpl.java

一个oa系统

package com.oa.crm.db;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

public class ClientServerDAOImpl extends HibernateDaoSupport implements
		ClientServerDAO {

	public void addCleintServer(ClientServer clientServer) {
		// TODO 自动生成方法存根
		Connection conn = getHibernateTemplate().getSessionFactory().openSession().connection();
		CallableStatement cstm = null;
		try {
			cstm = conn.prepareCall("{call add_client_server(?,?,?,?,?,?,?)}");
			cstm.setString(1, clientServer.getServerMode());
			cstm.setString(2, clientServer.getClientId());
			cstm.setString(3, clientServer.getClientName());
			cstm.setString(4, clientServer.getServerContent());
			cstm.setString(5, clientServer.getFkInfo());
			cstm.setString(6, clientServer.getEmpId());
			cstm.setString(7, clientServer.getServerTime());
			cstm.executeUpdate();

		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		} finally {
			try {
				if (cstm != null) {
					cstm.close();
				}
				if (conn != null) {
					conn.close();
				}
			} catch (Exception e) {
				// TODO: handle exception
			}
		}
	}

	public int getTotalRecord(String clientId) {
		// TODO 自动生成方法存根
		int count = 0;
		List list = getHibernateTemplate().find("select count(*) from ClientServer where client_id =?",clientId);
		count = Integer.parseInt(list.get(0).toString());
		return count;
	}

	public ArrayList<ClientServer> showAllClientServerByClientId(String clientId) {
		// TODO 自动生成方法存根
		ArrayList<ClientServer> list = (ArrayList<ClientServer>) getHibernateTemplate().find("from ClientServer where client_id =?", clientId);
		return list;
	}

	public ArrayList<ClientServer> showMenberClientServerByClientId(int start,
			int count, String clientId) {
		// TODO 自动生成方法存根
		ArrayList<ClientServer> clientServerList = new ArrayList<ClientServer>();
		String str = "select *from client_server where client_id ='" + clientId + "' limit " + start + ",3";
		Connection conn = getHibernateTemplate().getSessionFactory().openSession().connection();
		PreparedStatement pstmt = null;
		ResultSet rst = null;
		try {
			pstmt = conn.prepareStatement(str);
			rst = pstmt.executeQuery();
			while (rst.next()) {
				ClientServer clientServer = new ClientServer();
				clientServer.setServerId(rst.getString("server_id"));
				clientServer.setServerMode(rst.getString("server_mode"));
				clientServer.setServerTime(rst.getString("server_time"));
				clientServer.setServerContent(rst.getString("server_content"));
				clientServer.setFkInfo(rst.getString("fk_info"));
				clientServer.setCreateData(rst.getString("create_data"));
				clientServer.setClientId(rst.getString("client_id"));
				clientServer.setClientName(rst.getString("client_name"));
				clientServerList.add(clientServer);
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch
			e.printStackTrace();
		} finally {
			try {
				if (rst != null) {
					rst.close();
				}
				if (pstmt != null) {
					pstmt.close();
				}
				if (conn != null) {
					conn.close();
				}
			} catch (Exception e) {
				// TODO: handle exception
			}
		}
		return clientServerList;
	}

	public ClientServer showOneClientServer(String serverId) {
		// TODO 自动生成方法存根
		return (ClientServer) getHibernateTemplate().find("from ClientServer where server_id=?", serverId).get(0);
	}

}