SMBMS.rar

package cn.smbms.dao;

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;

/**
 * 操作数据库的基类--静态类
 * @author Administrator
 *
 */
public class baseDao {
	
	static{//静态代码块在类加载的时候执行
		init（）;
	}
	
	private static String driver;
	private static String url;
	private static String user;
	private static String password;
	
	//初始化连接参数从配置文件里获得
	public static void init（）{
		Properties params=new Properties（）;
		String configFile = “database.properties“;
		InputStream is=baseDao.class.getClassLoader（）.getResourceAsStream（configFile）;
		try {
			params.load（is）;
		} catch （IOException e） {
			e.printStackTrace（）;
		}
		driver=params.getProperty（“driver“）;
		url=params.getProperty（“url“）;
		user=params.getProperty（“user“）;
		password=params.getProperty（“password“）;

	}   
	
	
	/**
	 * 获取数据库连接
	 * @return
	 */
	public static Connection getConnection（）{
		Connection connection = null;
		try {
			Class.forName（driver）;
			connection = DriverManager.getConnection（url user password）;
		} catch （Exception e） {
			// TODO Auto-generated catch block
			e.printStackTrace（）;
		}
		
		return connection;
	}
	/**
	 * 查询操作
	 * @param connection
	 * @param pstm
	 * @param rs
	 * @param sql
	 * @param params
	 * @return
	 */
	public static ResultSet execute（Connection connectionPreparedStatement pstmResultSet rs
			String sqlobject[] params） throws Exception{
		pstm = connection.prepareStatement（sql）;
		for（int i = 0; i < params.length; i++）{
			pstm.setobject（i+1 params[i]）;
		}
		rs = pstm.executeQuery（）;
		return rs;
	}
	/**
	 * 更新操作
	 * @param connection
	 * @param pstm
	 * @param sql
	 * @param params
	 * @return
	 * @throws Exception
	 */
	public static int execute（Connection connectionPreparedStatement pstm
			String sqlobject[] params） throws Exception{
		int updateRows = 0;
		pstm = connection.prepareStatement（sql）;
		for（int i = 0; i < params.length; i++）{
			pstm.setobject（i+1 params[i]）;
		}
		updateRows = pstm.executeUpdate（）;
		return updateRows;
	}
	
	/**
	 * 释放资源
	 * @param connection
	 * @param pstm
	 * @param rs
	 * @return
	 */
	public static boolean closeResource（Connection connectionPreparedStatement pstmResultSet rs）{
		boolean flag = true;
		if（rs != null）{
			try {
				rs.close（）;
				rs = null;//GC回收
			} catch （SQLException e） {
				// TODO Auto-generated catch block
				e.printStackTrace（）;
				flag = false;
			}
		}
		if（pstm != null）{
			try {
				pstm.close（）;
				pstm = null;//GC回收
			} catch （SQLException e） {
				// TODO Auto-generated catch block
				e.printStackTrace（）;
				flag = false;
			}
		}
		if（connection != null）{
			try {
				connection.close（）;
				connection = null;//GC回收
			} catch （SQLException e） {