数据库操作疑难:Java连接MySQL并进行CRUD操作
在Java中,我们可以使用JDBC(Java Database Connectivity)来连接MySQL并执行CRUD操作。以下是详细的步骤:
添加JDBC驱动:
在你的项目中,可能已经包含了mysql-connector-java.jar。如果没有,你需要通过Maven或Gradle添加到你的依赖管理器。连接数据库:
使用java.sql.DriverManager类的getConnection()方法,传入URL(服务器地址)、用户名和密码。
import java.sql.Connection;
import java.sql.DriverManager;
public class MySQLCRUD {
private static final String JDBC_URL = "jdbc:mysql://localhost:3306/mydatabase";
private static final String USER = "username";
private static final String PASSWORD = "password";
public static void main(String[] args) {
// 连接数据库
Connection connection = DriverManager.getConnection(JDBC_URL, USER, PASSWORD));
// CRUD操作
// 插入(INSERT)
String sqlInsert = "INSERT INTO my_table (column1, column2)) VALUES ('value1', 'value2')";
try (PreparedStatement pstmt = connection.prepareStatement(sqlInsert)) {
pstmt.executeUpdate();
}
// 查询(SELECT)
String sqlSelect = "SELECT * FROM my_table WHERE column1 = 'value1'";
try (ResultSet rs = connection.createStatement().executeQuery(sqlSelect)) {
while (rs.next()) {
System.out.println(rs.getString("column1") + "\t" + rs.getString("column2")));
}
}
// 更新(UPDATE)
String sqlUpdate = "UPDATE my_table SET column2 = 'newvalue' WHERE column1 = 'value1'";
try (PreparedStatement pstmt = connection.prepareStatement(sqlUpdate)) {
pstmt.executeUpdate();
}
// 删除(DELETE)
String sqlDelete = "DELETE FROM my_table WHERE column1 = 'value1'";
try (PreparedStatement pstmt = connection.prepareStatement(sqlDelete)) {
pstmt.executeUpdate();
}
// 关闭连接
if (connection != null) {
connection.close();
}
}
}
这个示例包含了插入(INSERT)、查询(SELECT)、更新(UPDATE)和删除(DELETE)的操作。请确保替换代码中的URL、用户名、密码和表名等信息。
还没有评论,来说两句吧...