java 对MySQL数据库的链接读写的代码
时间: 2024-03-02 11:50:37 浏览: 22
以下是一个完整的 Java 程序示例,演示了如何链接 MySQL 数据库并进行一些基本的读写操作:
```java
import java.sql.*;
public class MySQLExample {
public static void main(String[] args) {
String url = "jdbc:mysql://localhost:3306/mydatabase";
String user = "root";
String password = "mypassword";
try {
Connection conn = DriverManager.getConnection(url, user, password);
// 创建一个 Statement 对象
Statement stmt = conn.createStatement();
// 创建一个表
String createTableSql = "CREATE TABLE IF NOT EXISTS mytable (id INT NOT NULL AUTO_INCREMENT, column1 VARCHAR(45) NOT NULL, column2 VARCHAR(45) NOT NULL, PRIMARY KEY (id))";
stmt.executeUpdate(createTableSql);
// 插入数据
String insertSql = "INSERT INTO mytable (column1, column2) VALUES ('value1', 'value2')";
stmt.executeUpdate(insertSql);
// 执行查询语句
ResultSet rs = stmt.executeQuery("SELECT * FROM mytable");
// 遍历结果集并输出结果
while (rs.next()) {
System.out.println(rs.getString("column1") + ", " + rs.getString("column2"));
}
// 执行更新语句
int rows = stmt.executeUpdate("UPDATE mytable SET column1 = 'newvalue' WHERE column2 = 'value2'");
System.out.println(rows + " rows updated.");
// 删除数据
String deleteSql = "DELETE FROM mytable WHERE column2 = 'value2'";
stmt.executeUpdate(deleteSql);
// 删除表
String dropTableSql = "DROP TABLE IF EXISTS mytable";
stmt.executeUpdate(dropTableSql);
// 关闭连接
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
```
在这个示例中,我们使用 `DriverManager.getConnection()` 方法来链接 MySQL 数据库。然后,我们创建一个 `Statement` 对象来执行 SQL 语句。首先,我们创建一个表,然后插入数据。接着,我们执行一个查询语句,遍历结果集并输出结果。然后,我们执行一个更新语句,并输出受影响的行数。最后,我们删除数据和表,并使用 `Connection` 对象的 `close()` 方法关闭连接。