java连接mysql数据库实现增删改查操作
时间: 2024-02-06 08:00:57 浏览: 95
Java连接MySQL数据库可以通过JDBC(Java Database Connectivity)实现。下面是一个简单的示例代码来进行增删改查操作:
1. 导入必要的包:
import java.sql.*;
2. 创建数据库连接:
String url = "jdbc:mysql://localhost:3306/mydatabase"; // 修改为你的数据库信息
String username = "root"; // 修改为你的数据库用户名
String password = "password"; // 修改为你的数据库密码
try {
Connection connection = DriverManager.getConnection(url, username, password);
} catch (SQLException e) {
e.printStackTrace();
}
3. 插入数据:
String insertQuery = "INSERT INTO table_name (column1, column2, column3) VALUES (?, ?, ?)"; // 修改为你的表名和字段名
try {
PreparedStatement statement = connection.prepareStatement(insertQuery);
statement.setString(1, "value1"); // 修改为要插入的值
statement.setString(2, "value2");
statement.setString(3, "value3");
statement.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}
4. 删除数据:
String deleteQuery = "DELETE FROM table_name WHERE column1 = ?"; // 修改为你的表名和字段名
try {
PreparedStatement statement = connection.prepareStatement(deleteQuery);
statement.setString(1, "value1"); // 修改为要删除的值
statement.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}
5. 更新数据:
String updateQuery = "UPDATE table_name SET column1 = ? WHERE column2 = ?"; // 修改为你的表名和字段名
try {
PreparedStatement statement = connection.prepareStatement(updateQuery);
statement.setString(1, "new value"); // 修改为要更新的值
statement.setString(2, "value2");
statement.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}
6. 查询数据:
String selectQuery = "SELECT * FROM table_name"; // 修改为你的表名
try {
Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery(selectQuery);
while (resultSet.next()) {
String column1 = resultSet.getString("column1"); // 修改为你的表的字段名
String column2 = resultSet.getString("column2");
String column3 = resultSet.getString("column3");
System.out.println(column1 + " " + column2 + " " + column3);
}
} catch (SQLException e) {
e.printStackTrace();
}
这是一个简单的示例代码,你可以根据你的实际需求进行适当的修改和优化。
阅读全文