使用JDBC连接Oracle数据库

引入依赖：

<dependency>
    <groupId>com.oracle.database.jdbc</groupId>
    <artifactId>ojdbc6</artifactId>
    <version>11.2.0.4</version>
</dependency>

package com.easyUtils.core.lang;
import com.easyUtils.common.DayInfo;
import javax.swing.*;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.ResultSetMetaData;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
public class JDBC {
    private String user;
    private String pass;
    private String url;
    private Connection conn = null;//连接对象
    private ResultSet rs = null;//结果集对象  
    private Statement sm = null;
    /**
     * 构造函数获得数据库用户名和密码
     *
     * @param user
     * @param pass
     */
    public JDBC(String user, String pass) {
        this.user = user;
        this.pass = pass;
        this.url = "jdbc:oracle:thin:@10.100.12.33:1521:orcl19c";
    }
    /**
     * 连接数据库
     *
     * @return
     */
    public Connection createConnection() {
        String sDBDriver = "oracle.jdbc.driver.OracleDriver";
        try {
            Class.forName(sDBDriver).newInstance();
            conn = DriverManager.getConnection(url, user, pass);
        } catch (Exception e) {
            System.out.println("数据库连接失败");
            e.printStackTrace();
        }
        return conn;
    }
    /**
     * 关闭数据库
     *
     * @param conn
     */
    public void closeConnection(Connection conn) {
        try {
            if (conn != null) {
                conn.close();
            }
        } catch (Exception e) {
            System.out.println("数据库关闭失败");
            e.printStackTrace();
        }
    }
    /**
     * 插入数据
     *
     * @param insert 插入语句
     * @return
     */
    public int insert(String insert) {
        conn = createConnection();
        //String insert = "insert into t_department values('D004','金融部')";  
        int re = 0;
        try {
            conn.setAutoCommit(false);//事物开始  
            sm = conn.createStatement();
            re = sm.executeUpdate(insert);
            if (re < 0) {               //插入失败
                conn.rollback();      //回滚  
                sm.close();
                closeConnection(conn);
                return re;
            }
            conn.commit();            //插入正常
            System.out.println("插入成功");
            sm.close();
            closeConnection(conn);
            return re;
        } catch (Exception e) {
            e.printStackTrace();
        }
        closeConnection(conn);
        return 0;
    }
    /**
     * 查询语句
     * 返回结果集
     *
     * @param select
     * @return
     */
    public ResultSet selectSql(String select) {
        conn = createConnection();
        try {
            sm = conn.createStatement();
            rs = sm.executeQuery(select);
            return rs;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }
    /**
     * 根据结果集输出
     *
     * @param rs
     */
    public void printRs(ResultSet rs) {
        int columnsCount = 0;
        boolean f = false;
        try {
            if (!rs.next()) {
                return;
            }
            ResultSetMetaData rsmd = rs.getMetaData();
            columnsCount = rsmd.getColumnCount();//数据集的列数  
            for (int i = 0; i < columnsCount; i++) {
                System.out.print(rsmd.getColumnLabel(i + 1) + "/n"); //输出列名
            }
            System.out.println();
            while (!f) {
                for (int i = 1; i <= columnsCount; i++) {
                    //System.out.print(rs.getString(i)+"/t");
                    //逻辑处理
                    String name = rs.getString("NAME");
                    System.out.print(rs.getString("NAME") + "/n");
                }
                System.out.println();
                if (!rs.next()) {
                    f = true;
                }
            }
            rs.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
        closeConnection(conn);
    }
    public static void main(String[] args) {
        //解析excle 文件
        JDBC jDBC = new JDBC("BGDOMS_HRFS_TEST", "spd#8899@2022");
        String insert = "insert into HRFS_PROJECT values('D005','外交部')";
        System.out.println(jDBC.insert(insert));//插入成功
        String select = "select * from HRFS_PROJECT";
        jDBC.printRs(jDBC.selectSql(select));
        System.out.println("结束");
    }
}