This topic describes how to use the JFinal framework and OceanBase Cloud to build an application for basic database operations, such as table creation, data insertion, and data query.
Download the java-oceanbase-Jfinal sample project Prerequisites
- You have registered an OceanBase Cloud account, and created a cluster instance and an Oracle-compatible tenant in OceanBase Cloud. For more information, see Create a cluster instance and Create a tenant.
- You have obtained the connection string of the Oracle-compatible tenant. For more information, see Obtain the connection string.
- You have installed Java Development Kit (JDK) 1.8 and Maven.
- You have installed IntelliJ IDEA.
Note
This topic uses IntelliJ IDEA Community Edition 2021.3.2 to run the sample code. You can also choose a suitable tool as needed.
Procedure
Note
The following procedure applies to Windows. If you use another operating system or compiler, the procedure can be slightly different.
Step 1: Import the java-oceanbase-Jfinal project to IntelliJ IDEA
Start IntelliJ IDEA and choose File > Open....

In the Open File or Project window, select the project files and click OK to import the files.
IntelliJ IDEA automatically identifies various files in the project. You can view project information such as the directory structure, file list, module list, and dependencies in the Project window. Generally, the Project window is at the leftmost of the UI of IntelliJ IDEA and is opened by default. If the Project window is closed, you can choose View > Tool Windows > Project in the menu bar or press Alt + 1 to open it.
Note
When you use IntelliJ IDEA to import a project, IntelliJ IDEA automatically detects the `pom.xml` file in the project, downloads the required dependency libraries based on the dependencies described in the file, and adds them to the project.
View the project.

Step 2: Build the Tomcat runtime environment for the java-oceanbase-Jfinal project
Download Tomcat 8.5.95.
Download the package of Tomcat 8.5.95 from the official website of Apache Tomcat. Decompress the package to the directory where you want to install Tomcat.
Configure Tomcat in IntelliJ IDEA.
Start IntelliJ IDEA and choose File > Settings. In the Settings window, click Plugins in the left-side navigation pane. In the Plugins pane, search for Smart Tomcat in the search box and install it. Then, click Apply in the lower-right corner. Tomcat Server appears at the bottom of the left-side navigation pane of the Settings window. Click Tomcat Server and then click the plus sign (+) in the right-side pane that appears. Select the directory where Tomcat is decompressed, click Apply, and then click OK.

Create a Tomcat runtime configuration.
In the top navigation bar of IntelliJ IDEA, choose Run > Edit Configurations. In the Run/Debug Configurations window, click the plus sign (+) and select Tomcat Server. Enter the server name in the Name field. On the Configuration tab, select the installed version from the Tomcat sever drop-down list, change the value of Context path to
/, and set SSL port to8080. In the Before launch section, click the plus sign (+) and choose Launch Web Browser. Click Edit and enterhttp://localhost:8080/hello/getDatain the URL field. Click Apply and then click OK.
Run the Tomcat server.
In the top navigation bar of IntelliJ IDEA, select the Tomcat runtime configuration you just created. Click the Run button (a green triangle) to start the Tomcat server. You can view the startup logs of the Tomcat server in the Run window of IntelliJ IDEA.
Step 3: Modify the database connection information in the java-oceanbase-Jfinal project
Modify the database connection information in the config.properties file based on the obtained connection string mentioned in the "Prerequisites" section.
Here is an example:
db.app.driver=com.oceanbase.jdbc.Driver
db.app.url=jdbc:oceanbase://t5******.********.oceanbase.cloud:3306/sys
db.app.user=test_user
db.app.password=******
db.app.poolInitialSize=3
db.app.poolMaxSize=10
db.app.connectionTimeoutMillis=100
db.app.validationQuery=select 1 from dual
- The name of the database driver is
com.oceanbase.jdbc.Driver. - The endpoint is
t5******.********.oceanbase.cloud. - The access port is
3306. - The name of the database to be accessed is
sys. - The tenant account is
test_user. - The password is
******.
Step 4: Run the java-oceanbase-Jfinal project
Specify the run path.
In the top navigation bar of IntelliJ IDEA, select the Tomcat runtime configuration you just created. Click the Run button (a green triangle) to start the Tomcat server. Enter the URL
http://localhost:8080/hello/getDatain Google Chrome or Internet Explorer to view the running result.View the running result.
[{"ID":1,"NAME":" John"},{"ID":2,"NAME":" Jane"}]
Project code
Click here to download the project code, which is a package named java-oceanbase-Jfinal.
Decompress the package to obtain a folder named java-oceanbase-Jfinal. The directory structure is as follows:
│--pom.xml
│
├─.idea
│
├─src
│ ├─main
│ │ ├─java
│ │ │ └─com
│ │ │ └─oceanbase
│ │ │ └─testjfinal
│ │ │ ├─config
│ │ │ │ └─UserConfig.java
│ │ │ │
│ │ │ ├─controller
│ │ │ │ └─UserController.java
│ │ │ │
│ │ │ └─pojo
│ │ │ └─User.java
│ │ │
│ │ ├─resources
│ │ │ └─config.properties
│ │ │
│ │ └─webapp
│ │ └─WEB-INF
│ │ └─web.xml
│ │
│ │
│ │
│ └─test
│ └─java
│
│
└─target
The files and directories are described as follows:
pom.xml: the configuration file of the Maven project, which contains the dependencies, plug-ins, and build rules of the project..idea: a directory used in an Integrated Development Environment (IDE) to store configuration information related to the project.src: a directory that stores the source code in the project.main: a directory that stores the main source code and resource files.java: a directory that stores the Java source code.com: the root directory of the Java package.oceanbase: the root directory of the project.testjfinal: a directory that stores code of the JFinal framework.config: a directory that stores the configuration files, including those of the application.UserConfig.java: the user configuration file.controller: the controller directory that stores the controller file of the application.UserController.java: the controller file.pojo: a directory that stores JavaBean or entity classes.User.java: a file that stores user entity classes.resources: a directory that stores resource files, such as configuration files and SQL files.config.properties: the configuration file that stores database connection information.webapp: a directory that stores the static resources and configuration file of the web application.WEB-INF: a directory that stores the configuration file and other protected resource files of the web application.web.xml: the deployment descriptor file of the web application.test: a directory that stores the test code and resource files.target: a directory that stores compiled class files and .jar packages.
Code in pom.xml
Note
You can retain the default code in this file for verification purposes or modify the code in the file as needed.
Perform the following steps to configure the pom.xml file:
Declare the file.
Declare the file to be an XML file that uses XML standard 1.0 and the character encoding UTF-8.
The sample code is as follows:
<?xml version="1.0" encoding="UTF-8"?>Configure namespaces and the POM model version.
xmlns: the default XML namespace for the POM, which is set tohttp://maven.apache.org/POM/4.0.0.xmlns:xsi: the XML namespace for XML elements prefixed withxsi, which is set tohttp://www.w3.org/2001/XMLSchema-instance.xsi:schemaLocation: the location of an XML schema definition (XSD) file. The value consists of two parts: the default XML namespace(http://maven.apache.org/POM/4.0.0)and the URI of the XSD file (http://maven.apache.org/xsd/maven-4.0.0.xsd).<modelVersion>: the POM model version used by the POM file, which is set to4.0.0.
The sample code is as follows:
<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> </project>Configure basic information.
<groupId>: the ID of the project group, which is set tocom.oceanbase.<artifactId>: the name of the project, which is set tojava-oceanbase-jfinal.<version>: the version of the project, which is set to1.0-SNAPSHOT.<packaging>: the packaging mode of the project, which is set toWAR. In this mode, archive files of the web application are packaged in the WAR format.
The sample code is as follows:
<groupId>com.oceanbase</groupId> <artifactId>java-oceanbase-jfinal</artifactId> <version>1.0-SNAPSHOT</version> <!-- Packaging method (default to jar) --> <packaging>war</packaging>Configure the Maven version.
Set the source code version and target code version of the compiler to Java 8 by using
<maven.compiler.source>and<maven.compiler.target>, respectively.The sample code is as follows:
<properties> <maven.compiler.source>8</maven.compiler.source> <maven.compiler.target>8</maven.compiler.target> </properties>Configure core dependencies.
Define a dependency named
jfinalthat belongs to thecom.jfinalgroup and whose version is5.0.6. With this dependency, you can use features of the JFinal framework.The sample code is as follows:
<dependency> <groupId>com.jfinal</groupId> <artifactId>jfinal</artifactId> <version>5.0.6</version> </dependency>Define a dependency named
druidthat belongs to thecom.alibabagroup and whose version is1.2.8. With this dependency, you can use the Druid library to manage and optimize the acquisition and release of database connections.The sample code is as follows:
<dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> <version>1.2.8</version> </dependency>Define a dependency named
oceanbase-clientthat belongs to thecom.oceanbasegroup and whose version is2.4.3. With this dependency, you can use the features of OBClient, such as connections, queries, and transactions.The sample code is as follows:
<dependencies> <dependency> <groupId>com.oceanbase</groupId> <artifactId>oceanbase-client</artifactId> <version>2.4.3</version> </dependency> </dependencies>
Code in config.properties
The config.properties file stores the connection information of OceanBase Cloud, including the class name of the database driver and the URL, username, password, and connection pool configurations. You can use the following parameters to establish and manage database connections for database operations in the application:
db.app.driver: the database driver used to establish a connection with OceanBase Cloud, which is set tocom.oceanbase.jdbc.Driver.db.app.url: the URL for connecting to the database.db.app.user: the username for connecting to the database.db.app.password: the password for connecting to the database.db.app.poolInitialSize: the initial size of the database connection pool, which is set to3, indicating that three database connections are initially created.db.app.poolMaxSize: the maximum number of database connections allowed for the connection pool, which is set to10, indicating that you can create a maximum of 10 database connections in a connection pool.db.app.connectionTimeoutMillis: the timeout period for obtaining a database connection, which is set to100 ms, indicating that if a connection cannot be obtained within 100 ms, a timeout exception is thrown.db.app.validationQuery: the SQL query statement for verifying database connections, which is set toselect 1 from dual. When you request a connection from the connection pool, this query statement is executed to verify the connection.The sample code is as follows:
db.app.driver=com.oceanbase.jdbc.Driver db.app.url=jdbc:oceanbase://host:port/schema_name db.app.user=user_name db.app.password=****** db.app.poolInitialSize=3 db.app.poolMaxSize=10 db.app.connectionTimeoutMillis=100 db.app.validationQuery=select 1 from dual
Code in web.xml
The web.xml file configures a filter for the web application.
Perform the following steps to configure the web.xml file:
Declare the file.
Declare the file to be an XML file that uses XML standard 1.0 and the character encoding UTF-8.
The sample code is as follows:
<?xml version="1.0" encoding="UTF-8"?>Configure the XML namespace and the XML model version.
xmlns:xsi: the XML namespace for XML elements prefixed withxsi, which is set tohttp://www.w3.org/2001/XMLSchema-instance.xmlns: the default XML namespace for the POM, which is set tohttp://java.sun.com/xml/ns/javaee.xsi:schemaLocation: a mapping from the default XML namespace (http://java.sun.com/xml/ns/javaee) to the location of the XML schema definition (XSD) file (http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd).<id>and<version>: the ID and version of the web application, which are respectively set toWebApp_IDand3.0.
The sample code is as follows:
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" id="WebApp_ID" version="3.0">Configure a JFinal filter.
Configure a filter named
jfinal. With this filter, you can use the JFinal framework in the web application. Set the class of the filter tocom.jfinal.core.JFinalFilter. Use the initialization parameterconfigClassto specifycom.oceanbase.testjfinal.config.UserConfigas the location of the configuration class for the JFinal framework. This filter allows the web application to use the JFinal framework and defines the behavior of the JFinal framework based on the specified configuration class.The sample code is as follows:
<filter> <filter-name>jfinal</filter-name> <filter-class>com.jfinal.core.JFinalFilter</filter-class> <init-param> <param-name>configClass</param-name> <!-- your jfinal configuration location --> <param-value>com.oceanbase.testjfinal.config.UserConfig</param-value> </init-param> </filter>Configure mappings of the JFinal filter.
Apply the JFinal filter named
jfinalto all request paths, namely, to all requests in the application.The sample code is as follows:
<filter-mapping> <filter-name>jfinal</filter-name> <url-pattern>/*</url-pattern> </filter-mapping>
Code in UserConfig.java
The UserConfig.java file configures the routing, plug-in, and database connection information of the application.
Perform the following steps to configure the UserConfig.java file:
Reference other classes and APIs.
Declare this file to contain the following APIs and classes:
StatFilterclass: collects statistics about the database access performance.JdbcConstantsclass: defines database type constants.WallFilterclass: prevents SQL injection attacks.PropKitclass: reads configuration files.ActiveRecordPluginclass: operates the database.Dbclass: executes database operations.OracleDialectclass: specifies a dialect of the database.DruidPluginclass: connects to the database.Engineclass: configures the template engine.UserControllerclass: processes user requests.Userclass: transmits and stores user data.
The sample code is as follows:
import com.alibaba.druid.filter.stat.StatFilter; import com.alibaba.druid.util.JdbcConstants; import com.alibaba.druid.wall.WallFilter; import com.jfinal.config.*; import com.jfinal.kit.PropKit; import com.jfinal.plugin.activerecord.ActiveRecordPlugin; import com.jfinal.plugin.activerecord.Db; import com.jfinal.plugin.activerecord.dialect.OracleDialect; import com.jfinal.plugin.druid.DruidPlugin; import com.jfinal.template.Engine; import com.oceanbase.testjfinal.controller.UserController; import com.oceanbase.testjfinal.pojo.User;Define the
UserConfigclass.Rewrite the methods in the
JFinalConfigclass to configure constant, routing, plug-in, and database connection information.Define the
configConstantmethod.Use this method to configure constants of the JFinal framework and use
PropKitto read configurations from the configuration file.The sample code is as follows:
@Override public void configConstant(Constants constants) { PropKit.use("config.properties"); }Define the
configRoutemethod.Use this method to configure route mappings. Call the
routes.addmethod to map the "/hello" path to the default access page of theUserControllerclass.The sample code is as follows:
@Override public void configRoute(Routes routes) { routes.add("/hello", UserController.class, "/"); }Define the
configEnginemethod.Use this method to configure the template engine.
The sample code is as follows:
@Override public void configEngine(Engine engine) { }Define the
configPluginmethod.Use this method to configure plug-ins of the application. Call the
initmethod to initialize the database connection and schema. Create theDruidPluginandActiveRecordPluginplug-ins and add them toplugins. Call theaddMappingmethod ofactiveRecordPluginto map theUserentity class to theTEST_USERdatabase table.The sample code is as follows:
@Override public void configPlugin(Plugins plugins) { init(); DruidPlugin druidPlugin = createDruidPlugin(); plugins.add(druidPlugin); ActiveRecordPlugin activeRecordPlugin = createActiveRecordPlugin(druidPlugin); activeRecordPlugin.addMapping("TEST_USER", User.class); plugins.add(activeRecordPlugin); }Define the
createDruidPluginmethod.This method creates a
DruidPluginplug-in and configures related parameters, including the connection pool size, SQL firewall, and connection error handling.Call the
getmethod ofPropKitto obtain database connection attributes from the configuration file, including the URL, username, password, and driver class. Then, create aDruidPluginobject and use the obtained attribute values to initialize the object. Call theaddFiltermethod to add aStatFilterinstance toDruidPluginfor collecting access performance statistics of the database. Create aWallFilterinstance, call thesetDbTypemethod to set the database type to OceanBase Cloud, and then add the instance toDruidPluginfor SQL firewall-based filtering. Call thesetInitialSizemethod to set the initial size of the connection pool, thesetMaxPoolPreparedStatementPerConnectionSizemethod to set the maximum number of prepared statements allowed in each connection pool, thesetTimeBetweenConnectErrorMillismethod to set the interval for a retry upon an error, and thesetValidationQuerymethod to set the query statement for verifying connections. Then, return the createdDruidPlugininstance.The sample code is as follows:
private DruidPlugin createDruidPlugin() { DruidPlugin druidPlugin = new DruidPlugin( PropKit.get("db.app.url"), PropKit.get("db.app.user"), PropKit.get("db.app.password"), PropKit.get("db.app.driver") ); druidPlugin.addFilter(new StatFilter()); WallFilter wallFilter = new WallFilter(); wallFilter.setDbType(JdbcConstants.OCEANBASE); druidPlugin.addFilter(wallFilter); druidPlugin.setInitialSize(PropKit.getInt("db.app.poolInitialSize")); druidPlugin.setMaxPoolPreparedStatementPerConnectionSize(PropKit.getInt("db.app.poolMaxSize")); druidPlugin.setTimeBetweenConnectErrorMillis(PropKit.getInt("db.app.connectionTimeoutMillis")); druidPlugin.setValidationQuery("select 1 from dual"); return druidPlugin; }
Define the
initmethod.Use this method to initialize database connections and create database tables. Call the
initDbConnectionmethod to initialize the database connection and return anActiveRecordPlugininstance. Execute an SQL statement to query whether the user tableTEST_USERexists. If the user table does not exist, execute theCREATE TABLEstatement to create a table namedTEST_USERthat contains theIDandNAMEfields. Close the connection of theActiveRecordPluginplug-in to release the database connection.The sample code is as follows:
public void init() { ActiveRecordPlugin arp = initDbConnection(); boolean tableExists = Db.queryInt("SELECT COUNT(*) FROM USER_TABLES WHERE TABLE_NAME = 'TEST_USER'") > 0; if (!tableExists) { String sql = "CREATE TABLE TEST_USER (ID NUMBER(10), NAME VARCHAR2(50))"; Db.update(sql); } arp.stop(); }Define the
initDbConnectionmethod.Use this method to initialize the database connection. First, call the
createDruidPluginmethod to create aDruidPluginobject and assign it to thedruidPluginvariable. This method is used to create and configureDruidPluginobjects for database connection pool management. Then, call thecreateActiveRecordPluginmethod to create anActiveRecordPluginobject and pass theDruidPluginobject as parameters to thecreateActiveRecordPluginmethod. This method is used to create and configureActiveRecordPluginobjects for database operation management. Call thedruidPlugin.startmethod to start theDruidPluginobject to initialize the database connection pool. Finally, call theactiveRecordPlugin.startmethod to start theActiveRecordPluginobject. This method initializes database operation settings based on configurations.The sample code is as follows:
private ActiveRecordPlugin initDbConnection() { DruidPlugin druidPlugin = createDruidPlugin(); ActiveRecordPlugin activeRecordPlugin = createActiveRecordPlugin(druidPlugin); druidPlugin.start(); activeRecordPlugin.start(); return activeRecordPlugin; }Define the
ConfigInterceptorandConfigHandlermethods.These methods are used for global configuration during system initialization.
The sample code is as follows:
@Override public void configInterceptor(Interceptors interceptors) { } @Override public void configHandler(Handlers handlers) { }
Code in UserController.java
The UserController.java file uses the getData method to insert data into the database, query data from the database, and return the query result to the client in the JavaScript Object Notation (JSON) format. The Db class provided by the JFinal framework is used to perform database operations, and the custom User class is used to map data, thereby implementing database operations and result returning.
Perform the following steps to configure the UserController.java file:
Reference other classes and APIs.
Declare this file to contain the following APIs and classes:
Controllerclass: processes requests and responses.Dbclass: executes database operations.Userclass: maps database tables.Listinterface: operates the query result set.
The sample code is as follows:
import com.jfinal.core.Controller; import com.jfinal.plugin.activerecord.Db; import com.oceanbase.testjfinal.pojo.User; import java.util.List;Define the
UserControllerclass.Use this class to provide a controller for the JFinal framework, and use the
getDatamethod to insert data into and query data from the database.- Insert data. Call the
Db.updatemethod to execute an SQL statement to insert two data records "1, John" and "2, Jane" into theTEST_USERtable. - Query data. Call the
User.dao.findmethod to execute an SQL statement to query all data from theTEST_USERtable. The query result is assigned to theusersvariable of theListtype. - Render data into the JSON format. Call the
renderJsonmethod to render the data stored in theusersobject into the JSON format and return it to the client. - Handle exceptions. Call the
catchstatement block to print the stack information of an exception that is thrown during the execution.
The sample code is as follows:
public class UserController extends Controller { public void getData(){ try { // Insert data. String insertDataSql = "INSERT INTO TEST_USER (ID, NAME) VALUES (?, ?) "; Db.update(insertDataSql, 1, "John"); Db.update(insertDataSql, 2, "Jane"); // Query data. List<User> users; users = User.dao.find("SELECT * FROM TEST_USER"); renderJson(users); }catch (Exception e){ e.printStackTrace(); } } }- Insert data. Call the
Code in User.java
The User.java file maps database tables and Java objects.
Perform the following steps to configure the User.java file:
Reference the
Modelclass.Use the
Modelclass to map database tables and operate data.Define the
Userclass.The
Userclass inherits the methods provided in theModelclass for database operations.The sample code is as follows:
import com.jfinal.plugin.activerecord.Model; public class User extends Model<User> { public static final User dao = new User(); }
Complete code
<?xml version="1.0" encoding="UTF-8"?>
<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</groupId>
<artifactId>java-oceanbase-jfinal</artifactId>
<version>1.0-SNAPSHOT</version>
<!-- Packaging method (default to jar) -->
<packaging>war</packaging>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
</properties>
<dependencies>
<dependency>
<groupId>com.jfinal</groupId>
<artifactId>jfinal</artifactId>
<version>5.0.6</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.2.8</version>
</dependency>
<dependency>
<groupId>com.oceanbase</groupId>
<artifactId>oceanbase-client</artifactId>
<version>2.4.3</version>
</dependency>
</dependencies>
</project>
db.app.driver=com.oceanbase.jdbc.Driver
db.app.url=jdbc:oceanbase://host:port/schema_name
db.app.user=user_name
db.app.password=
db.app.poolInitialSize=3
db.app.poolMaxSize=10
db.app.connectionTimeoutMillis=100
db.app.validationQuery=select 1 from dual
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" id="WebApp_ID" version="3.0">
<filter>
<filter-name>jfinal</filter-name>
<filter-class>com.jfinal.core.JFinalFilter</filter-class>
<init-param>
<param-name>configClass</param-name>
<!-- your jfinal configuration location -->
<param-value>com.oceanbase.testjfinal.config.UserConfig</param-value>
</init-param>
</filter>
<filter-mapping>
<filter-name>jfinal</filter-name>
<url-pattern>/*</url-pattern>
</filter-mapping>
</web-app>
package com.oceanbase.testjfinal.config;
import com.alibaba.druid.filter.stat.StatFilter;
import com.alibaba.druid.util.JdbcConstants;
import com.alibaba.druid.wall.WallFilter;
import com.jfinal.config.*;
import com.jfinal.kit.PropKit;
import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
import com.jfinal.plugin.activerecord.Db;
import com.jfinal.plugin.activerecord.dialect.OracleDialect;
import com.jfinal.plugin.druid.DruidPlugin;
import com.jfinal.template.Engine;
import com.oceanbase.testjfinal.controller.UserController;
import com.oceanbase.testjfinal.pojo.User;
public class UserConfig extends JFinalConfig {
@Override
public void configConstant(Constants constants) {
// Read the property configuration.
PropKit.use("config.properties");
}
@Override
public void configRoute(Routes routes) {
// Set the default access page for project startup, which does not need to be set in the web.
routes.add("/hello", UserController.class, "/");
}
@Override
public void configEngine(Engine engine) {
}
@Override
public void configPlugin(Plugins plugins) {
init();
DruidPlugin druidPlugin = createDruidPlugin();
plugins.add(druidPlugin);
ActiveRecordPlugin activeRecordPlugin = createActiveRecordPlugin(druidPlugin);
activeRecordPlugin.addMapping("TEST_USER", User.class);
plugins.add(activeRecordPlugin);
}
private DruidPlugin createDruidPlugin() {
DruidPlugin druidPlugin = new DruidPlugin(
PropKit.get("db.app.url"),
PropKit.get("db.app.user"),
PropKit.get("db.app.password"),
PropKit.get("db.app.driver")
);
druidPlugin.addFilter(new StatFilter());
WallFilter wallFilter = new WallFilter();
wallFilter.setDbType(JdbcConstants.OCEANBASE);
druidPlugin.addFilter(wallFilter);
druidPlugin.setInitialSize(PropKit.getInt("db.app.poolInitialSize"));
druidPlugin.setMaxPoolPreparedStatementPerConnectionSize(PropKit.getInt("db.app.poolMaxSize"));
druidPlugin.setTimeBetweenConnectErrorMillis(PropKit.getInt("db.app.connectionTimeoutMillis"));
druidPlugin.setValidationQuery("select 1 from dual");
return druidPlugin;
}
private ActiveRecordPlugin createActiveRecordPlugin(DruidPlugin druidPlugin) {
ActiveRecordPlugin activeRecordPlugin = new ActiveRecordPlugin(druidPlugin);
activeRecordPlugin.setDialect(new OracleDialect());
return activeRecordPlugin;
}
public void init() {
ActiveRecordPlugin arp = initDbConnection();
boolean tableExists = Db.queryInt("SELECT COUNT(*) FROM USER_TABLES WHERE TABLE_NAME = 'TEST_USER'") > 0;
if (!tableExists) {
String sql = "CREATE TABLE TEST_USER (ID NUMBER(10), NAME VARCHAR2(50))";
Db.update(sql);
}
arp.stop();
}
private ActiveRecordPlugin initDbConnection() {
DruidPlugin druidPlugin = createDruidPlugin();
ActiveRecordPlugin activeRecordPlugin = createActiveRecordPlugin(druidPlugin);
druidPlugin.start();
activeRecordPlugin.start();
return activeRecordPlugin;
}
@Override
public void configInterceptor(Interceptors interceptors) {
}
@Override
public void configHandler(Handlers handlers) {
}
}
package com.oceanbase.testjfinal.controller;
import com.jfinal.core.Controller;
import com.jfinal.plugin.activerecord.Db;
import com.oceanbase.testjfinal.pojo.User;
import java.util.List;
public class UserController extends Controller {
public void getData(){
try {
// Insert data.
String insertDataSql = "INSERT INTO TEST_USER (ID, NAME) VALUES (?, ?) ";
Db.update(insertDataSql, 1, "John");
Db.update(insertDataSql, 2, "Jane");
// Query data.
List<User> users;
users = User.dao.find("SELECT * FROM TEST_USER");
renderJson(users);
}catch (Exception e){
e.printStackTrace();
}
}
}
package com.oceanbase.testjfinal.pojo;
import com.jfinal.plugin.activerecord.Model;
public class User extends Model<User> {
public static final User dao = new User();
}
References
For more information about OceanBase Connector/J, see OceanBase Connector/J.