dbopertion.java

个人网上银行系统设计该系统使用MySQL数据库。

package com.perwebbank;

//import java.io.FileInputStream;
//import java.io.FileNotFoundException;
//import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
//import java.util.Properties;

public class DBOpertion {
	//private static Properties props = null;

	//private static FileInputStream in = null;

	private static String drivers = "org.gjt.mm.mysql.Driver";

	private static String url = "jdbc:mysql://127.0.0.1:3306/perwebbank";

	private static String username = "root";

	private static String pass = null;

	private static Connection conn = null;

	private static Statement stmt = null;

	private static ResultSet rs = null;

	public static Connection getConnection() {
		/*try {
			in = new FileInputStream("/database.properties");

		} catch (FileNotFoundException e) {
			e.printStackTrace();
		}
		try {
			props.load(in);
		} catch (IOException e) {
			e.printStackTrace();
		}
		drivers = props.getProperty("jdbc.drivers");
		url = props.getProperty("jdbc.url");
		username = props.getProperty("jdbc.username");
		pass = props.getProperty("jdbc.pass");
		if (drivers != null) {
			try {
				Class.forName(drivers);
			} catch (ClassNotFoundException e1) {
				e1.printStackTrace();
			}
		}
		try {
			conn = DriverManager.getConnection(url, username, pass);
		} catch (SQLException e) {
			e.printStackTrace();
		}*/
		try {
			Class.forName(drivers);
		} catch (ClassNotFoundException e) {			
			e.printStackTrace();
		}
		try {
			conn = DriverManager.getConnection(url,username,pass);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return conn;
	}
	public static void getStatement(){
		Connection cn=DBOpertion.getConnection();
		try {
			stmt = cn.createStatement();
		} catch (SQLException e) {			
			e.printStackTrace();
		}
	}
	
	public static void excuteInsert(String sql){
		try {
			stmt.executeUpdate(sql);
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
	
	public static ResultSet executeQuery(String sql){
		try {
			 rs = stmt.executeQuery(sql);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return rs;
	}
	
	public static void exeuteUpdate(String sql){
		try {
			stmt.executeUpdate(sql);
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
	
	public static void executeDelete(String sql){
		try {
			stmt.executeUpdate(sql);
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
	
	public static void closeConnection(){
		try {
			conn.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
	
	public static void closeStatement(){
		try {
			stmt.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
	
	public static void closeResultSet(ResultSet rs){
		try {
			rs.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
}