引入依赖:
<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("结束");
- }
- }
联系客服