package cn.xwkj.dao;
/**
 * ������ݿ���
 * @author 84661
 *
 */
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import java.util.Properties;

/**
 * BaseDao������ݿ�
 * @author 84661
 *
 */
public class BaseDao {
	//��
	private static String driver;
	//��ַ
	private static String url;
	//�û���
	private static String user;
	//����
	private static String pwd;
	//������ݿ�
	Connection conn = null;
	//ִ��SQL���
	PreparedStatement pstmt = null;
	//���ص�ֵ
	ResultSet rs = null;
	//��ȡ�����ļ�
	static{
		Properties pt = new Properties();
		//�ļ���λ��
		String path ="database.properties";
		//�ļ����Ķ�ȡ
		InputStream is = BaseDao.class.getClassLoader().getResourceAsStream(path);
		//����
		try {
			pt.load(is);
		} catch (IOException e) {
			e.printStackTrace();
		}
		//��ʼ��ȡ
		driver=pt.getProperty("driver");
		url=pt.getProperty("url");
		user=pt.getProperty("user");
		pwd=pt.getProperty("pwd");
		
	}

	/**
	 * ��ݿ�����
	 * @return
	 */
	public Connection getConnection(){
		
		try {
			//������
			Class.forName(driver);
			return DriverManager.getConnection(url,user,pwd);
		} catch (Exception e) {
			e.printStackTrace();
		}
		return conn;
		
	}
	/**
	 * �ر���ݿ�
	 */
	public void closeAll(){
		//�رն�ȡ
		if (rs!=null) {
			try {
				rs.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		//�ر�����
		if (pstmt!=null) {
			try {
				pstmt.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		//�ر���ݿ�
		if (conn!=null) {
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
	/**
	 * ��ѯ
	 * @param sql
	 * @param param
	 * @return
	 */
	public ResultSet executeQuery(String sql,Object...param){
		
		try {
			
			conn=getConnection();
			pstmt=conn.prepareStatement(sql);
			if (param!=null && param.length>0) {
				for (int i = 0; i < param.length; i++) {
					pstmt.setObject(i+1,param[i]);
				}
			}
			
			return pstmt.executeQuery();
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}
	/**
	 * ��ӣ�ɾ���޸�
	 * @param sql
	 * @param param
	 * @return
	 */
	public int executeUpdate(String sql,Object...param){
		
		try {
			//��ȡ����
			conn= getConnection();
			//��ȡִ�ж���
			pstmt = conn.prepareStatement(sql);
			//�������ֵ
			if (param!=null && param.length>0) {
				for (int i = 0; i < param.length; i++) {
					pstmt.setObject(i+1, param[i]);
				}
			}
			//����ֵ
			return pstmt.executeUpdate();
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			closeAll();
		}
		return -1;
		
	}
}