Spring JDBC 连接 seekdb 示例程序

本文将介绍如何使用 Spring JDBC 框架、MySQL Connector/J 和 seekdb 构建一个应用程序，实现基本的数据库操作，包括创建表、插入和查询数据等。

点击下载 spring-jdbc-mysql-client 示例工程

功能特性

支持基本的 CRUD 操作
提供事务管理
异常处理机制
连接池管理

适用场景

需要直接使用 SQL 语句的场景
对性能要求较高的场景
简单的数据库操作场景

前提条件

您已安装 seekdb。
您已安装 JDK 1.8 和 Maven。
您已安装 Eclipse。

信息
本文档运行代码使用的工具是 Eclipse IDE for Java Developers 2022-03 版本，您也可以根据个人喜好选择适合自己的工具运行的示例代码。

操作步骤

信息

本文中给出的操作步骤是在 Windows 环境下使用 Eclipse IDE for Java Developers 2022-03 编译和运行该项目的步骤。如果您使用的是其他操作系统环境或编译器，那么操作步骤可能会略有不同。

将 spring-jdbc-mysql-client 项目导入到 Eclipse 中。
获取 seekdb URL。
修改 spring-jdbc-mysql-client 项目中的数据库连接信息。
运行 spring-jdbc-mysql-client 项目。

步骤一：将 spring-jdbc-mysql-client 项目导入到 Eclipse 中

打开 Eclipse，在菜单栏上选择 File -> Open Projects from File System。
在弹出的对话框中，点击 Directory 按钮选择项目所在的目录，然后点击 Finish 完成导入。

信息
当使用 Eclipse 导入 Maven 项目时，Eclipse 会自动检测项目中的 pom.xml 文件，并根据文件中描述的依赖关系自动下载所需的依赖库，并将它们添加到项目中。
查看项目情况。

步骤二：获取 seekdb URL

联系 seekdb 部署人员或者管理员获取相应的数据库连接串。

示例如下：
```
mysql -hxxx.xxx.xxx.xxx -P2881 -uroot -p****** -Dtest
```
更多连接串的信息，请参见通过 MySQL 客户端连接 seekdb。
根据 seekdb 连接串信息填写下面 URL 的对应信息。
```
jdbc:mysql://$host:$port/$database_name?user=$user_name&password=$password&useSSL=false
```
参数说明：
- $host：提供 seekdb 的连接 IP。应该被实际的 IP 替换，也可以使用本地 IP 及 127.0.0.1。
- $port：提供 seekdb 接端口。应该被实际的端口替换，默认是 2881，在部署 seekdb 时可自定义。
- $database_name：需要访问的数据库名称。
- user_name：提供连接账户。格式：用户名 。
- password：提供账户密码。
更多有关 MySQL Connector/J 连接属性信息，请参见 Configuration Properties。

示例如下：
```
jdbc:mysql://xxx.xxx.xxx.xxx:2881/test?user=root&password=******&useSSL=false
```

步骤三：修改 spring-jdbc-mysql-client 项目中的数据库连接信息

根据 步骤二：获取 seekdb URL 中获取的信息修改文件 spring-jdbc-mysql-client/src/main/java/com/example/Main.java 中的数据库连接信息。

示例如下：

seekdb 的 IP 地址为 xxx.xxx.xxx.xxx。
访问端口使用的是 2881。
需要访问的数据库名称为 test。
连接账户是 root。
密码是 ******。

代码如下：

...
        String url = "jdbc:mysql://xxx.xxx.xxx.xxx:2881/test?useSSL=false";
        String username = "root";
        String password = "******";
...

步骤四：运行 spring-jdbc-mysql-client 项目

在项目导航器视图中，找到并展开 src/main/java 目录。
右键点击 Main.java 文件，然后选择 Run As -> Java Application。
在 Eclipse 的控制台窗口中来查看输出结果。

常见问题

1. 连接超时

如果遇到连接超时问题，可以在 JDBC URL 中配置连接超时参数：

jdbc:mysql://host:port/database?connectTimeout=30000&socketTimeout=60000

2. 字符集问题

为确保正确的字符编码，在 JDBC URL 中设置正确的字符集参数：

jdbc:mysql://host:port/database?characterEncoding=utf8&useUnicode=true

3. SSL 连接

要启用与 seekdb 的 SSL 连接，在 JDBC URL 中添加以下参数：

jdbc:mysql://host:port/database?useSSL=true&requireSSL=true

4. 账号密码中的特殊字符

如果用户名或密码包含特殊字符（如 #），需要进行 URL 编码：

String encodedPassword = URLEncoder.encode(password, "UTF-8");

信息

使用 MySQL Connector/J 8.x 时，确保账号密码不包含井号(#)。否则，可能会遇到连接错误。

项目代码介绍

点击 spring-jdbc-mysql-client 下载项目代码，是一个名称为 spring-jdbc-mysql-client.zip 的压缩包。

解压后，得到一个名为 spring-jdbc-mysql-client 的文件夹。目录结构如下所示：

spring-jdbc-mysql-client
├── src
│   └── main
│       └── java
│           └── com
│                └── example
│                   └── Main.java
└── pom.xml

文件说明：

src：源代码根目录。
main：主代码目录，包含应用程序的主要逻辑。
java：Java 源代码目录。
com：Java 包目录。
example：示例项目的包目录。
Main.java：主类，包含创建表和插入数据等逻辑。
pom.xml：Maven 项目的配置文件，用于管理项目的依赖和构建设置。

pom.xml 代码介绍

pom.xml 文件是 Maven 项目的配置文件，定义了项目的依赖项、插件和构建规则等信息。Maven 是一个 Java 项目管理工具，可以自动下载依赖项、编译和打包项目等操作。

本文 pom.xml 文件的代码主要包括以下几个部分：

文件声明语句。

声明本文件是一个 XML 文件，使用的 XML 版本是 1.0，字符编码方式是 UTF-8。

代码如下：
```
<?xml version="1.0" encoding="UTF-8"?>
```
配置 POM 的命名空间和 POM 模型版本。
1. 通过 xmlns 指定 POM 的命名空间为 http://maven.apache.org/POM/4.0.0。
2. 通过 xmlns:xsi 指定 XML 命名空间 http://www.w3.org/2001/XMLSchema-instance。
3. 通过 xsi:schemaLocation 指定 POM 的命名空间为 http://maven.apache.org/POM/4.0.0 和 POM 的 XSD 文件的位置为 http://maven.apache.org/xsd/maven-4.0.0.xsd。
4. 通过 <modelVersion> 元素指定了该 POM 文件使用的 POM 模型版本为 4.0.0。
代码如下：
```
<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>
```
配置基本信息。
1. 通过 <groupId> 指定项目所属组织为 com.example。
2. 通过 <artifactId> 指定项目的名称为 spring-jdbc-mysql-client。
3. 通过 <version> 项目的版本号为 1.0-SNAPSHOT。
代码如下：
```
    <groupId>com.example</groupId>
    <artifactId>spring-jdbc-mysql-client</artifactId>
    <version>1.0-SNAPSHOT</version>
```

配置项目源文件的属性。

指定 Maven 的编译器插件为 maven-compiler-plugin，并设置了源代码和目标 Java 版本都为 8。这意味着项目的源代码使用 Java 8 特性编写，且编译后的字节码也将兼容 Java 8 运行时环境。这样设置可以确保项目在编译和运行时能够正确地处理 Java 8 的语法和特性。

信息

Java 1.8 和 Java 8 是同一个版本的不同命名方式。

代码如下：

    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <configuration>
                    <source>8</source>
                    <target>8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>

配置项目所依赖组件。
1. 添加 mysql-connector-java 依赖库，用于与数据库进行交互：
  
  信息
  本部分代码定义项目所依赖组件是 MySQL Connector/J 的 V5.1.40 版本，如果需要了解其他版本的信息，请参见 MySQL Connector/J。
  1. 通过 <groupId> 指定依赖项所属的组织为 mysql。
  2. 通过 <artifactId> 指定依赖项的名称为 mysql-connector-java。
  3. 通过 <version> 指定依赖项的版本号为 5.1.40。
  代码如下：
```
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.40</version>
        </dependency>
```
2. 添加 spring-jdbc 依赖库：
  1. 通过 <groupId> 指定依赖项所属的组织为 org.springframework。
  2. 通过 <artifactId> 指定依赖项的名称为 spring-jdbc。
  3. 通过 <version> 指定依赖项的版本号为 5.2.0.RELEASE。
  代码如下：
```
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>5.2.0.RELEASE</version>
        </dependency>
```

Main.java 代码介绍

Main.java 文件是示例程序的一部分，代码演示了如何使用 Spring JDBC 框架执行数据库操作。它首先配置了数据库连接信息，然后创建了一个 JdbcTemplate 对象来执行数据库操作。代码中还包括了创建表、插入数据和查询数据的示例。

本文 Main.java 文件的代码主要包括以下几个部分：

定义包和导入必要的类。
1. 声明当前代码所属的包名为 com.example。
2. 导入 JdbcTemplate 类，它是 Spring JDBC 框架中的核心类，用于执行数据库操作。
3. 导入 DriverManagerDataSource 类，它是 Spring 提供的一个实现了 DataSource 接口的数据源类，用于配置数据库连接信息。
代码如下：
```
package com.example;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
```

创建一个 Main 类，并定义了 main 方法。

定义一个名为 Main 的公共类，作为程序的入口点。类名需要与文件名保持一致。
定义一个公共静态方法 main，作为程序的起始执行点。
其他数据库操作。

代码如下：

public class Main {
    public static void main(String[] args) {
        // 数据库连接信息
        // 创建数据源
        // 创建 JdbcTemplate 对象
        // 创建表
        // 插入数据
        // 更新数据
        // 删除数据
        // 查询数据
        // 删除表
    }
}

定义数据库连接信息。

定义用于连接数据库的 URL、用户名和密码。您需要将 $host、$port、$database_name、$user_name 和 $password 替换为实际的数据库连接信息。

代码如下：
```
        String url = "jdbc:mysql://$host:$port/$database_name?useSSL=false";
        String username = "$user_name";
        String password = "$password";
```
参数解释：
- $host：提供 seekdb 的连接 IP。使用实际的 IP 替换，也可以使用本地 IP 及 127.0.0.1。
- $port：提供 seekdb 接端口。使用实际的端口替换，默认是 2881，在部署 seekdb 时可自定义。
- $database_name：需要访问的数据库名称。
- $user_name：提供连接账户。格式：用户名 。
- $password：提供账户密码。
创建数据源。

创建一个 DriverManagerDataSource 对象，并配置了数据库连接的相关信息，包括驱动类名、数据库 URL、用户名和密码。具体步骤如下：
1. 创建一个 DriverManagerDataSource 对象，用于配置数据库连接的信息。
2. 设置驱动类名：通过调用 setDriverClassName 方法，设置数据库驱动类名为 com.mysql.jdbc.Driver。
3. 设置数据库 URL：通过调用 setUrl 方法，设置数据库的 URL。
4. 设置用户名：通过调用 setUsername 方法，设置数据库的用户名。
5. 设置密码：通过调用 setPassword 方法，设置数据库的密码。
代码如下：
```
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl(url);
        dataSource.setUsername(username);
        dataSource.setPassword(password);
```
创建 JdbcTemplate 对象。

创建一个 JdbcTemplate 对象，它是 Spring JDBC 框架的核心类之一。JdbcTemplate 提供了执行数据库操作的方法，如执行 SQL 语句、更新数据以及查询数据等。

代码如下：
```
        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
```
创建表。
1. 定义一个创建表的 SQL 语句，SQL 语句中指定表名为 test_springjdbc，并定义了两个列，一个是名为 id 的 INT 类型列，另一个是名为 name 的 VARCHAR(20) 类型列。
2. 执行创建表的 SQL 语句，jdbcTemplate 对象通过调用 execute 方法，执行了上述定义的创建表的 SQL 语句。
3. 在控制台输出一条成功创建表的消息。
代码如下：
```
        String createTableSql = "CREATE TABLE test_springjdbc (id INT, name VARCHAR(20))";
        jdbcTemplate.execute(createTableSql);
        System.out.println("Create table successfully.");
```
插入数据。
1. 定义插入数据的 SQL 语句，SQL 语句中指定了要插入的表为 test_springjdbc，列为 id 和 name，插入了两行数据，分别是 (1,'A1')、(2,'A2') 和 (3,'A3')。
2. 执行插入数据的 SQL 语句，jdbcTemplate 对象通过调用 update 方法，执行了上述定义的插入数据的 SQL 语句。
3. 在控制台输出一条成功插入数据的消息。
代码如下：
```
        String insertDataSql = "INSERT INTO test_springjdbc (id,name) VALUES (1,'A1'), (2,'A2'), (3,'A3')";
        jdbcTemplate.update(insertDataSql);
        System.out.println("Insert data successfully.");
```
更新数据。
1. 定义一个 SQL 语句，用于更新数据库表 test_springjdbc 中 id 为 1 的记录的 name 字段的值为 A11。
2. 通过 jdbcTemplate 对象执行 SQL 语句，将更新操作应用于数据库。
3. 在控制台输出一条成功更新数据的消息。
代码如下：
```
        String updateDataSql = "UPDATE test_springjdbc SET name = 'A11' WHERE id = 1";
        jdbcTemplate.update(updateDataSql);
        System.out.println("Update data successfully.");
```
删除数据。
1. 定义一个 SQL 语句，用于从数据库表 test_springjdbc 中删除 id 为 2 的记录。
2. 通过 jdbcTemplate 对象执行 SQL 语句，将删除操作应用于数据库。
3. 在控制台输出一条成功删除数据的消息。
代码如下：
```
        String deleteDataSql = "DELETE FROM test_springjdbc WHERE id = 2";
        jdbcTemplate.update(deleteDataSql);
        System.out.println("Delete data successfully.");
```
查询数据。
1. 定义查询数据的 SQL 语句，SQL 语句中使用了 SELECT * 来选择所有列，从 test_springjdbc 表中查询数据。
2. 执行查询数据的SQL语句，jdbcTemplate 对象通过调用 query 方法，执行了上述定义的查询数据的 SQL 语句，并接收一个回调函数作为参数。
3. 回调函数中的代码使用 ResultSet 对象(rs) 获取查询结果中的每一行数据，并进行处理。回调函数使用 getInt 和 getString 方法从 ResultSet 对象中获取 id 和 name 列的值，并将其打印到控制台。最后，回调函数返回 null。
4. 在控制台输出一条成功查询数据的消息。
代码如下：
```
        String selectDataSql = "SELECT * FROM test_springjdbc";
        jdbcTemplate.query(selectDataSql, (rs, rowNum) -> {
            int id = rs.getInt("id");
            String name = rs.getString("name");
            System.out.println("id: " + id + ", name: " + name);
            return null;
        });
        System.out.println("Query data successfully.");
```
删除表。
1. 定义一个 SQL 语句，用于删除数据库中的表 test_springjdbc。
2. 通过 jdbcTemplate 对象执行 SQL 语句，将删除表的操作应用于数据库。
3. 输出一条成功删除表的消息。
代码如下：
```
        String deleteTableSql = "DROP TABLE test_springjdbc";
        jdbcTemplate.execute(deleteTableSql);
        System.out.println("Table drop successfully.");
```

完整的代码展示

pom.xml

<?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.example</groupId>
    <artifactId>spring-jdbc-mysql-client</artifactId>
    <version>1.0-SNAPSHOT</version>

    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <configuration>
                    <source>8</source>
                    <target>8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>

    <dependencies>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.40</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>5.2.0.RELEASE</version>
        </dependency>
    </dependencies>

</project>

Main.java

package com.example;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DriverManagerDataSource;

public class Main {
    public static void main(String[] args) {
        // Database Connect Information
        String url = "jdbc:mysql://$host:$port/$database_name?useSSL=false";
        String username = "$user_name";
        String password = "$password";

        // create data source
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl(url);
        dataSource.setUsername(username);
        dataSource.setPassword(password);

        // Create a JdbcTemplate object
        JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);

        // Create table
        String createTableSql = "CREATE TABLE test_springjdbc (id INT, name VARCHAR(20))";
        jdbcTemplate.execute(createTableSql);
        System.out.println("Create table successfully.");

        // Insert data
        String insertDataSql = "INSERT INTO test_springjdbc (id,name) VALUES (1,'A1'), (2,'A2'), (3,'A3')";
        jdbcTemplate.update(insertDataSql);
        System.out.println("Insert data successfully.");

        // Update data
        String updateDataSql = "UPDATE test_springjdbc SET name = 'A11' WHERE id = 1";
        jdbcTemplate.update(updateDataSql);
        System.out.println("Update data successfully.");

        // Delete data
        String deleteDataSql = "DELETE FROM test_springjdbc WHERE id = 2";
        jdbcTemplate.update(deleteDataSql);
        System.out.println("Delete data successfully.");

        // Query data
        String selectDataSql = "SELECT * FROM test_springjdbc";
        jdbcTemplate.query(selectDataSql, (rs, rowNum) -> {
            int id = rs.getInt("id");
            String name = rs.getString("name");
            System.out.println("id: " + id + ", name: " + name);
            return null;
        });
        System.out.println("Query data successfully.");

        // Delete table
        String deleteTableSql = "DROP TABLE test_springjdbc";
        jdbcTemplate.execute(deleteTableSql);
        System.out.println("Table drop successfully.");
    }
}

最佳实践

事务管理

@Transactional
public void transferMoney(String fromAccount, String toAccount, BigDecimal amount) {
    // 事务操作
}

Spring JDBC 连接 seekdb 示例程序

功能特性

适用场景

前提条件

操作步骤

步骤一：将 spring-jdbc-mysql-client 项目导入到 Eclipse 中

步骤二：获取 seekdb URL

步骤三：修改 spring-jdbc-mysql-client 项目中的数据库连接信息

步骤四：运行 spring-jdbc-mysql-client 项目

常见问题

1. 连接超时

2. 字符集问题

3. SSL 连接

4. 账号密码中的特殊字符

项目代码介绍

pom.xml 代码介绍

Main.java 代码介绍

完整的代码展示

pom.xml

Main.java

最佳实践

事务管理

相关文档

Contents

功能特性​

适用场景​

前提条件​

操作步骤​

步骤一：将 spring-jdbc-mysql-client 项目导入到 Eclipse 中​

步骤二：获取 seekdb URL​

步骤三：修改 spring-jdbc-mysql-client 项目中的数据库连接信息​

步骤四：运行 spring-jdbc-mysql-client 项目​

常见问题​

1. 连接超时​

2. 字符集问题​

3. SSL 连接​

4. 账号密码中的特殊字符​

项目代码介绍​

pom.xml 代码介绍​

Main.java 代码介绍​

完整的代码展示​

pom.xml​

Main.java​

最佳实践​

事务管理​

相关文档​

Contents

功能特性

适用场景

前提条件

操作步骤

步骤一：将 spring-jdbc-mysql-client 项目导入到 Eclipse 中

步骤二：获取 seekdb URL

步骤三：修改 spring-jdbc-mysql-client 项目中的数据库连接信息

步骤四：运行 spring-jdbc-mysql-client 项目

常见问题

1. 连接超时

2. 字符集问题

3. SSL 连接

4. 账号密码中的特殊字符

项目代码介绍

pom.xml 代码介绍

Main.java 代码介绍

完整的代码展示

pom.xml

Main.java

最佳实践

事务管理

相关文档