在Java中连接数据库并执行查询语句可以通过JDBC API实现。下面将详细介绍如何使用Java连接数据库并执行查询语句。
在开始之前,需要做好以下准备工作:
在开始之前,需要在MySQL中创建一个数据库和一个表:
CREATE DATABASE test; USE test; CREATE TABLE user ( id INT PRIMARY KEY AUTO_INCREMENT, name VARCHAR(50) NOT NULL, age INT NOT NULL);
向表中插入数据:
INSERT INTO user (name, age) VALUES ('张三', 25); INSERT INTO user (name, age) VALUES ('李四', 30); INSERT INTO user (name, age) VALUES ('王五', 35);
在代码中需要导入相关的依赖,同时需要使用驱动管理器加载不同数据库的驱动。JDBC的连接和执行都是通过Connection、Statement和ResultSet等接口实现的。
<dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>8.0.26</version> </dependency>
在Java代码中,需要完成以下几个步骤:
这些步骤分别对应了下面的代码。
import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; public class DatabaseConnector { public static void main(String[] args) throws Exception { // 加载数据库驱动 Class.forName("com.mysql.cj.jdbc.Driver"); // 建立连接 String url = "jdbc:mysql://localhost:3306/test?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC"; String user = "root"; String password = "123456"; Connection conn = DriverManager.getConnection(url, user, password); // 创建 Statement 对象 Statement stmt = conn.createStatement(); // 执行 SQL 查询语句 String sql = "SELECT * FROM user"; ResultSet rs = stmt.executeQuery(sql); // 处理结果集 while (rs.next()) { int id = rs.getInt("id"); String name = rs.getString("name"); int age = rs.getInt("age"); System.out.println("ID: " + id + ", Name: " + name + ", Age: " + age); } // 关闭资源 rs.close(); stmt.close(); conn.close(); } }
ID: 1, Name: 张三, Age: 25 ID: 2, Name: 李四, Age: 30 ID: 3, Name: 王五, Age: 35
通过Java连接数据库并执行查询语句,可以实现通过代码访问数据库的功能。而在实际项目中,往往需要实现更加复杂的操作,如增加、修改、删除数据等。这些操作,都可以通过JDBC API实现。
感谢您的阅读,如果您对本文有所收获,请不要吝啬您的赞和分享,同时您还可以给我们留言评论来反馈您的意见和建议。
关注更多优质技术文章,请关注我们的公众号。