dataprocess.java

java oracle 示例 prefirst.rar

package cn.com.freeborders.dataconn;

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

public class DataProcess {
	public static Connection getConnection() {
		Connection conn;
		try {
			Class.forName("oracle.jdbc.driver.OracleDriver");
			String url = "jdbc:oracle:thin:@localhost:1521:db"; // orcl为数据库的SID
			conn = DriverManager.getConnection(url, "test", "test");
			//System.out.println("连接数据库成功。");
			return conn;
		} // 连接数据库
		catch (ClassNotFoundException e) { // 意外处理，驱动程序无法找到
			e.printStackTrace();
			System.out.println("无法找到数据库驱动程序");
			return null;
		} catch (SQLException e1) { // 意外处理，数据库操作失败
			e1.printStackTrace();
			System.out.println("数据库操作失败");
			return null;
		}

	}

	public static void closeConnection(Connection conn) {
		try {
			conn.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	// insert and delete
	public static void exeQuery(String sql) {
		try {
			Connection conn = getConnection();
			Statement stmt = conn.createStatement();
			//System.out.println("+++++++++++");
			stmt.executeUpdate(sql);
			conn.commit();
			stmt.close();
			closeConnection(conn);

		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	// get resultset
	public static ResultSet getResult(String sql, Connection conn) {
		ResultSet rs = null;
		try {
			Statement stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);
			conn.commit();
			//stmt.close();

		} catch (Exception e) {
			e.printStackTrace();
		}
		return rs;
	}
	public static void closeResult(ResultSet rs) {
		try {
			rs.getStatement().close();
			rs.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

}