dbutil.java

仓库管理系统

package edu.scau.database;

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

public class DBUtil {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		DBUtil util = new DBUtil();
		util.getConn();

	}

	/**
	 * 
	 * @return connetion
	 */
	public Connection getConn() {
		Connection con = null;
		try {
			// //1。动态加载数据库启动程序
			Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
			// 2。获取数据库连接
			con = DriverManager.getConnection("jdbc:microsoft:sqlserver://127.0.0.1:1433;DatabaseName=train", "sa", "maoyijun");
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return con;
	}

	/**
	 * 
	 * @param sql
	 * @return
	 */
	public ResultSet getRSBySql(String sql) {
		Connection con = getConn();
		ResultSet rs = null;
		try {
			Statement sm = con.createStatement();
			rs = sm.executeQuery(sql);
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return rs;
	}

	/**
	 * 
	 * @param sm
	 */
	public void closeStatement(Statement sm) {
		if (sm != null) {
			try {
				sm.close();
			} catch (SQLException e1) {
				e1.printStackTrace();
			}
		}
	}

	/**
	 * 
	 * @param con
	 */
	public void closeConnection(Connection con) {
		if (con != null) {
			try {
				con.close();
			} catch (SQLException e1) {
				e1.printStackTrace();
			}
		}
	}
}