java连接mysql数据库,判断是否连接成功,实现增删改查,需要预处理
时间: 2024-03-13 08:47:22 浏览: 140
java数据库
好的,我会回答你的问题。首先需要导入mysql连接的jar包,然后建立与数据库的连接,判断是否连接成功可以通过getConnection方法返回的连接对象是否为null来判断。接下来,使用PreparedStatement接口实现增删改查操作,可以预防SQL注入攻击。
以下是Java连接MySQL数据库的示例代码:
```java
import java.sql.*;
public class MySQLDemo {
public static void main(String[] args) {
Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
// 加载驱动程序
Class.forName("com.mysql.jdbc.Driver");
// 建立连接
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?serverTimezone=UTC", "root", "root");
// 判断连接是否成功
if (conn != null) {
System.out.println("数据库连接成功");
} else {
System.out.println("数据库连接失败");
}
// 实现增删改查
String sql = "insert into user(name,age) values(?,?)";
ps = conn.prepareStatement(sql);
ps.setString(1, "Tom");
ps.setInt(2, 20);
ps.executeUpdate();
sql = "select * from user";
ps = conn.prepareStatement(sql);
rs = ps.executeQuery();
while (rs.next()) {
System.out.println(rs.getInt("id") + " " + rs.getString("name") + " " + rs.getInt("age"));
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
if (rs != null)
rs.close();
if (ps != null)
ps.close();
if (conn != null)
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
```
上述代码中,我们首先加载了MySQL驱动程序,然后建立了与数据库test的连接。然后使用PreparedStatement接口实现了插入一条数据和查询所有数据的操作,并使用了setXXX方法设置占位符的值。最后,我们关闭了ResultSet、PreparedStatement和Connection对象,释放了资源。
希望我的回答能帮到你,如果还有其他问题可以继续问我哦。
阅读全文