datebase.java

来自「个人办公平台,用JAVA开发的TOMCAT的服务器」· Java 代码 · 共 123 行

package conn.skyhawk.control_2;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.Statement;

import java.sql.DriverManager;

import java.sql.SQLException;

public class DateBase {
	
	private Connection conn=null;
	
	private Statement sea=null;
	
	private ResultSet rs=null;	
	
	public Connection getConnection()//数据库的连接
	{
		try {
			Class.forName("oracle.jdbc.driver.OracleDriver");
			
			try {
				conn=DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:oracle","system","dxjrplcmd");
						
			} catch (SQLException e1) {
				
				e1.printStackTrace();
			}
		} catch (ClassNotFoundException e) {
		
			e.printStackTrace();
		}
		System.out.println(conn);	
		
		return conn;
	}
	
	public ResultSet getSet(String u)//添加
	{
		DateBase b=new DateBase();
		
		Connection c=b.getConnection();
		
		try {
			sea=c.createStatement();
			
			rs=sea.executeQuery(u);
			
		} catch (SQLException e) {
		
			e.printStackTrace();
		}
		
		return rs;		
	}
	
	public void setInsert(String u){
		DateBase b=new DateBase();
		Connection c=b.getConnection();
		try {
			sea=c.createStatement();
			sea.executeUpdate(u);
			//sea.
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}
	
public static void CloseObject(ResultSet rs,Statement sta,Connection conn){
	
	CloseObject(rs);
	CloseObject(sta,conn);
	}
public static void CloseObject(Statement sta,Connection conn){
        CloseObject(sta);
        CloseObject(conn);

}
	
	public static void CloseObject(ResultSet rs){
		if(rs!=null){
			try {
				rs.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	
}
public static void CloseObject(Statement sta){
	
	if(sta!=null){
		try {
			sta.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}
public static void CloseObject(Connection conn){
	if(conn!=null){
		try {
			conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}
	public static void main(String[] args) {
		DateBase d=new DateBase();
		//d.getConnection("");
	}
}