dbmanager.java

用mvc实现购物车,简单使用,欢迎大家来下载啊

package com.xaccp.db;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import org.apache.commons.dbcp.BasicDataSource;

import com.xaccp.fileRead.Env;

public class DBManager {
	private Connection con = null;
	
	private static BasicDataSource dataSource;
	
	static{
		String userName = Env.getInstance().getProperty("userName");
		String userPwd = Env.getInstance().getProperty("userPwd");
		String url = Env.getInstance().getProperty("url");
		String driverClass=Env.getInstance().getProperty("driverClass");
		int max = Integer.parseInt(Env.getInstance().getProperty("max"));
		int min = Integer.parseInt(Env.getInstance().getProperty("min"));
		
		dataSource = new BasicDataSource();
		dataSource.setUrl(url);
		dataSource.setPassword(userPwd);
		dataSource.setUsername(userName);
		dataSource.setDriverClassName(driverClass);
		dataSource.setMaxActive(max);
		dataSource.setMinIdle(min);
	}
	
	public void openDB(){
		try {
			con = dataSource.getConnection();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		if(con!=null){
			System.out.println("成功获得连接");
		}
	}
	public void closedDB() {
		try {
			if (con != null && !con.isClosed()) {
				con.close();
				con = null;
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}

	public int executeSQL(String sql) {
		try {
			return con.createStatement().executeUpdate(sql);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return -1;
	}

	public int executeSQL(String sql, Object[] obj) {
		PreparedStatement pstat;
		try {
			pstat = con.prepareStatement(sql);
			this.setParameter(pstat, obj);
			return pstat.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return -1;

	}

	public ResultSet executeQuery(String sql) {
		try {
			return con.createStatement().executeQuery(sql);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return null;
	}

	public ResultSet executeQuery(String sql, Object[] obj) {
		try {
			PreparedStatement pstat = con.prepareStatement(sql);
			this.setParameter(pstat, obj);
			return pstat.executeQuery();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return null;
	}

	private void setParameter(PreparedStatement pstat, Object[] obj) {
		for (int i = 0; i < obj.length; i++) {
			try {
				pstat.setObject(i + 1, obj[i]);
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

}