MySql数据库访问程序代码

import java.sql.*;

public class MySQLAccess {
  private Connection connect = null;
  private Statement statement = null;
  private ResultSet resultSet = null;

  public void readDataBase() throws Exception {
    try {
      // 连接到MySQL数据库
      Class.forName("com.mysql.jdbc.Driver");
      connect = DriverManager.getConnection("jdbc:mysql://localhost/database_name", "username", "password");

      // 执行SQL查询
      statement = connect.createStatement();
      resultSet = statement.executeQuery("SELECT * FROM table_name");

      // 处理查询结果
      while (resultSet.next()) {
        String column1 = resultSet.getString("column1");
        String column2 = resultSet.getString("column2");
        // 其他操作...
      }
    } catch (Exception e) {
      throw e;
    } finally {
      // 关闭连接和资源
      close();
    }
  }

  private void close() {
    try {
      if (resultSet != null) {
        resultSet.close();
      }
      if (statement != null) {
        statement.close();
      }
      if (connect != null) {
        connect.close();
      }
    } catch (Exception e) {
      // 处理异常
    }
  }
}