阅读量:0
import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; public class MySQLQueryExample { public static void main(String[] args) { // 数据库连接参数 String url = "jdbc:mysql://localhost:3306/your_database_name"; // 数据库URL String user = "your_username"; // 数据库用户名 String password = "your_password"; // 数据库密码 String query = "SELECT * FROM your_table_name WHERE your_column_name = ?"; // SQL查询语句,?为参数占位符 // 加载数据库驱动 try { Class.forName("com.mysql.cj.jdbc.Driver"); } catch (ClassNotFoundException e) { System.out.println("MySQL JDBC Driver not found."); e.printStackTrace(); return; } // 建立数据库连接 try (Connection connection = DriverManager.getConnection(url, user, password); // 创建PreparedStatement对象 PreparedStatement preparedStatement = connection.prepareStatement(query)) { // 设置参数值 preparedStatement.setString(1, "参数值"); // 根据实际情况设置参数值 // 执行查询 ResultSet resultSet = preparedStatement.executeQuery(); // 处理结果集 while (resultSet.next()) { // 根据实际情况获取数据 // String columnNameValue = resultSet.getString("column_name"); System.out.println("Data retrieved from the database."); } } catch (SQLException e) { System.out.println("Database connection failed."); e.printStackTrace(); } } }
代码说明:
1、数据库连接参数:需要替换为你的数据库URL、用户名、密码以及查询的表名和列名。
2、加载数据库驱动:使用Class.forName()
方法加载MySQL JDBC驱动。
3、建立数据库连接:使用DriverManager.getConnection()
方法连接到数据库。
4、创建PreparedStatement对象:使用SQL查询语句和参数占位符创建PreparedStatement
对象。
5、设置参数值:使用setString()
等方法设置查询参数的值。
6、执行查询:调用executeQuery()
方法执行查询并返回结果集。
7、处理结果集:遍历结果集并获取所需的数据。
8、异常处理:使用trywithresources语句自动关闭资源,并捕获可能的SQLException
。