Java连接MySQL工具类
时间: 2023-10-22 21:08:04 浏览: 45
以下是一个简单的Java连接MySQL的工具类,可以用来连接MySQL数据库并执行SQL查询和更新操作:
```java
import java.sql.*;
public class MySQLUtils {
private Connection conn = null;
private Statement stmt = null;
// 连接数据库
public void connect(String url, String username, String password) {
try {
Class.forName("com.mysql.cj.jdbc.Driver");
conn = DriverManager.getConnection(url, username, password);
stmt = conn.createStatement();
} catch (Exception e) {
e.printStackTrace();
}
}
// 查询操作
public ResultSet query(String sql) {
try {
return stmt.executeQuery(sql);
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
// 更新操作
public int update(String sql) {
try {
return stmt.executeUpdate(sql);
} catch (Exception e) {
e.printStackTrace();
return -1;
}
}
// 关闭连接
public void close() {
try {
if (stmt != null) stmt.close();
if (conn != null) conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
```
使用示例:
```java
MySQLUtils mysql = new MySQLUtils();
mysql.connect("jdbc:mysql://localhost:3306/test", "root", "123456");
// 执行查询操作
ResultSet rs = mysql.query("SELECT * FROM users");
while (rs.next()) {
System.out.println(rs.getInt("id") + " " + rs.getString("name"));
}
// 执行更新操作
int result = mysql.update("UPDATE users SET name='Tom' WHERE id=1");
System.out.println("Update result: " + result);
mysql.close();
```
需要注意:
1. 需要导入MySQL的JDBC驱动包,可以从MySQL官网下载;
2. MySQL连接字符串的格式为:jdbc:mysql://[host][:port]/[database][?参数名1=参数值1&参数名2=参数值2...];
3. 连接成功后,需要创建一个Statement对象来执行SQL操作;
4. 执行查询操作时,使用ResultSet对象来获取结果集;
5. 执行更新操作时,返回更新的行数。