准备工作
1、确保已经安装了Java开发环境(JDK)和数据库(如MySQL)。
2、下载并导入数据库连接驱动(如MySQL Connector/J)。
3、创建一个Java项目,并将数据库连接驱动添加到项目的类路径中。
编写代码
1、导入所需的包:
import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; import java.io.FileWriter; import java.io.IOException;
2、编写一个方法用于连接数据库:
public static Connection getConnection() { Connection connection = null; try { Class.forName("com.mysql.jdbc.Driver"); String url = "jdbc:mysql://localhost:3306/your_database_name?useSSL=false&serverTimezone=UTC"; String user = "your_username"; String password = "your_password"; connection = DriverManager.getConnection(url, user, password); } catch (Exception e) { e.printStackTrace(); } return connection; }
3、编写一个方法用于查询数据库数据:
public static void queryData(Connection connection) { Statement statement = null; ResultSet resultSet = null; try { statement = connection.createStatement(); String sql = "SELECT * FROM your_table_name"; resultSet = statement.executeQuery(sql); while (resultSet.next()) { // 获取并输出数据, int id = resultSet.getInt("id"); String name = resultSet.getString("name"); System.out.println("ID: " + id + ", Name: " + name); } } catch (Exception e) { e.printStackTrace(); } finally { // 关闭资源 try { if (resultSet != null) { resultSet.close(); } if (statement != null) { statement.close(); } } catch (Exception e) { e.printStackTrace(); } } }
4、编写一个方法用于将查询到的数据导出到文件:
public static void exportDataToFile(Connection connection, String filePath) { Statement statement = null; ResultSet resultSet = null; try { statement = connection.createStatement(); String sql = "SELECT * FROM your_table_name"; resultSet = statement.executeQuery(sql); FileWriter fileWriter = new FileWriter(filePath); while (resultSet.next()) { // 获取并输出数据, int id = resultSet.getInt("id"); String name = resultSet.getString("name"); fileWriter.write("ID: " + id + ", Name: " + name + " "); } fileWriter.close(); } catch (Exception e) { e.printStackTrace(); } finally { // 关闭资源 try { if (resultSet != null) { resultSet.close(); } if (statement != null) { statement.close(); } } catch (Exception e) { e.printStackTrace(); } } }
调用方法导出数据并保存到文件
public static void main(String[] args) { Connection connection = getConnection(); // 连接数据库 queryData(connection); // 查询数据并输出到控制台(可选) exportDataToFile(connection, "output.txt"); // 将数据导出到文件(可选) }
原创文章,作者:未希,如若转载,请注明出处:https://www.kdun.com/ask/643242.html
本网站发布或转载的文章及图片均来自网络,其原创性以及文中表达的观点和判断不代表本网站。如有问题,请联系客服处理。
发表回复