java,import java.sql.*;,,public class MySQLConnection {, public static void main(String[] args) {, // JDBC驱动名和数据库URL, String jdbcDriver = "com.mysql.jdbc.Driver";, String dbUrl = "jdbc:mysql://localhost/mydatabase";,, // 数据库用户名和密码, String username = "your_username";, String password = "your_password";,, try {, // 注册JDBC驱动程序, Class.forName(jdbcDriver);,, // 打开数据库连接, Connection conn = DriverManager.getConnection(dbUrl, username, password);,, // 执行查询操作, Statement stmt = conn.createStatement();, ResultSet rs = stmt.executeQuery("SELECT * FROM your_table");,, // 处理结果集, while (rs.next()) {, // 获取数据并输出, int id = rs.getInt("id");, String name = rs.getString("name");, System.out.println("ID: " + id + ", Name: " + name);, },, // 关闭连接, rs.close();, stmt.close();, conn.close();, } catch (Exception e) {, e.printStackTrace();, }, },},
“,,请注意,上述代码中的”mydatabase”、”your_username”、”your_password”和”your_table”需要替换为实际的数据库名称、用户名、密码和表名。还需要确保已将MySQL的JDBC驱动程序添加到项目的类路径中。导入相关依赖
在Java项目中,我们需要导入MySQL的JDBC驱动包,以便能够连接MySQL数据库,可以在项目的pom.xml文件中添加以下依赖:
<dependencies> <!MySQL Connector Java > <dependency> <groupId>mysql</groupId> <artifactId>mysqlconnectorjava</artifactId> <version>8.0.26</version> </dependency> </dependencies>
编写数据库连接工具类
创建一个名为DBUtil
的工具类,用于封装数据库连接的相关操作。
import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class DBUtil { private static final String URL = "jdbc:mysql://localhost:3306/your_database_name?useSSL=false&serverTimezone=UTC"; private static final String USER = "your_username"; private static final String PASSWORD = "your_password"; static { try { Class.forName("com.mysql.cj.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace(); } } public static Connection getConnection() { Connection connection = null; try { connection = DriverManager.getConnection(URL, USER, PASSWORD); } catch (SQLException e) { e.printStackTrace(); } return connection; } }
请将your_database_name
、your_username
和your_password
替换为实际的数据库名称、用户名和密码。
使用数据库连接工具类进行数据库操作
现在我们可以在其他类中使用DBUtil
工具类来获取数据库连接,并进行相应的数据库操作,创建一个名为UserDao
的类,用于操作用户表。
import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; public class UserDao { // 查询所有用户信息 public List<User> findAllUsers() { List<User> userList = new ArrayList<>(); Connection connection = null; PreparedStatement preparedStatement = null; ResultSet resultSet = null; try { connection = DBUtil.getConnection(); String sql = "SELECT * FROM user"; preparedStatement = connection.prepareStatement(sql); resultSet = preparedStatement.executeQuery(); while (resultSet.next()) { int id = resultSet.getInt("id"); String name = resultSet.getString("name"); int age = resultSet.getInt("age"); User user = new User(id, name, age); userList.add(user); } } catch (SQLException e) { e.printStackTrace(); } finally { // 关闭资源 close(resultSet, preparedStatement, connection); } return userList; } // 关闭资源的方法,用于释放数据库连接、预编译语句和结果集等资源 private void close(AutoCloseable... closeables) { for (AutoCloseable closeable : closeables) { if (closeable != null) { try { closeable.close(); } catch (Exception e) { e.printStackTrace(); } } } } }
在这个例子中,我们首先通过DBUtil
工具类获取到数据库连接,然后使用PreparedStatement
执行SQL查询语句,最后将查询结果封装成User
对象并添加到列表中,在操作完成后,需要调用close
方法关闭资源。
原创文章,作者:未希,如若转载,请注明出处:https://www.kdun.com/ask/640796.html
本网站发布或转载的文章及图片均来自网络,其原创性以及文中表达的观点和判断不代表本网站。如有问题,请联系客服处理。
发表回复