dbresult.java

用于商品进销存管理的BS系统

package com.mingri.dbconn;

import java.sql.*;

public class DBResult {
	Connection con = null;
	ResultSet rs = null;

	public DBResult() {
		try {
			Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
		} catch (java.lang.ClassNotFoundException e) {
			System.err.println(e.getMessage());
		}
	}

	/**
	 * 用于获得执行SQL语句的ResultSet对象
	 */
	public ResultSet getResult(String sql) {
		try {
			con = DriverManager.getConnection("jdbc:odbc:db_shopping");
			Statement stmt = con.createStatement();
			rs = stmt.executeQuery(sql);
		} catch (Exception e) {
			System.err.println(e.getMessage());
		}
		return rs;
	}

	
	public int executeUpdate(String sql) {
		int result = 0;
		try{
			con = DriverManager.getConnection("jdbc:odbc:db_shopping");
			Statement stmt = con.createStatement();
			result = stmt.executeUpdate(sql);
		}
		catch(SQLException ex)
		{
			System.err.println(ex.getMessage());
		}
		
		return result;
	}
	/**
	 * 用于执行SQL语句没有返回值
	 */
	public void doExecute(String sql) {
		try {
			con = DriverManager.getConnection("jdbc:odbc:db_shopping");
			Statement stmt = con.createStatement();
			stmt.executeQuery(sql);
		} catch (Exception e) {
			System.err.println(e.getMessage());
		}
	}

	/**
	 * 用于获得执行SQL语句的PreparedStatement(预处理)对象
	 */
	public PreparedStatement getPreparedStatement(String sql) {
		try {
			PreparedStatement pstmt = con.prepareStatement(sql);
			return pstmt;
		} catch (Exception e) {
		}
		return null;
	}

	/**
	 * 关闭连接
	 */
	public void closeCon() {
		try {
			this.con.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}