IDEA实现Oracle毗连以及基本的增删改查操作步骤详解

1. 导入数据库对应jdbc驱动

去Oracle官网下载数据库毗连驱动，下载地址：https://www.oracle.com/database/technologies/appdev/jdbc-downloads.html
各人根据java版本选择对应的版本驱动。

或者在Oracle安装目录下自带有个jdbc文件夹，点进lib，里面有各版本的jdbc包

2. 导入JAR包

打开项目结构

点击模块，选择依靠，点+导入Jar包后应用

在外部库能检索到jar包阐明导入成功

测试可否毗连数据库

3.JDBC介绍

3.1 常用接口

1）Driver 接口
Driver 接口由数据库厂家提供，只需要使用 Driver 接口就可以了。在编程中要毗连数据库，必须先装载特定厂商的数据库驱动程序，差别的数据库有差别的装载方法。如：

1. 装载 MySql 驱动：Class.forName("com.mysql.jdbc.Driver");
2. 装载 Oracle 驱动：Class.forName("oracle.jdbc.driver.OracleDriver");

复制代码

2）Connection 接口
Connection 与特定命据库的毗连（会话），在毗连上下文中实行 sql 语句并返回结果。DriverManager.getConnection(url, user, password)方法创建在 JDBC URL 中定义的数据库 Connection 毗连上。

1. 连接 MySql 数据库：
2. Connection conn =
3. DriverManager.getConnection("jdbc:mysql://host:port/database", "user",
4. "password");
5. 连接 Oracle 数据库：
6. Connection conn =DriverManager.getConnection("jdbc:oracle:thin:@host:port:database", "user",
7. "password");
8. 连接 SqlServer 数据库：
9. Connection conn = DriverManager.getConnection("jdbc:microsoft:sqlserver://host:port;
10. DatabaseName=database", "user", "password");

复制代码

常用方法：
• createStatement()：创建向数据库发送 sql 的 statement 对象。
• prepareStatement(sql) ：创建向数据库发送预编译 sql 的 PrepareSatement 对象。
• prepareCall(sql)：创建实行存储过程的 callableStatement 对象。
• setAutoCommit(boolean autoCommit)：设置事务是否主动提交。
留意：
prepareStatement会先初始化SQL，先把这个SQL提交到数据库中举行预处理，多次使用可进步效率。
createStatement不会初始化，没有预处理，每次都是从0开始实行SQL。
prepareStatement支持批量处理，createStatement只实行一次。
PreparedStatement 有效的防止 sql 注入(SQL 语句在程序运行前已经举行了预编译, 当运行时动态地把参数传给 PreprareStatement 时，纵然参数里有敏感字符如 or '1=1’也数据库会作为一个参数一个字段的属性值来处理而不会作为一个 SQL 指令
3）Statement 接口
用于实行静态 SQL 语句并返回它所天生结果的对象。
两种 Statement 类：
• Statement：由 createStatement 创建，用于发送简单的 SQL 语句（不带参数）。
• PreparedStatement ：继承自 Statement 接口，由 preparedStatement 创建，用于发送含有一个或多个参数的 SQL 语句。PreparedStatement 对象比Statement 对象的效率更高，并且可以防止 SQL 注入，所以我们一样平常都使用PreparedStatement。
常用 Statement 方法：
• execute(String sql):运行语句，返回是否有结果集
• executeQuery(String sql)：运行 select 语句，返回 ResultSet 结果集。
• executeUpdate(String sql)：运行 insert/update/delete 操作，返回更新的行数。
• addBatch(String sql) ：把多条 sql 语句放到一个批处理中。
• executeBatch()：向数据库发送一批 sql 语句实行。
4）ResultSet 接口
ResultSet 提供检索差别类型字段的方法，常用的有：
• getString(int index)、getString(String columnName)：获得在数据库里是varchar、char 等类型的数据对象。
• getFloat(int index)、getFloat(String columnName)：获得在数据库里是 Float类型的数据对象。
• getDate(int index)、getDate(String columnName)：获得在数据库里是 Date 类型的数据。
• getBoolean(int index)、getBoolean(String columnName)：获得在数据库里是Boolean 类型的数据。
• getObject(int index)、getObject(String columnName)：获取在数据库里任意类型的数据。
ResultSet 还提供了对结果集举行滚动的方法：
• next()：移动到下一行
• Previous()：移动到前一行
• absolute(int row)：移动到指定行
• beforeFirst()：移动 resultSet 的最前面。
• afterLast() ：移动到 resultSet 的最后面。
使用后依次关闭对象及毗连：ResultSet → Statement → Connection
4. 编写代码毗连Oracle数据库

创建文件夹用作数据访问层Dao，可在BaseDao实现初始化数据库毗连和毗连关闭的操作

JDBC使用步骤：

加载 JDBC 驱动程序 → 创建数据库毗连 Connection → 创建实行 SQL 的语句
Statement → 处理实行结果 ResultSet → 释放资源

1. package cn.test_oracle.dao;
2. /*基本数据访问类（获取数据库连接）*/
4. import org.junit.platform.commons.function.Try;
6. import java.sql.*;
9. public class BaseDao {
10.     static {
11.         //加载驱动
12.         try {
13.             Class.forName("oracle.jdbc.driver.OracleDriver");
14.         } catch (ClassNotFoundException e) {
15.             throw new RuntimeException(e);
16.         }
17.     }
18.     //获取数据库连接
19.     public static Connection getConnection() throws SQLException {
20.         Connection conn = null;
21.         try {
22.             conn =  DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:orcl","system","123456" );
23.         } catch (SQLException e) {
24.             throw new RuntimeException(e);
25.         }
26.         if (conn != null) {
27.             System.out.println("连接成功");
28.         }else {
29.             System.out.println("连接失败");
30.         }
31.         return conn;
32.     }
34.     public static void CloseAll(Connection conn, Statement stmt, ResultSet rs) {
35.         try {
36.             if (rs != null) {
37.                 rs.close();
38.             }
39.         } catch (SQLException e) {
40.             e.printStackTrace();
41.         }
42.         try {
43.             if (stmt != null) {
44.                 stmt.close();
45.             }
46.         } catch (SQLException e) {
47.             e.printStackTrace();
48.         }
49.         try {
50.             if (conn != null) {
51.                 conn.close();
52.             }
53.         } catch (SQLException e) {
54.             e.printStackTrace();
55.         }
56.     }
57. }

复制代码

数据库表字段类型计划如下

创建实体类，并实现get，set方法

1. package cn.test_oracle.entity;
3. import java.util.Date;
5. //用户表
6. public class Owners {
7.     private Long userId; //用户id
8.     private String userName;
9.     private String userPwd;
10.     private Long age;
11.     private String gender;
12.     private String email;
13.     private Date regTime;
15.     public Long getUserId() {
16.         return userId;
17.     }
19.     public void setUserId(Long userId) {
20.         this.userId = userId;
21.     }
23.     public String getUserName() {
24.         return userName;
25.     }
27.     public void setUserName(String userName) {
28.         this.userName = userName;
29.     }
31.     public String getUserPwd() {
32.         return userPwd;
33.     }
35.     public void setUserPwd(String userPwd) {
36.         this.userPwd = userPwd;
37.     }
39.     public Long getAge() {
40.         return age;
41.     }
43.     public void setAge(Long age) {
44.         this.age = age;
45.     }
47.     public String getGender() {
48.         return gender;
49.     }
51.     public void setGender(String gender) {
52.         this.gender = gender;
53.     }
55.     public String getEmail() {
56.         return email;
57.     }
59.     public void setEmail(String email) {
60.         this.email = email;
61.     }
63.     public Date getRegTime() {
64.         return regTime;
65.     }
67.     public void setRegTime(Date regTime) {
68.         this.regTime = regTime;
69.     }
70. }

复制代码

在OwnersDao实现对数据库的增删改查操作
增加用户代码如下

1.     //增加用户
2.     public static void Add(Owners owners) {
3.         Connection conn = null;
4.         //创建执行对象
5.         PreparedStatement stmt = null;
6.         try {
7.             conn = BaseDao.getConnection();
8.             //SQL语句
9.             stmt = conn.prepareStatement("insert into PJ.tb_user values (?,?,?,?,?,?,?)");
10.             //设置占位符
11.             stmt.setLong(1, owners.getUserId());
12.             stmt.setString(2, owners.getUserName());
13.             stmt.setString(3, owners.getUserPwd());
14.             stmt.setLong(4, owners.getAge());
15.             stmt.setString(5, owners.getGender());
16.             stmt.setString(6, owners.getEmail());
17.             //这里需求的是sql.date，但java提供的是util.date，可以通过java的getTime方法将util.date变成long型，再转换成Date型
18.             stmt.setDate(7, new Date(owners.getRegTime().getTime()));
19.             stmt.execute();
22.         } catch (SQLException e) {
23.             throw new RuntimeException(e);
24.         } finally {
25.             BaseDao.CloseAll(conn, stmt, null);
26.         }
27.     }

复制代码

修改用户代码如下

1.     //修改用户
2.     public static void Update(Owners owners) {
3.         Connection conn = null;
4.         //创建执行对象
5.         PreparedStatement stmt = null;
6.         try {
7.             conn = BaseDao.getConnection();
8.             //SQL语句
9.             stmt = conn.prepareStatement("update PJ.tb_user set username=?, userpwd=?, " +
10.                     "age = ?, gender = ?, email = ?, regtime = ? where  userid = ?");
11.             //设置占位符
13.             stmt.setString(1, owners.getUserName());
14.             stmt.setString(2, owners.getUserPwd());
15.             stmt.setLong(3, owners.getAge());
16.             stmt.setString(4, owners.getGender());
17.             stmt.setString(5, owners.getEmail());
18.             //这里需求的是sql.date，但java提供的是util.date，可以通过java的getTime方法将util.date变成long型，再转换成Date型
19.             stmt.setDate(6, new Date(owners.getRegTime().getTime()));
20.             stmt.setLong(7, owners.getUserId());
21.             stmt.execute();
24.         } catch (SQLException e) {
25.             throw new RuntimeException(e);
26.         } finally {
27.             BaseDao.CloseAll(conn, stmt, null);
28.         }
29.     }

复制代码

删除用户代码如下

1.     //删除用户
2.     public static void Delete(Long id) {
3.         Connection conn = null;
4.         //创建执行对象
5.         PreparedStatement stmt = null;
6.         try {
7.             conn = BaseDao.getConnection();
8.             //SQL语句
9.             stmt = conn.prepareStatement("delete from PJ.tb_user where userid = ?");
10.             //设置占位符
11.             stmt.setLong(1, id);
12.             stmt.execute();
13.         } catch (SQLException e) {
14.             throw new RuntimeException(e);
15.         } finally {
16.             BaseDao.CloseAll(conn, stmt, null);
17.         }
18.     }

复制代码

查询代码如下

1.     //查询用户
2.     public static ArrayList<Owners> Query(Long id) {
3.         ArrayList<Owners> list = new ArrayList<>();
4.         Connection conn = null;
5.         //创建执行对象
6.         PreparedStatement stmt = null;
7.         ResultSet rs = null;
8.         try {
9.             conn = BaseDao.getConnection();
10.             //SQL语句
11.             stmt = conn.prepareStatement("select * FROM PJ.tb_user where  userid = ?");
12.             //设置占位符
13.             stmt.setLong(1, id);
14.             //处理执行结果
15.             rs = stmt.executeQuery();
16.             while (rs.next()){
17.                 Owners s = new Owners();
18.                 s.setUserId(rs.getLong("userid"));
19.                 s.setUserName(rs.getString("username"));
20.                 s.setUserPwd(rs.getString("userpwd"));
21.                 s.setAge(rs.getLong("age"));
22.                 s.setGender(rs.getString("gender"));
23.                 s.setEmail(rs.getString("email"));
24.                 s.setRegTime(rs.getDate("regtime"));
25.                 list.add(s);
26.             }
27.             return list;
29.         } catch (SQLException e) {
30.             throw new RuntimeException(e);
31.         } finally {
32.             BaseDao.CloseAll(conn, stmt, rs);
33.         }
34.     }

复制代码

看上述代码可否实现对数据库的交互，测试代码如下：

1. package cn.test_oracle.test;
3. import cn.test_oracle.dao.OwnersDao;
4. import cn.test_oracle.entity.Owners;
6. import java.text.DateFormat;
7. import java.text.ParseException;
8. import java.text.SimpleDateFormat;
9. import java.util.ArrayList;
10. import java.util.Date;
13. public class testdao {
14.     public static void main(String[] args) throws ParseException {
15.         Owners owners = new Owners();
16.         owners.setUserId(2L);
17.         owners.setUserName("clearlove7");
18.         owners.setUserPwd("123456");
19.         owners.setAge(39L);
20.         owners.setGender("男");
21.         owners.setEmail("pnj@3422.com");
22.         //将String转换成Date两者处理方式，方式1
23. /*        DateFormat fmt = new SimpleDateFormat("yyyy-MM-dd");
24.         Date date = fmt.parse("2021-01-30");*/
25.         //将String转换为Date，方式2
26.         Date date = java.sql.Date.valueOf("2023-02-12");
27.         owners.setRegTime(date);
29.         OwnersDao.Add(owners);//增加用户
30.         OwnersDao.Update(owners);//修改用户信息
31.         OwnersDao.Delete(2L);//删除用户信息
32.         ArrayList<Owners> a = OwnersDao.Query(1L);//查询用户信息
34.         for (int i = 0; i < a.size(); i++) {
35.             Owners owner1 = a.get(i);
36.             System.out.println(owner1.getUserId());
37.             System.out.println(owner1.getUserName());
38.             System.out.println(owner1.getUserPwd());
39.             System.out.println(owner1.getGender());
40.             System.out.println(owner1.getAge());
41.             System.out.println(owner1.getEmail());
42.             System.out.println(owner1.getRegTime());
43.         }
44.     }
45. }

复制代码

结果如下，用户2成功添加进数据库。

查询结果：

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。