[大数据]jdbc连接Oracle和MySQL的封装

记得在项目中加入jar包

JDBC 连接Oracle

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

public class main {
	Connection con=null;
	Statement sta = null;
	ResultSet res = null;
	
	//打开数据库连接
	public Connection openOrcl(){
		try {
			// 加载驱动
			Class.forName("oracle.jdbc.driver.OracleDriver");
			//注册驱动
			DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
			//连接数据库
			//orcl：数据库名字
			String url = "jdbc:oracle:thin:127.0.0.1:1521:orcl";
			String UserName = "system";
			String UserPass = "123456";
			con = DriverManager.getConnection(url, UserName, UserPass);
			
		} catch (Exception e) {}
		
		return con;
	}
	
	//增删改
	public int update(String sql)
	{
		int re=0;
		try {
			//创建执行对象
			 sta=con.createStatement();
			 re = sta.executeUpdate(sql);//返回影响的行数
			
		} catch (Exception e) {}
		return re;
	}

	//查询方法
	public ResultSet select(String sql){
		try {
			sta=con.createStatement();
			res = sta.executeQuery(sql);
		} catch (Exception e) {}
		return res;
	}
	//关闭数据库连接
	//高频词查询才需要关闭
	public void closeOrcl() {
		try{
			res.close();
			sta.close();
			con.close();
		}catch(Exception e){}
	}
}

JDBC连接MySQL

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

public class DataServer {
    Connection con=null;
    Statement sta = null;
    ResultSet res = null;

    DataServer() throws SQLException {
        this.openMysql();
    }
    //打开数据库连接
    public Connection openMysql() throws SQLException {
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");

        } catch (Exception e) {
            System.out.println("error");
        }
        //mysql为mysql数据库名字
        String url="jdbc:mysql://localhost:3306/cs";
        String name="root";
        String pass="123";
        con = DriverManager.getConnection(url,name, pass);

        return con;
    }

    //增删改
    public int update(String sql)
    {
        int re=0;
        try {
            //创建执行对象
            sta=con.createStatement();
            re = sta.executeUpdate(sql);//返回影响的行数

        } catch (Exception e) {}
        return re;
    }

    //查询方法
    public ResultSet select(String sql) throws SQLException {
        try {
            sta=con.createStatement();
            res = sta.executeQuery(sql);
        } catch (Exception e) {}
        return res;
    }
    //关闭数据库连接
    //高频词查询才需要关闭
    public void closeMysql() {
        try{
            res.close();
            sta.close();
            con.close();
        }catch(Exception e){}
    }
}