[Feat]: Add a demo of SpringJDBC

oceanbase · May 17, 2024 · 29ac6fc · 29ac6fc
1 parent 64197f6
commit 29ac6fc
Show file tree

Hide file tree

Showing 6 changed files with 419 additions and 0 deletions.
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -37,6 +37,9 @@ jobs:
           - name: 'mybatis-plus'
             language: 'java'
             with_oceanbase_container: false
+          - name: 'spring-jdbc'
+            language: 'java'
+            with_oceanbase_container: false
     uses: ./.github/workflows/basic-ci.yml
     with:
       module: ${{ matrix.module.name }}

diff --git a/java/spring-jdbc/README-CN.md b/java/spring-jdbc/README-CN.md
@@ -0,0 +1,133 @@
+# SpringJDBC 连接 OceanBase 指南
+[English](README.md) | 简体中文
+
+本文介绍如何通过 SpringJDBC 连接 OceanBase 数据库。
+由于 OceanBase 支持 MySQL 模式与 Oracle 模式，因此可以使用 MySQL 驱动连接 OceanBase。
+### 快速开始
+1. 在 pom.xml 中首先加入 MySQL 驱动，pom.xml 参考[OceanBase Spring JDBC 连接示例](https://www.oceanbase.com/docs/community-observer-cn-10000000000900916) 示例。
+
+```xml
+    <dependency>
+      <groupId>org.springframework</groupId>
+      <artifactId>spring-jdbc</artifactId>
+      <version>5.0.9.RELEASE</version>
+    </dependency>
+    <dependency>
+      <groupId>mysql</groupId>
+      <artifactId>mysql-connector-java</artifactId>
+      <version>8.0.25</version>
+    </dependency>
+    <dependency>
+      <groupId>com.alibaba</groupId>
+      <artifactId>druid</artifactId>
+      <version>1.2.18</version>
+    </dependency>
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <version>4.13.2</version>
+      <scope>test</scope>
+    </dependency>
+```
+2.新建测试类，使用 Druid 连接池实例化 JdbcTemplate。
+
+```java
+public class OceanBaseSpringJdbcApplicationTest {
+  private static JdbcTemplate jdbcTemplate;
+  private String sql;
+
+  static {
+    Map<String, String> map = new HashMap<String, String>();
+    map.put("url", "jdbc:mysql://localhost:2881/test");
+    map.put("driverClassName", "com.mysql.cj.jdbc.Driver");
+    map.put("username", "root@test");
+    map.put("password", "");
+    try {
+      Class.forName(map.get("driverClassName"));
+      jdbcTemplate = new JdbcTemplate(DruidDataSourceFactory.createDataSource(map));
+      //防止异常语句,没有这两句，会出错(Prevent abnormal statements, without which errors will occur)
+      jdbcTemplate.execute("set transaction_isolation = 'READ-COMMITTED';"); // MySQL 8.0 之后，系统变量 tx_isolation 被更改为 transaction_isolation (After MySQL 8.0, the system variable tx_isolation was changed to transaction_isolation)
+      // jdbcTemplate.execute("set tx_isolation = 'READ-COMMITTED';"); // MySQL 8.0 之前的版本使用 tx_isolation (tx_isolation is used in versions before MySQL 8.0)
+    } catch (Exception e) {
+      e.printStackTrace();
+    }
+  }
+}
+```
+3.编写测试方法，执行 SQL 语句。
+
+```java
+// MySQL Type Create Table
+@Test
+public void createByMySQLTypeDate(){
+  // MySQL Create Table
+  sql ="CREATE TABLE D_DPRECORD(DEV_ID VARCHAR(50),"+
+    "CAR_SPEED INT(3),"+
+    "CAP_DATE TIMESTAMP," +
+    "DEV_CHNID VARCHAR(50) not null," +
+    "TRSFMARK INT(1) DEFAULT 0," +
+    "CREATE_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP" +
+    ");";
+  jdbcTemplate.execute(sql);
+}
+
+// Oracle Type Create
+@Test
+public void createByOrcTypeDate(){
+  // Oracle Create Table
+  sql ="CREATE TABLE D_DPRECORD(DEV_ID VARCHAR2(50),"+
+    "CAR_SPEED NUMBER(3),"+
+    "CAP_DATE TIMESTAMP WITH LOCAL TIME ZONE," +
+    "DEV_CHNID VARCHAR2(50) NOT NULL," +
+    "TRSFMARK NUMBER(1) DEFAULT 0," +
+    "CREATE_TIME DATE DEFAULT sysdate" +
+    ");";
+
+  jdbcTemplate.execute(sql);
+}
+
+// MySQL/Oracle Type Add Test Data
+@Test
+public void addTest(){
+  int i = 1;
+  for (;i<=100;i++){
+    sql = "INSERT INTO D_DPRECORD VALUES " +
+      "('DEV_ID"+i+"',"+i+",'2021-01-01 00:00:00','DEV_CHNID"+i+"',"+i+",'2021-01-01 00:00:00');";
+    jdbcTemplate.execute(sql);
+  }
+}
+
+// MySQL/Oracle Type Query Test Data
+@Test
+public void queryTest(){
+  sql = "SELECT * FROM D_DPRECORD;";
+  jdbcTemplate.queryForList(sql).forEach(System.out::println);
+}
+
+// MySQL/Oracle Type Update Test Data
+@Test
+public void updateTest(){
+  sql = "UPDATE D_DPRECORD SET CAR_SPEED = 100 WHERE DEV_ID = 'DEV_ID1';";
+  jdbcTemplate.execute(sql);
+}
+
+// MySQL/Oracle Type Delete Test Data
+@Test
+public void deleteTest(){
+  sql = "DELETE FROM D_DPRECORD WHERE DEV_ID = 'DEV_ID1';";
+  jdbcTemplate.execute(sql);
+}
+
+// MySQL/Oracle Type Drop Table
+@Test
+public void dropTable(){
+  sql = "DROP TABLE D_DPRECORD;";
+  jdbcTemplate.execute(sql);
+}
+```
+
+修改代码中的连接信息，之后你就可以直接使用 run.sh 运行示例代码。
+
+  ```bash
+  sh run.sh
+  ```
diff --git a/java/spring-jdbc/README.md b/java/spring-jdbc/README.md
@@ -0,0 +1,137 @@
+# Guide Connecting SpringJDBC to OceanBase
+English | [简体中文](README-CN.md)
+
+This document introduces how to connect to the OceanBase database through SpringJDBC.
+Since OceanBase supports MySQL mode and Oracle mode, you can use the MySQL driver to connect to OceanBase.
+
+## Quick Start
+
+1. add the MySQL driver dependency to the pom.xml file, referring to the [OceanBase Spring JDBC connection example](https://www.oceanbase.com/docs/community-observer-cn-10000000000900916).
+
+```xml
+    <dependency>
+      <groupId>org.springframework</groupId>
+      <artifactId>spring-jdbc</artifactId>
+      <version>5.0.9.RELEASE</version>
+    </dependency>
+    <dependency>
+      <groupId>mysql</groupId>
+      <artifactId>mysql-connector-java</artifactId>
+      <version>8.0.25</version>
+    </dependency>
+    <dependency>
+      <groupId>com.alibaba</groupId>
+      <artifactId>druid</artifactId>
+      <version>1.2.18</version>
+    </dependency>
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <version>4.13.2</version>
+      <scope>test</scope>
+    </dependency>
+```
+
+2. Create a new test class and instantiate JdbcTemplate using the Druid connection pool.
+
+```java
+public class OceanBaseSpringJdbcApplicationTest {
+  private static JdbcTemplate jdbcTemplate;
+  private String sql;
+
+  static {
+    Map<String, String> map = new HashMap<String, String>();
+    map.put("url", "jdbc:mysql://localhost:2881/test");
+    map.put("driverClassName", "com.mysql.cj.jdbc.Driver");
+    map.put("username", "root@test");
+    map.put("password", "");
+    try {
+      Class.forName(map.get("driverClassName"));
+      jdbcTemplate = new JdbcTemplate(DruidDataSourceFactory.createDataSource(map));
+      //防止异常语句,没有这两句，会出错(Prevent abnormal statements, without which errors will occur)
+      jdbcTemplate.execute("set transaction_isolation = 'READ-COMMITTED';"); // MySQL 8.0 之后，系统变量 tx_isolation 被更改为 transaction_isolation (After MySQL 8.0, the system variable tx_isolation was changed to transaction_isolation)
+      // jdbcTemplate.execute("set tx_isolation = 'READ-COMMITTED';"); // MySQL 8.0 之前的版本使用 tx_isolation (tx_isolation is used in versions before MySQL 8.0)
+    } catch (Exception e) {
+      e.printStackTrace();
+    }
+  }
+}
+```
+
+3. Write any tests method to execute the SQL statement.
+
+```java
+// MySQL Type Create Table
+@Test
+public void createByMySQLTypeDate(){
+  // MySQL Create Table
+  sql ="CREATE TABLE D_DPRECORD(DEV_ID VARCHAR(50),"+
+    "CAR_SPEED INT(3),"+
+    "CAP_DATE TIMESTAMP," +
+    "DEV_CHNID VARCHAR(50) not null," +
+    "TRSFMARK INT(1) DEFAULT 0," +
+    "CREATE_TIME TIMESTAMP DEFAULT CURRENT_TIMESTAMP" +
+    ");";
+  jdbcTemplate.execute(sql);
+}
+
+// Oracle Type Create
+@Test
+public void createByOrcTypeDate(){
+  // Oracle Create Table
+  sql ="CREATE TABLE D_DPRECORD(DEV_ID VARCHAR2(50),"+
+    "CAR_SPEED NUMBER(3),"+
+    "CAP_DATE TIMESTAMP WITH LOCAL TIME ZONE," +
+    "DEV_CHNID VARCHAR2(50) NOT NULL," +
+    "TRSFMARK NUMBER(1) DEFAULT 0," +
+    "CREATE_TIME DATE DEFAULT sysdate" +
+    ");";
+
+  jdbcTemplate.execute(sql);
+}
+
+// MySQL/Oracle Type Add Test Data
+@Test
+public void addTest(){
+  int i = 1;
+  for (;i<=100;i++){
+    sql = "INSERT INTO D_DPRECORD VALUES " +
+      "('DEV_ID"+i+"',"+i+",'2021-01-01 00:00:00','DEV_CHNID"+i+"',"+i+",'2021-01-01 00:00:00');";
+    jdbcTemplate.execute(sql);
+  }
+}
+
+// MySQL/Oracle Type Query Test Data
+@Test
+public void queryTest(){
+  sql = "SELECT * FROM D_DPRECORD;";
+  jdbcTemplate.queryForList(sql).forEach(System.out::println);
+}
+
+// MySQL/Oracle Type Update Test Data
+@Test
+public void updateTest(){
+  sql = "UPDATE D_DPRECORD SET CAR_SPEED = 100 WHERE DEV_ID = 'DEV_ID1';";
+  jdbcTemplate.execute(sql);
+}
+
+// MySQL/Oracle Type Delete Test Data
+@Test
+public void deleteTest(){
+  sql = "DELETE FROM D_DPRECORD WHERE DEV_ID = 'DEV_ID1';";
+  jdbcTemplate.execute(sql);
+}
+
+// MySQL/Oracle Type Drop Table
+@Test
+public void dropTable(){
+  sql = "DROP TABLE D_DPRECORD;";
+  jdbcTemplate.execute(sql);
+}
+```
+
+Modify the connection info in code, and use `run.sh` to run the example code.
+
+```bash
+sh run.sh
+```
diff --git a/java/spring-jdbc/pom.xml b/java/spring-jdbc/pom.xml
@@ -0,0 +1,40 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <groupId>com.oceanbase.samples</groupId>
+  <artifactId>spring-jdbc</artifactId>
+  <version>1.0-SNAPSHOT</version>
+
+  <name>oceanbase-spring-jdbc</name>
+
+  <properties>
+    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    <maven.compiler.source>1.8</maven.compiler.source>
+    <maven.compiler.target>1.8</maven.compiler.target>
+  </properties>
+
+  <dependencies>
+    <dependency>
+      <groupId>org.springframework</groupId>
+      <artifactId>spring-jdbc</artifactId>
+      <version>5.0.9.RELEASE</version>
+    </dependency>
+    <dependency>
+      <groupId>mysql</groupId>
+      <artifactId>mysql-connector-java</artifactId>
+      <version>8.0.25</version>
+    </dependency>
+    <dependency>
+      <groupId>com.alibaba</groupId>
+      <artifactId>druid</artifactId>
+      <version>1.2.18</version>
+    </dependency>
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <version>4.13.2</version>
+      <scope>test</scope>
+    </dependency>
+  </dependencies>
+</project>
diff --git a/java/spring-jdbc/run.sh b/java/spring-jdbc/run.sh
@@ -0,0 +1,2 @@
+#!/usr/bin/env bash
+mvn test -Dtest=com.oceanbase.samples.OceanBaseSpringJdbcApplicationTest exec:java -Dexec.cleanupDaemonThreads=false -Dexec.mainClass=com.oceanbase.samples.OceanBaseSpringJdbcApplicationTest
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		#!/usr/bin/env bash
		mvn test -Dtest=com.oceanbase.samples.OceanBaseSpringJdbcApplicationTest exec:java -Dexec.cleanupDaemonThreads=false -Dexec.mainClass=com.oceanbase.samples.OceanBaseSpringJdbcApplicationTest