1. 引入JDBC驱动
在使用JDBC连接MySQL之前，首先需要引入MySQL的JDBC驱动。你可以在MySQL官网或者Maven仓库中下载合适版本的MySQL Connector/J。
// 引入MySQL JDBC驱动 Class.forName("com.mysql.cj.jdbc.Driver");
2. 建立数据库连接
import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class MySQLConnection { public static Connection getConnection() throws SQLException { String url = "jdbc:mysql://localhost:3306/your_database"; String user = "your_username"; String password = "your_password"; return DriverManager.getConnection(url, user, password); } }
在上述代码中，将your_database、your_username和your_password替换为实际的数据库名、用户名和密码。请注意，这里使用的是DriverManager类来获取数据库连接，确保已加载MySQL的JDBC驱动。
3. 关闭数据库连接
public class MySQLConnection { // ... public static void closeConnection(Connection connection) { if (connection != null) { try { connection.close(); } catch (SQLException e) { e.printStackTrace(); } } } }
在Java中，及时关闭数据库连接是一种良好的编程习惯，可以避免资源泄漏。上述代码中的closeConnection方法用于关闭数据库连接。
4. 使用连接池
连接池是一种常见的优化手段，可以提高数据库连接的复用性和性能。使用开源的连接池库，如HikariCP、C3P0或Druid，可以轻松实现连接池的配置和管理。
import com.zaxxer.hikari.HikariConfig; import com.zaxxer.hikari.HikariDataSource; public class MySQLConnection { private static HikariDataSource dataSource; static { HikariConfig config = new HikariConfig(); config.setJdbcUrl("jdbc:mysql://localhost:3306/your_database"); config.setUsername("your_username"); config.setPassword("your_password"); dataSource = new HikariDataSource(config); } public static Connection getConnectionFromPool() throws SQLException { return dataSource.getConnection(); } }
5. 使用try-with-resources
Java 7引入了try-with-resources语句，可以在代码块结束时自动关闭资源，包括数据库连接。这样可以减少手动关闭资源的繁琐操作。
public class MySQLConnection { public static void main(String[] args) { try (Connection connection = MySQLConnection.getConnection()) { // 在这里执行数据库操作 } catch (SQLException e) { e.printStackTrace(); } } }
6. 优化查询性能
在执行大量数据查询时，可以使用PreparedStatement来预编译SQL语句，提高查询性能。同时，使用setXxx方法绑定参数，防止SQL注入攻击。
import java.sql.PreparedStatement; import java.sql.ResultSet; public class MySQLConnection { public static void main(String[] args) { String sql = "SELECT * FROM your_table WHERE column_name = ?"; try (Connection connection = MySQLConnection.getConnection(); PreparedStatement preparedStatement = connection.prepareStatement(sql)) { preparedStatement.setString(1, "parameter_value"); ResultSet resultSet = preparedStatement.executeQuery(); // 处理查询结果 while (resultSet.next()) { // 处理每一行数据 } } catch (SQLException e) { e.printStackTrace(); } } }
7. 处理异常
在实际应用中，务必处理可能发生的异常。可以使用日志框架如Log4j记录详细的错误信息，便于排查问题。
import org.apache.log4j.Logger; public class MySQLConnection { private static final Logger logger = Logger.getLogger(MySQLConnection.class); public static void main(String[] args) { try (Connection connection = MySQLConnection.getConnection()) { // 在这里执行数据库操作 } catch (SQLException e) { logger.error("数据库操作发生异常", e); } } }
8. 总结
通过以上的最优JDBC连接MySQL数据库的代码实例，相信你已经对如何编写简洁、高效的数据库连接代码有了更深入的理解。
