dbutils.java

来自「网上购物书店。包括购物车」· Java 代码 · 共 106 行

package com.cric.onlineshop.util;

import java.sql.*;

public class DBUtils {
	private String dbDriver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
	private String dbUrl = "jdbc:microsoft:sqlserver://localhost:1433;databaseName=onlineShop";
	private String userName = "sa";
	private String passWord = "sa";
	private java.sql.Connection conn = null;
	private java.sql.Statement stmt = null;
	private java.sql.ResultSet rs = null;

	public DBUtils() {
		try {
			Class.forName(dbDriver);
		} catch (java.lang.ClassNotFoundException e) {
			e.printStackTrace();
		}
	}

	public Connection getConnection() throws java.sql.SQLException {
		if (conn == null || conn.isClosed())
			this.conn = java.sql.DriverManager.getConnection(dbUrl, userName,
					passWord);
		return this.conn;
	}

	public ResultSet excuteQuery(String sqlStr) {
		if (sqlStr == null || sqlStr.equals("")) {
			return null;
		}
		try {
			this.getConnection();
			this.stmt = this.conn.createStatement();
			this.rs = this.stmt.executeQuery(sqlStr);
		} catch (java.sql.SQLException e) {
			e.printStackTrace();
		}

		return this.rs;
	}

	public boolean excuteUpdate(String sqlStr)
	{
		if(sqlStr==null||sqlStr.equals(""))
		{
			return false;
		}		
		try {
			this.getConnection();
			this.stmt = this.conn.createStatement();
			stmt.executeUpdate(sqlStr);
		} catch (java.sql.SQLException e) {
			e.printStackTrace();
			return false;
		}finally{
			try{
				if(this.stmt!=null)
				{
					this.stmt.close();
				}
			}catch(java.sql.SQLException e)
			{
				e.printStackTrace();
			}
			try{
				if(this.conn!=null)
				{
					this.conn.close();
				}
			}catch(java.sql.SQLException e)
			{
				e.printStackTrace();
			}	
		}		
		return true;		
	}
    
	public void closeStmt(){
		try{
			if(this.stmt!=null)
			{
				this.stmt.close();
			}
		}catch(java.sql.SQLException e)
		{
			e.printStackTrace();
		}
		
	}
	public void closeConnection()
	{
		try{
			if(this.conn!=null)
			{
				this.conn.close();
			}
		}catch(java.sql.SQLException e)
		{
			e.printStackTrace();
		}	
	}
	
}