MySQL Java 教程 · ZetCode 中文系列教程

# MySQL Java 教程 > 原文： [http://zetcode.com/db/mysqljava/](http://zetcode.com/db/mysqljava/) 这是 MySQL 数据库的 Java 教程。它涵盖了使用 JDBC 进行 Java 中 MySQL 编程的基础。 ZetCode 拥有用于 MySQL Java 的完整电子书： [MySQL Java 编程电子书](/ebooks/mysqljava/)。 [Tweet](https://twitter.com/share) 在本教程中，我们使用 MySQL Connector/J 驱动程序。它是 MySQL 的官方 JDBC 驱动程序。这些示例是在 Ubuntu Linux 上创建和测试的。您可能还需要查看 [Java 教程](/lang/java/)， [PostgreSQL Java 教程](/db/postgresqljavatutorial/)， [Apache Derby 教程](/db/apachederbytutorial/)， [MySQL 教程](/databases/mysqltutorial/)或 [Spring JdbcTemplate ZetCode 的教程](/db/jdbctemplate/)。 ## JDBC _JDBC_ 是 Java 编程语言的 API，用于定义客户端如何访问数据库。它提供了查询和更新数据库中数据的方法。 JDBC 面向关系数据库。从技术角度来看，API 是`java.sql`包中的一组类。要将 JDBC 与特定数据库一起使用，我们需要该数据库的 JDBC 驱动程序。 JDBC 是 Java 数据库编程的基石。今天，它被认为是非常底层的，并且容易出错。创建了诸如 MyBatis 或`JdbcTemplate`之类的解决方案来减轻 JDBC 编程的负担。但是，实际上，这些解决方案仍然使用 JDBC。 JDBC 是 Java Standard Edition 平台的一部分。 JDBC 管理以下三个主要的编程活动： * 连接到数据库； * 向数据库发送查询和更新语句； * 检索和处理从数据库接收到的结果以响应查询。 ## MySQL Connector/J 为了以 Java 连接到 MySQL，MySQL 提供了 MySQL Connector/J，它是实现 JDBC API 的驱动程序。 MySQL Connector/J 是 JDBC Type 4 驱动程序。 Type 4 表示驱动程序是 MySQL 协议的纯 Java 实现，并且不依赖 MySQL 客户端库。在本教程中，我们使用 MySQL Connector/J 5.1.41，它是 5.1 生产分支的维护版本。 ## 连接字符串使用连接字符串定义数据库连接。它包含诸如数据库类型，数据库名称，服务器名称和端口号之类的信息。它还可能包含用于配置的其他键/值对。每个数据库都有其自己的连接字符串格式。以下是 MySQL 连接字符串的语法： ```java jdbc:mysql://[host1][:port1][,[host2][:port2]]...[/[database]] [?propertyName1=propertyValue1[&propertyName2=propertyValue2]...] ``` 可以为服务器故障转移设置指定多个主机。方括号中的项目是可选的。如果未指定主机，则主机名默认为`localhost`。如果未指定主机端口，则默认为 MySQL 服务器的默认端口号 3306。 ```java jdbc:mysql://localhost:3306/testdb?useSSL=false ``` 这是一个 MySQL 连接字符串的示例。 `jdbc:mysql://`被称为子协议，对于 MySQL 来说是恒定的。我们在 MySQL 标准端口 3306 上连接到`localhost`。数据库名称为`testdb`。其他键/值对在问号字符（`?`）之后。 `useSSL=false`告诉 MySQL，将没有安全连接。 ## 关于 MySQL 数据库 MySQL 是领先的开源数据库管理系统。它是一个多用户，多线程的数据库管理系统。 MySQL 在网络上特别流行。它是由 Linux，Apache，MySQL 和 PHP 组成的非常流行的 _LAMP_ 平台的一部分。目前，MySQL 由 Oracle 拥有。在大多数重要的 OS 平台上都可以使用 MySQL 数据库。它可以在 BSD Unix，Linux，Windows 或 Mac OS 上运行。维基百科和 YouTube 使用 MySQL。这些站点每天管理数百万个查询。 MySQL 有两个版本：MySQL 服务器系统和 MySQL 嵌入式系统。 ## 设置 MySQL 在本节中，我们将安装 MySQL 服务器，创建`testdb`数据库和测试用户。 ```java $ sudo apt-get install mysql-server ``` 此命令将安装 MySQL 服务器和其他各种包。在安装包时，提示我们输入 MySQL 根帐户的密码。接下来，我们将创建一个新的数据库用户和一个新的数据库。我们使用`mysql`客户端。 ```java $ sudo service mysql status mysql start/running, process 5129 ``` 我们检查 MySQL 服务器是否正在运行。如果没有，我们需要启动服务器。在 Ubuntu Linux 上，可以使用`sudo service mysql start`命令来完成。 ```java $ mysql -u root -p Enter password: Welcome to the MySQL monitor. Commands end with ; or \g. Your MySQL connection id is 43 Server version: 5.7.21-0ubuntu0.16.04.1 (Ubuntu) Copyright (c) 2000, 2018, Oracle and/or its affiliates. All rights reserved. Oracle is a registered trademark of Oracle Corporation and/or its affiliates. Other names may be trademarks of their respective owners. Type 'help;' or '\h' for help. Type '\c' to clear the current input statement. mysql> SHOW DATABASES; +--------------------+ | Database | +--------------------+ | information_schema | | mysql | +--------------------+ 2 rows in set (0.00 sec) ``` 我们使用 mysql 监视器客户端应用连接到服务器。我们使用根帐户连接到数据库。我们用`SHOW DATABASES`语句显示所有可用的数据库。 ```java mysql> CREATE DATABASE testdb; Query OK, 1 row affected (0.02 sec) ``` 我们创建一个新的`testdb`数据库。在整个教程中，我们将使用此数据库。 ```java mysql> CREATE USER 'testuser'@'localhost' IDENTIFIED BY 'test623'; Query OK, 0 rows affected (0.00 sec) mysql> USE testdb; Database changed mysql> GRANT ALL ON testdb.* TO 'testuser'@'localhost'; Query OK, 0 rows affected (0.00 sec) mysql> quit; Bye ``` 我们创建一个新的数据库用户。我们为该用户授予`testdb`数据库所有表的所有特权。 ## Maven 文件我们使用以下 Maven 文件： `pom.xml` ```java <?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.zetcode</groupId> <artifactId>AppName</artifactId> <version>1.0-SNAPSHOT</version> <packaging>jar</packaging> <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>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.45</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.codehaus.mojo</groupId> <artifactId>exec-maven-plugin</artifactId> <version>1.6.0</version> <configuration> <mainClass>com.zetcode.AppName</mainClass> <cleanupDaemonThreads>false</cleanupDaemonThreads> </configuration> </plugin> </plugins> </build> <name>AppName</name> </project> ``` POM 文件具有 MySQL 驱动程序的依赖关系。我们还包括用于执行 Maven Java 程序的`exec-maven-plugin`。在`<mainClass></mainClass>`标签之间，我们提供了应用的全名。 ## Java MySQL 版本如果以下程序运行正常，则我们已安装一切正常。我们检查 MySQL 服务器的版本。 `JdbcMySQLVersion.java` ```java package com.zetcode; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.logging.Level; import java.util.logging.Logger; public class JdbcMySQLVersion { public static void main(String[] args) { String url = "jdbc:mysql://localhost:3306/testdb?useSSL=false"; String user = "testuser"; String password = "test623"; String query = "SELECT VERSION()"; try (Connection con = DriverManager.getConnection(url, user, password); Statement st = con.createStatement(); ResultSet rs = st.executeQuery(query)) { if (rs.next()) { System.out.println(rs.getString(1)); } } catch (SQLException ex) { Logger lgr = Logger.getLogger(JdbcMySQLVersion.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } } } ``` 我们连接到数据库并获取有关 MySQL 服务器的一些信息。 ```java String url = "jdbc:mysql://localhost:3306/testdb?useSSL=false"; ``` 这是 MySQL 数据库的连接 URL。每个驱动程序对于 URL 都有不同的语法。在本例中，我们提供了主机，端口和数据库名称。 ```java try (Connection con = DriverManager.getConnection(url, user, password); Statement st = con.createStatement(); ResultSet rs = st.executeQuery(query)) { ``` 我们使用连接 URL，用户名和密码建立与数据库的连接。通过`getConnection()`方法建立连接。连接对象的`createStatement()`方法创建一个`Statement`对象，用于将 SQL 语句发送到数据库。连接对象的`executeQuery()`方法执行给定的 SQL 语句，该语句返回单个`ResultSet`对象。 `ResultSet`是由特定 SQL 语句返回的数据表。 `try-with-resources`语法可确保最终清除资源。 ```java if (result.next()) { System.out.println(result.getString(1)); } ``` `ResultSet`对象维护一个游标，该游标指向其当前数据行。最初，光标位于第一行之前。 `next()`方法将光标移动到下一行。如果没有剩余的行，则该方法返回`false`。 `getString()`方法检索指定列的值。第一列的索引为 1。 ```java } catch (SQLException ex) { Logger lgr = Logger.getLogger(JdbcMySQLVersion.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } ``` 如果发生异常，我们将记录错误消息。对于此控制台示例，该消息显示在终端中。 ```java $ mvn exec:java -q 5.7.21-0ubuntu0.16.04.1 ``` 我们从命令行运行程序。 Manen 的`-q`选项在安静模式下运行 Maven。即我们只看到错误消息。 ## 创建和填充表接下来，我们将创建数据库表并用数据填充它们。这些表将在本教程中使用。 `mysql_tables.sql` ```java USE testdb; DROP TABLE IF EXISTS Books, Authors, Testing, Images; CREATE TABLE Authors(Id BIGINT PRIMARY KEY AUTO_INCREMENT, Name VARCHAR(100)); CREATE TABLE Books(Id BIGINT PRIMARY KEY AUTO_INCREMENT, AuthorId BIGINT, Title VARCHAR(100), FOREIGN KEY(AuthorId) REFERENCES Authors(Id) ON DELETE CASCADE); CREATE TABLE Testing(Id INT); CREATE TABLE Images(Id INT PRIMARY KEY AUTO_INCREMENT, Data MEDIUMBLOB); INSERT INTO Authors(Id, Name) VALUES(1, 'Jack London'); INSERT INTO Authors(Id, Name) VALUES(2, 'Honore de Balzac'); INSERT INTO Authors(Id, Name) VALUES(3, 'Lion Feuchtwanger'); INSERT INTO Authors(Id, Name) VALUES(4, 'Emile Zola'); INSERT INTO Authors(Id, Name) VALUES(5, 'Truman Capote'); INSERT INTO Books(Id, AuthorId, Title) VALUES(1, 1, 'Call of the Wild'); INSERT INTO Books(Id, AuthorId, Title) VALUES(2, 1, 'Martin Eden'); INSERT INTO Books(Id, AuthorId, Title) VALUES(3, 2, 'Old Goriot'); INSERT INTO Books(Id, AuthorId, Title) VALUES(4, 2, 'Cousin Bette'); INSERT INTO Books(Id, AuthorId, Title) VALUES(5, 3, 'Jew Suess'); INSERT INTO Books(Id, AuthorId, Title) VALUES(6, 4, 'Nana'); INSERT INTO Books(Id, AuthorId, Title) VALUES(7, 4, 'The Belly of Paris'); INSERT INTO Books(Id, AuthorId, Title) VALUES(8, 5, 'In Cold blood'); INSERT INTO Books(Id, AuthorId, Title) VALUES(9, 5, 'Breakfast at Tiffany'); ``` SQL 命令创建四个数据库表：`Authors`，`Books`，`Testing`和`Images`。这些表是 InnoDB 类型的。 InnoDB 数据库支持外键约束和事务。我们将外键约束放置在`Books`表的`AuthorId`列上。我们用初始数据填充`Authors`和`Books`表。 ```java mysql> source mysql_tables.sql Query OK, 0 rows affected (0.07 sec) Query OK, 0 rows affected (0.12 sec) Query OK, 1 row affected (0.04 sec) ... ``` 我们使用`source`命令执行`tables.sql`脚本。 ## Java MySQL 预备语句现在，我们将以预备语句来关注自己。在编写预备语句时，我们使用占位符，而不是直接将值写入语句中。预准备的语句可提高安全性和性能。在 Java 中，`PreparedStatement`是代表预编译的 SQL 语句的对象。 `JdbcPrepared.java` ```java package com.zetcode; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; import java.util.logging.Level; import java.util.logging.Logger; public class JdbcPrepared { public static void main(String[] args) { String url = "jdbc:mysql://localhost:3306/testdb?useSSL=false"; String user = "testuser"; String password = "test623"; String author = "Trygve Gulbranssen"; String sql = "INSERT INTO Authors(Name) VALUES(?)"; try (Connection con = DriverManager.getConnection(url, user, password); PreparedStatement pst = con.prepareStatement(sql)) { pst.setString(1, author); pst.executeUpdate(); System.out.println("A new author has been inserted"); } catch (SQLException ex) { Logger lgr = Logger.getLogger(JdbcPrepared.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } } } ``` 我们将新作者添加到`Authors`表中。 ```java try (Connection con = DriverManager.getConnection(url, user, password); PreparedStatement pst = con.prepareStatement(sql)) { ``` 在这里，我们创建一个预备语句。在编写预备语句时，我们使用占位符，而不是直接将值写入语句中。预备语句更快，并且可以防止 SQL 注入攻击。 `?`是一个占位符，稍后将被填充。 ```java pst.setString(1, author); ``` 值绑定到占位符。 ```java pst.executeUpdate(); ``` 执行预备语句。当我们不希望返回任何数据时，我们使用语句对象的`executeUpdate()`方法。这是当我们创建数据库或执行`INSERT`，`UPDATE`，`DELETE`语句时。 ```java $ mvn exec:java -q A new author has been inserted mysql> select * from Authors; +----+--------------------+ | Id | Name | +----+--------------------+ | 1 | Jack London | | 2 | Honore de Balzac | | 3 | Lion Feuchtwanger | | 4 | Emile Zola | | 5 | Truman Capote | | 6 | Trygve Gulbranssen | +----+--------------------+ 6 rows in set (0.00 sec) ``` 我们在表中插入了一位新作者。 ## 测试 MySQL 预备和非预备的语句对于以下两个示例，我们将使用`Testing`表。我们将执行一条普通语句和一条准备语句 5000 次。我们检查执行时间是否有差异。 `JdbcNotPreparedTesting.java` ```java package com.zetcode; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement; import java.util.logging.Level; import java.util.logging.Logger; public class JdbcNotPreparedTesting { public static void main(String[] args) { String cs = "jdbc:mysql://localhost:3306/testdb?useSSL=false"; String user = "testuser"; String password = "test623"; try (Connection con = DriverManager.getConnection(cs, user, password); Statement st = con.createStatement()) { for (int i = 1; i <= 5000; i++) { String sql = "INSERT INTO Testing(Id) VALUES(" + 2 * i + ")"; st.executeUpdate(sql); } } catch (SQLException ex) { Logger lgr = Logger.getLogger(JdbcNotPreparedTesting.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } } } ``` 第一个示例使用普通的`Statement`对象。 ```java for (int i = 1; i <= 5000; i++) { String sql = "INSERT INTO Testing(Id) VALUES(" + 2 * i + ")"; st.executeUpdate(sql); } ``` 我们建立查询并执行 5000 次。 ```java $ time mvn exec:java -q real 4m14.716s user 0m6.820s sys 0m0.404s ``` 完成 5000 次插入需要 4.14 分钟。 `JdbcPreparedTesting.java` ```java package com.zetcode; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; import java.util.logging.Level; import java.util.logging.Logger; public class JdbcPreparedTesting { public static void main(String[] args) { String cs = "jdbc:mysql://localhost:3306/testdb?useSSL=false"; String user = "testuser"; String password = "test623"; String sql = "INSERT INTO Testing(Id) VALUES(?)"; try (Connection con = DriverManager.getConnection(cs, user, password); PreparedStatement pst = con.prepareStatement(sql)) { for (int i = 1; i <= 5000; i++) { pst.setInt(1, i * 2); pst.executeUpdate(); } } catch (SQLException ex) { Logger lgr = Logger.getLogger(JdbcPreparedTesting.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } } } ``` 现在，我们使用`PreparedStatement`执行相同的任务。 ```java try (Connection con = DriverManager.getConnection(cs, user, password); PreparedStatement pst = con.prepareStatement(sql)) { ``` 我们使用`prepareStatement()`方法创建预备语句。 ```java for (int i = 1; i <= 5000; i++) { pst.setInt(1, i * 2); pst.executeUpdate(); } ``` 我们将一个值绑定到预备语句，并在循环中执行数千次。 ```java $ time mvn exec:java -q real 3m53.962s user 0m6.280s sys 0m0.380s ``` 现在花了 3.53 分钟完成了 5000 次插入。我们节省了 20 秒。 ## Java MySQL 检索数据接下来，我们将展示如何从数据库表中检索数据。我们从`Authors`表中获取所有数据。 `JdbcRetrieve.java` ```java package com.zetcode; import java.sql.PreparedStatement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.util.logging.Level; import java.util.logging.Logger; public class JdbcRetrieve { public static void main(String[] args) { String url = "jdbc:mysql://localhost:3306/testdb?useSSL=false"; String user = "testuser"; String password = "test623"; String query = "SELECT * FROM Authors"; try (Connection con = DriverManager.getConnection(url, user, password); PreparedStatement pst = con.prepareStatement(query); ResultSet rs = pst.executeQuery()) { while (rs.next()) { System.out.print(rs.getInt(1)); System.out.print(": "); System.out.println(rs.getString(2)); } } catch (SQLException ex) { Logger lgr = Logger.getLogger(JdbcRetrieve.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } } } ``` 我们从`Authors`表中获取所有作者并将其打印到控制台。 ```java String query = "SELECT * FROM Authors"; try (Connection con = DriverManager.getConnection(url, user, password); PreparedStatement pst = con.prepareStatement(query); ResultSet rs = pst.executeQuery()) { ``` 我们执行一个查询，该查询从`Authors`表中选择所有列。我们使用`executeQuery()`方法。该方法执行给定的 SQL 语句，该语句返回单个`ResultSet`对象。 `ResultSet`是 SQL 查询返回的数据表。 ```java while (rs.next()) { System.out.print(rs.getInt(1)); System.out.print(": "); System.out.println(rs.getString(2)); } ``` `next()`方法将光标移至下一条记录。当结果集中没有更多行时，它将返回`false`。 `getInt()`和`getString()`方法检索此`ResultSet`对象当前行中指定列的值，作为 Java 编程语言的`int`和`String`。 ```java $ mvn exec:java -q 1: Jack London 2: Honore de Balzac 3: Lion Feuchtwanger 4: Emile Zola 5: Truman Capote 6: Trygve Gulbranssen ``` 我们执行程序；我们在控制台上印有作者的 ID 和姓名。 ## 属性通常的做法是将配置数据放在程序外部的单独文件中。这样程序员可以更加灵活。我们可以更改用户，密码或连接 URL，而无需重新编译程序。它在需要大量测试，调试，保护数据等的动态环境中特别有用。在 Java 中，`Properties`是为此经常使用的类。该类用于轻松读取和保存键/值属性。 `db.properties` ```java db.url=jdbc:mysql://localhost:3306/testdb?useSSL=false db.user=testuser db.passwd=test623 ``` 我们有一个`db.properties`文件，其中有三个键/值对。这些是在程序执行期间动态加载的。 `JdbcProperties.java` ```java package com.zetcode; import java.io.FileInputStream; import java.io.IOException; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.PreparedStatement; import java.util.Properties; import java.util.logging.Level; import java.util.logging.Logger; public class JdbcProperties { private static Properties getConnectionData() { Properties props = new Properties(); String fileName = "src/main/resources/db.properties"; try (FileInputStream in = new FileInputStream(fileName)) { props.load(in); } catch (IOException ex) { Logger lgr = Logger.getLogger(JdbcProperties.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } return props; } public static void main(String[] args) { Properties props = getConnectionData(); String url = props.getProperty("db.url"); String user = props.getProperty("db.user"); String passwd = props.getProperty("db.passwd"); String query = "SELECT * FROM Authors"; try (Connection con = DriverManager.getConnection(url, user, passwd); PreparedStatement pst = con.prepareStatement(query); ResultSet rs = pst.executeQuery()) { while (rs.next()) { System.out.print(rs.getInt(1)); System.out.print(": "); System.out.println(rs.getString(2)); } } catch (SQLException ex) { Logger lgr = Logger.getLogger(JdbcProperties.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } } } ``` 我们连接到`testdb`数据库，并将`Authors`表的内容打印到控制台。这次，我们从文件加载连接属性。他们没有在程序中硬编码。 ```java Properties props = new Properties(); String fileName = "src/main/resources/db.properties"; try (FileInputStream in = new FileInputStream(fileName)) { props.load(in); } catch (IOException ex) { Logger lgr = Logger.getLogger(JdbcProperties.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } ``` 创建`Properties`类。数据是从名为`db.properties`的文件中加载的，其中包含我们的配置数据。 ```java String url = props.getProperty("db.url"); String user = props.getProperty("db.user"); String passwd = props.getProperty("db.passwd"); ``` 使用`getProperty()`方法检索这些值。 ## Java MySQL 数据源在此示例中，我们使用数据源连接到数据库。数据源的使用可以提高应用的性能和可伸缩性。与`DriverManager`相比，使用数据源具有多个优点：增强了可移植性，连接池和分布式事务。 `MysqlDataSource`是用于创建数据源的类。 `db.properties` ```java # mysql properties mysql.driver=com.mysql.jdbc.Driver mysql.url=jdbc:mysql://localhost:3306/testdb?useSSL=false mysql.username=testuser mysql.password=test623 ``` 是 MySQL 数据库的属性。 `ComLineDSEx.java` ```java package com.zetcode; import com.mysql.jdbc.jdbc2.optional.MysqlDataSource; import java.io.FileInputStream; import java.io.IOException; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.PreparedStatement; import java.util.Properties; import java.util.logging.Level; import java.util.logging.Logger; public class ComLineDSEx { public static MysqlDataSource getMySQLDataSource() { Properties props = new Properties(); String fileName = "src/main/resources/db.properties"; try (FileInputStream fis = new FileInputStream(fileName)) { props.load(fis); } catch (IOException ex) { Logger lgr = Logger.getLogger(ComLineDSEx.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } MysqlDataSource ds = new MysqlDataSource(); ds.setURL(props.getProperty("mysql.url")); ds.setUser(props.getProperty("mysql.username")); ds.setPassword(props.getProperty("mysql.password")); return ds; } public static void main(String[] args) { MysqlDataSource ds = getMySQLDataSource(); String query = "SELECT VERSION()"; try (Connection con = ds.getConnection(); PreparedStatement pst = con.prepareStatement(query); ResultSet rs = pst.executeQuery()) { if (rs.next()) { String version = rs.getString(1); System.out.println(version); } } catch (SQLException ex) { Logger lgr = Logger.getLogger(ComLineDSEx.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } } } ``` 在此示例中，我们使用数据源连接到数据库。 ```java String fileName = "src/main/resources/db.properties"; try (FileInputStream fis = new FileInputStream(fileName)) { props.load(fis); } catch (IOException ex) { Logger lgr = Logger.getLogger(ComLineDSEx.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } ``` 从`db.properties`文件中读取数据库属性。 ```java MysqlDataSource ds = new MysqlDataSource(); ds.setURL(props.getProperty("mysql.url")); ds.setUser(props.getProperty("mysql.username")); ds.setPassword(props.getProperty("mysql.password")); ``` 创建`MysqlDataSource`并设置数据源属性。 ```java try (Connection con = ds.getConnection(); PreparedStatement pst = con.prepareStatement(query); ResultSet rs = pst.executeQuery()) { ``` 连接对象是从数据源创建的。 ## Java MySQL 多条语句可以在一个查询中执行多个 SQL 语句。必须将`allowMultiQueries`设置为启用 MySQL 中的多个语句。 `JdbcMulStat.java` ```java package com.zetcode; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; public class JdbcMulStat { public static void main(String[] args) throws SQLException { String cs = "jdbc:mysql://localhost:3306/" + "testdb?allowMultiQueries=true&useSSL=false"; String user = "testuser"; String password = "test623"; String query = "SELECT Id, Name FROM Authors WHERE Id=1;" + "SELECT Id, Name FROM Authors WHERE Id=2;" + "SELECT Id, Name FROM Authors WHERE Id=3"; try (Connection con = DriverManager.getConnection(cs, user, password); PreparedStatement pst = con.prepareStatement(query);) { boolean isResult = pst.execute(); do { try (ResultSet rs = pst.getResultSet()) { while (rs.next()) { System.out.print(rs.getInt(1)); System.out.print(": "); System.out.println(rs.getString(2)); } isResult = pst.getMoreResults(); } } while (isResult); } } } ``` 在代码示例中，我们从`Authors`表中检索三行。我们使用三个`SELECT`语句来获取三行。 ```java String cs = "jdbc:mysql://localhost:3306/" + "testdb?allowMultiQueries=true&useSSL=false"; ``` 通过将`allowMultiQueries`参数设置为`true`，我们可以在数据库 URL 中启用多个语句查询。 ```java String query = "SELECT Id, Name FROM Authors WHERE Id=1;" + "SELECT Id, Name FROM Authors WHERE Id=2;" + "SELECT Id, Name FROM Authors WHERE Id=3"; ``` 在这里，我们有一个包含多个语句的查询。语句用分号分隔。 ```java boolean isResult = pst.execute(); ``` 我们调用已预备语句对象的`execute()`方法。该方法返回一个布尔值，该布尔值指示第一个结果是否为`ResultSet`对象。使用`getMoreResults()`方法调用后续结果。 ```java do { try (ResultSet rs = pst.getResultSet()) { while (rs.next()) { System.out.print(rs.getInt(1)); System.out.print(": "); System.out.println(rs.getString(2)); } isResult = pst.getMoreResults(); } } while (isResult); ``` 结果的处理在`do while`循环内完成。通过`getResultSet()`方法调用检索`ResultSet`。为了找出是否还有其他结果，我们调用`getMoreResults()`方法。 ```java $ mvn exec:java -q 1: Jack London 2: Honore de Balzac 3: Lion Feuchtwanger ``` 这是示例的输出。前三行是从`Authors`表中检索的。 ## Java MySQL 列标题下面的示例显示如何使用数据库表中的数据打印列标题。我们将列名称称为元数据。元数据是有关数据库中核心数据的数据。 `JdbcColumnHeaders.java` ```java package com.zetcode; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.util.logging.Level; import java.util.logging.Logger; public class JdbcColumnHeaders { public static void main(String[] args) { String cs = "jdbc:mysql://localhost:3306/testdb?useSSL=false"; String user = "testuser"; String password = "test623"; String query = "SELECT Name, Title From Authors, " + "Books WHERE Authors.Id=Books.AuthorId"; try (Connection con = DriverManager.getConnection(cs, user, password); PreparedStatement pst = con.prepareStatement(query); ResultSet rs = pst.executeQuery()) { ResultSetMetaData meta = rs.getMetaData(); String colname1 = meta.getColumnName(1); String colname2 = meta.getColumnName(2); String header = String.format("%-21s%s", colname1, colname2); System.out.println(header); while (rs.next()) { String row = String.format("%-21s", rs.getString(1)); System.out.print(row); System.out.println(rs.getString(2)); } } catch (SQLException ex) { Logger lgr = Logger.getLogger(JdbcColumnHeaders.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } } } ``` 在此程序中，我们从`Authors`表中选择作者，并从`Books`表中选择他们的书。我们打印结果集中返回的列的名称。输出已格式化。 ```java String query = "SELECT Name, Title From Authors, " + "Books WHERE Authors.Id=Books.AuthorId"; ``` 这是将作者与他们的书联系在一起的 SQL 语句。 ```java ResultSetMetaData meta = rs.getMetaData(); ``` 要获取列名，我们需要获取`ResultSetMetaData`。它是一个对象，可用于获取有关`ResultSet`对象中列的类型和属性的信息。 ```java String colname1 = meta.getColumnName(1); String colname2 = meta.getColumnName(2); ``` 从获得的元数据中，我们获得列名。 ```java String header = String.format("%-21s%s", colname1, colname2); System.out.println(header); ``` 我们将列名称打印到控制台。 ```java while (rs.next()) { String row = String.format("%-21s", rs.getString(1)); System.out.print(row); System.out.println(rs.getString(2)); } ``` 我们将数据打印到控制台。第一列为 21 个字符，并在左侧对齐。 ```java $ mvn exec:java -q NAME Title Jack London Call of the Wild Jack London Martin Eden Honore de Balzac Old Goriot Honore de Balzac Cousin Bette Lion Feuchtwanger Jew Suess Emile Zola Nana Emile Zola The Belly of Paris Truman Capote In Cold blood Truman Capote Breakfast at Tiffany ``` 这是程序的输出。 ## MySQL Java 自动生成的键 MySQL 的`AUTO_INCREMENT`属性为新行生成唯一的 ID。以下示例说明了如何使用 JDBC 检索自动生成的键值。 `JdbcAutoGenKey.java` ```java package com.zetcode; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.logging.Level; import java.util.logging.Logger; public class JdbcAutoGenKey { public static void main(String[] args) { String url = "jdbc:mysql://localhost:3306/testdb?useSSL=false"; String user = "testuser"; String password = "test623"; String author = "Oscar Wilde"; String sql = "INSERT INTO Authors(Name) VALUES(?)"; try (Connection con = DriverManager.getConnection(url, user, password); PreparedStatement pst = con.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS)) { pst.setString(1, author); pst.executeUpdate(); try (ResultSet rs = pst.getGeneratedKeys()) { if (rs.first()) { System.out.printf("The ID of new author: %d", rs.getLong(1)); } } } catch (SQLException ex) { Logger lgr = Logger.getLogger(JdbcAutoGenKey.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } } } ``` 在该示例中，我们向表中添加了一个新作者，其主键由 MySQL 自动递增。我们检索生成的 ID。 ```java try (Connection con = DriverManager.getConnection(url, user, password); PreparedStatement pst = con.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS)) { ``` 第一步，我们必须将`Statement.RETURN_GENERATED_KEYS`传递给`prepareStatement()`方法。 ```java try (ResultSet rs = pst.getGeneratedKeys()) { ``` 然后，我们使用`getGeneratedKeys()`方法检索生成的键。 ```java if (rs.first()) { System.out.printf("The ID of new author: %d", rs.getLong(1)); } ``` 由于我们只有一个插入语句，因此我们使用`first()`导航到该值。 ```java $ mvn exec:java -q The ID of new author: 7 ``` 这是一个示例输出。 ## MySQL Java 编写图像有些人喜欢将其图像放入数据库中，有些人则希望将其保留在文件系统中以供其应用使用。当我们处理大量图像时，会出现技术难题。图像是二进制数据。 MySQL 数据库具有一种特殊的数据类型来存储称为`BLOB`（二进制大对象）的二进制数据。对于此示例，我们使用`Images`表。 `JdbcWriteImage.java` ```java package com.zetcode; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; import java.util.logging.Level; import java.util.logging.Logger; public class JdbcWriteImage { public static void main(String[] args) { String cs = "jdbc:mysql://localhost:3306/testdb?useSSL=false"; String user = "testuser"; String password = "test623"; String sql = "INSERT INTO Images(Data) VALUES(?)"; try (Connection con = DriverManager.getConnection(cs, user, password); PreparedStatement pst = con.prepareStatement(sql)) { File myFile = new File("src/main/resources/tree.png"); try (FileInputStream fin = new FileInputStream(myFile)) { pst.setBinaryStream(1, fin, (int) myFile.length()); pst.executeUpdate(); } catch (IOException ex) { Logger lgr = Logger.getLogger(JdbcWriteImage.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } } catch (SQLException ex) { Logger lgr = Logger.getLogger(JdbcWriteImage.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } } } ``` 在前面的示例中，我们从当前工作目录中读取 PNG 图像，并将其插入`Images`表中。 ```java String sql = "INSERT INTO Images(Data) VALUES(?)"; ``` 这是插入图像的 SQL。 ```java File myFile = new File("src/main/resources/tree.png"); try (FileInputStream fin = new FileInputStream(myFile)) { ``` 我们为图像文件创建一个`File`对象。要从该文件读取字节，我们创建一个`FileInputStream`对象。 ```java pst.setBinaryStream(1, fin, (int) myFile.length()); ``` 二进制流设置为预备语句。 `setBinaryStream()`方法的参数是要绑定的参数索引，输入流和流中的字节数。 ```java pst.executeUpdate(); ``` 我们执行该语句。 ## MySQL Java 读取图像在前面的示例中，我们已将图像插入数据库表中。现在，我们将从表中读取图像。 `JdbcReadImage.java` ```java package com.zetcode; import java.io.FileOutputStream; import java.io.IOException; import java.sql.Blob; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.logging.Level; import java.util.logging.Logger; public class JdbcReadImage { public static void main(String[] args) { String url = "jdbc:mysql://localhost:3306/testdb?useSSL=false"; String user = "testuser"; String password = "test623"; String query = "SELECT Data FROM Images LIMIT 1"; try (Connection con = DriverManager.getConnection(url, user, password); PreparedStatement pst = con.prepareStatement(query); ResultSet result = pst.executeQuery()) { if (result.next()) { String fileName = "src/main/resources/tree.png"; try (FileOutputStream fos = new FileOutputStream(fileName)) { Blob blob = result.getBlob("Data"); int len = (int) blob.length(); byte[] buf = blob.getBytes(1, len); fos.write(buf, 0, len); } catch (IOException ex) { Logger lgr = Logger.getLogger(JdbcReadImage.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } } } catch (SQLException ex) { Logger lgr = Logger.getLogger(JdbcReadImage.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } } } ``` 我们从图片表中读取了一张图片。 ```java String query = "SELECT Data FROM Images LIMIT 1"; ``` 我们从表中选择一条记录。 ```java String fileName = "src/main/resources/tree.png"; try (FileOutputStream fos = new FileOutputStream(fileName)) { ``` 创建`FileOutputStream`对象以写入文件。它旨在写入原始字节流，例如图像数据。 ```java Blob blob = result.getBlob("Data"); ``` 我们通过调用`getBlob()`方法从`Data`列中获取图像数据。 ```java int len = (int) blob.length(); ``` 我们计算出斑点数据的长度。换句话说，我们得到字节数。 ```java byte[] buf = blob.getBytes(1, len); ``` `getBytes()`方法以字节数组的形式检索 Blob 对象的所有字节。 ```java fos.write(buf, 0, len); ``` 字节被写入输出流。该映像在文件系统上创建。 ## 事务支持事务是针对一个或多个数据库中数据的数据库操作的基本单位。事务中所有 SQL 语句的影响可以全部提交给数据库，也可以全部回滚。 MySQL 数据库具有不同类型的存储引擎。最常见的是 MyISAM 和 InnoDB 引擎。在数据安全性和数据库速度之间需要权衡。 MyISAM 表的处理速度更快，并且不支持事务。另一方面，InnoDB 表可以更安全地防止数据丢失。它们支持事务，并且处理速度较慢。 `JdbcTransaction.java` ```java package com.zetcode; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement; import java.util.logging.Level; import java.util.logging.Logger; public class JdbcTransaction { public static void main(String[] args) { String url = "jdbc:mysql://localhost:3306/testdb?useSSL=false"; String user = "testuser"; String password = "test623"; try (Connection con = DriverManager.getConnection(url, user, password)) { try (Statement st = con.createStatement()) { con.setAutoCommit(false); st.executeUpdate("UPDATE Authors SET Name = 'Leo Tolstoy'" + "WHERE Id = 1"); st.executeUpdate("UPDATE Books SET Title = 'War and Peace'" + "WHERE Id = 1"); st.executeUpdate("UPDATE Books SET Titl = 'Anna Karenina'" + "WHERE Id = 2"); con.commit(); } catch (SQLException ex) { try { con.rollback(); } catch (SQLException ex1) { Logger lgr = Logger.getLogger(JdbcTransaction.class.getName()); lgr.log(Level.WARNING, ex1.getMessage(), ex1); } Logger lgr = Logger.getLogger(JdbcTransaction.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } } catch (SQLException ex) { Logger.getLogger(JdbcTransaction.class.getName()).log( Level.SEVERE, null, ex); } } } ``` 在此程序中，我们想在`Authors`表的第一行上更改作者的姓名。我们还必须更改与该作者相关的书籍。这是一个需要进行事务的很好的例子。如果我们更改作者但不更改作者的书，则数据已损坏。 ```java con.setAutoCommit(false); ``` 要处理事务，我们必须将自动提交模式设置为`false`。默认情况下，数据库连接处于自动提交模式。在这种模式下，每条语句在执行后都会立即提交给数据库。声明无法撤消。当自动提交关闭时，我们通过调用`commit()`提交更改，或通过调用`rollback()`方法将其回滚。 ```java st.executeUpdate("UPDATE Books SET Titl = 'Anna Karenina' " + "WHERE Id = 2"); ``` 第三个 SQL 语句有一个错误。表中没有`Titl`栏。 ```java con.commit(); ``` 如果没有异常，则提交事务。 ```java try { con.rollback(); } catch (SQLException ex1) { Logger lgr = Logger.getLogger(JdbcTransaction.class.getName()); lgr.log(Level.WARNING, ex1.getMessage(), ex1); } ``` 发生异常时，事务将回滚。没有更改提交到数据库。 ```java Feb 21, 2018 2:35:14 PM com.zetcode.JdbcTransaction main SEVERE: Unknown column 'Titl' in 'field list' com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Unknown column 'Titl' in 'field list' ``` 该应用以异常结束。 ```java mysql> SELECT Name, Title From Authors, Books WHERE Authors.Id=Books.AuthorId; +-------------------+----------------------+ | Name | Title | +-------------------+----------------------+ | Jack London | Call of the Wild | | Jack London | Martin Eden | | Honore de Balzac | Old Goriot | | Honore de Balzac | Cousin Bette | | Lion Feuchtwanger | Jew Suess | | Emile Zola | Nana | | Emile Zola | The Belly of Paris | | Truman Capote | In Cold blood | | Truman Capote | Breakfast at Tiffany | +-------------------+----------------------+ 9 rows in set (0.01 sec) ``` 事务已回滚，并且未进行任何更改。但是，如果没有事务，数据是不安全的。 `JdbcNoTransaction.java` ```java package com.zetcode; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement; import java.util.logging.Level; import java.util.logging.Logger; public class JdbcNoTransaction { public static void main(String[] args) { String url = "jdbc:mysql://localhost:3306/testdb?useSSL=false"; String user = "testuser"; String password = "test623"; try (Connection con = DriverManager.getConnection(url, user, password); Statement st = con.createStatement()) { st.executeUpdate("UPDATE Authors SET Name = 'Leo Tolstoy'" + "WHERE Id = 1"); st.executeUpdate("UPDATE Books SET Title = 'War and Peace'" + "WHERE Id = 1"); st.executeUpdate("UPDATE Books SET Titl = 'Anna Karenina'" + "WHERE Id = 2"); } catch (SQLException ex) { Logger lgr = Logger.getLogger(JdbcNoTransaction.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } } } ``` 我们有同样的例子。这次，没有事务支持。 ```java mysql> SELECT Name, Title From Authors, Books WHERE Authors.Id=Books.AuthorId; +-------------------+----------------------+ | Name | Title | +-------------------+----------------------+ | Leo Tolstoy | War and Peace | | Leo Tolstoy | Martin Eden | | Honore de Balzac | Old Goriot | | Honore de Balzac | Cousin Bette | | Lion Feuchtwanger | Jew Suess | | Emile Zola | Nana | | Emile Zola | The Belly of Paris | | Truman Capote | In Cold blood | | Truman Capote | Breakfast at Tiffany | +-------------------+----------------------+ 9 rows in set (0.00 sec) ``` 再次引发异常。列夫·托尔斯泰没有写马丁·伊甸园；数据已损坏。 ## 批量更新当我们需要使用多个语句更新数据时，可以使用批处理更新。批处理更新可用于`INSERT`，`UPDATE`，`DELETE`语句以及`CREATE TABLE`和`DROP TABLE`语句。 `JdbcBatchUpdate.java` ```java package com.zetcode; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement; import java.util.logging.Level; import java.util.logging.Logger; public class JdbcBatchUpdate { public static void main(String[] args) { String url = "jdbc:mysql://localhost:3306/testdb?useSSL=false"; String user = "testuser"; String password = "test623"; try (Connection con = DriverManager.getConnection(url, user, password)) { try (Statement st = con.createStatement()) { con.setAutoCommit(false); st.addBatch("DROP TABLE IF EXISTS Authors2"); st.addBatch("CREATE TABLE Authors2(Id INT PRIMARY KEY, " + "Name VARCHAR(100))"); st.addBatch("INSERT INTO Authors2(Id, Name) " + "VALUES(1, 'Jack London')"); st.addBatch("INSERT INTO Authors2(Id, Name) " + "VALUES(2, 'Honore de Balzac')"); st.addBatch("INSERT INTO Authors2(Id, Name) " + "VALUES(3, 'Lion Feuchtwanger')"); st.addBatch("INSERT INTO Authors2(Id, Name) " + "VALUES(4, 'Emile Zola')"); st.addBatch("INSERT INTO Authors2(Id, Name) " + "VALUES(5, 'Truman Capote')"); st.addBatch("INSERT INTO Authors2(Id, Name) " + "VALUES(6, 'Umberto Eco')"); int counts[] = st.executeBatch(); con.commit(); System.out.printf("Committed %d updates", counts.length); } catch (SQLException ex) { try { con.rollback(); } catch (SQLException ex2) { Logger lgr = Logger.getLogger(JdbcBatchUpdate.class.getName()); lgr.log(Level.FINEST, ex2.getMessage(), ex2); } Logger lgr = Logger.getLogger(JdbcBatchUpdate.class.getName()); lgr.log(Level.FINEST, ex.getMessage(), ex); } } catch (SQLException ex) { Logger lgr = Logger.getLogger(JdbcBatchUpdate.class.getName()); lgr.log(Level.FINEST, ex.getMessage(), ex); } } } ``` 这是用于批处理更新的示例程序。我们从`Authors`表中删除所有数据，然后插入新数据。我们添加了一位新作者，`Umberto Eco`，以查看更改。 ```java st.addBatch("DROP TABLE IF EXISTS Authors2"); st.addBatch("CREATE TABLE Authors2(Id INT PRIMARY KEY, " + "Name VARCHAR(100))"); st.addBatch("INSERT INTO Authors2(Id, Name) " + "VALUES(1, 'Jack London')"); ... ``` 我们使用`addBatch()`方法向该语句添加新命令。 ```java int counts[] = st.executeBatch(); ``` 添加所有命令后，我们调用`executeBatch()`进行批量更新。该方法返回已提交更改的数组。 ```java con.commit(); ``` 批处理更新在事务中提交。 ```java } catch (SQLException ex) { try { con.rollback(); } catch (SQLException ex2) { Logger lgr = Logger.getLogger(JdbcBatchUpdate.class.getName()); lgr.log(Level.FINEST, ex2.getMessage(), ex2); } Logger lgr = Logger.getLogger(JdbcBatchUpdate.class.getName()); lgr.log(Level.FINEST, ex.getMessage(), ex); } ``` 万一批量更新失败，我们将其称为`rollback()`。 ```java $ mvn exec:java -q Committed 8 updates mysql> SELECT * from Authors2; +----+-------------------+ | Id | Name | +----+-------------------+ | 1 | Jack London | | 2 | Honore de Balzac | | 3 | Lion Feuchtwanger | | 4 | Emile Zola | | 5 | Truman Capote | | 6 | Umberto Eco | +----+-------------------+ 6 rows in set (0.00 sec) ``` 我们执行`BatchUpdate`程序。 `SELECT`语句显示`Authors2`表已成功更新。它有一个新作者，Umerto Eco。 ## 将数据导出到 CSV 文件下一个示例将数据导出到 CSV 文件。我们需要对`testuser`具有适当的文件许可权；否则，我们会收到拒绝访问错误消息。 ```java mysql> GRANT FILE ON *.* TO 'testuser'@'localhost'; ``` 我们设置了`FILE`权限。 ```java mysql> SHOW VARIABLES LIKE "secure_file_priv"; +------------------+-----------------------+ | Variable_name | Value | +------------------+-----------------------+ | secure_file_priv | /var/lib/mysql-files/ | +------------------+-----------------------+ 1 row in set (0.26 sec) ``` 出于安全原因，MySQL 从启用`--secure-file-priv`选项开始，该选项仅允许处理特定目录中的文件。该目录在`secure_file_priv`变量中指定。在 Windows 上，路径类似于`'C:/ProgramData/MySQL/MySQL Server 5.7/Uploads'`。 `ExportCSV.java` ```java package com.zetcode; import java.sql.PreparedStatement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.util.logging.Level; import java.util.logging.Logger; public class JdbcExportCSV { public static void main(String[] args) { String url = "jdbc:mysql://localhost:3306/testdb?useSSL=false"; String user = "testuser"; String password = "test623"; String query = "SELECT Name, Title INTO OUTFILE " + "'/var/lib/mysql-files/authors_books.csv' " + "FIELDS TERMINATED BY ',' " + "FROM Authors, Books WHERE " + "Authors.Id=Books.AuthorId"; try (Connection con = DriverManager.getConnection(url, user, password); PreparedStatement pst = con.prepareStatement(query)) { pst.execute(); } catch (SQLException ex) { Logger lgr = Logger.getLogger(JdbcExportCSV.class.getName()); lgr.log(Level.SEVERE, ex.getMessage(), ex); } } } ``` 我们将作者及其相应的书籍导出到`/var/lib/mysql-files/authors_books.csv`文件中。 ```java String query = "SELECT Name, Title INTO OUTFILE " + "'/var/lib/mysql-files/authors_books.csv' " + "FIELDS TERMINATED BY ',' " + "FROM Authors, Books WHERE " + "Authors.Id=Books.AuthorId"; ``` 要将数据导出到文件中，我们使用`SELECT INTO OUTFILE` SQL 语句。 ```java $ cat /var/lib/mysql-files/authors_books.csv Jack London,Call of the Wild Jack London,Martin Eden Honore de Balzac,Old Goriot Honore de Balzac,Cousin Bette Lion Feuchtwanger,Jew Suess Emile Zola,Nana Emile Zola,The Belly of Paris Truman Capote,In Cold blood Truman Capote,Breakfast at Tiffany ``` 我们验证数据。这是 MySQL Java 教程。您可能也对 [JDBI 教程](/db/jdbi/)， [Java H2 教程](/java/h2database/)， [PostgreSQL Java 教程](/db/postgresqljavatutorial/)， [MongoDB Java 教程](/db/mongodbjava/)或 [MySQL 教程](/databases/mysqltutorial/)感兴趣。