import java.sql.*;
public class MyDBase {
private Connection conn;
private Statement stmt;
private ResultSet rs;
public MyDBase() {
// 初始化数据库连接
try {
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
String connectionUrl = "jdbc:sqlserver://localhost;databaseName=MyDatabase;user=myUserName;password=myPassword;";
conn = DriverManager.getConnection(connectionUrl);
stmt = conn.createStatement();
} catch (Exception e) {
e.printStackTrace();
}
}
public ResultSet doQuery(String query) {
try {
rs = stmt.executeQuery(query);
} catch (SQLException e) {
e.printStackTrace();
}
return rs;
}
public int doUpdate(String updateQuery) {
int rowsAffected = 0;
try {
rowsAffected = stmt.executeUpdate(updateQuery);
} catch (SQLException e) {
e.printStackTrace();
}
return rowsAffected;
}
public void close() {
try {
if (rs != null) {
rs.close();
}
if (stmt != null) {
stmt.close();
}
if (conn != null) {
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}这个代码实例提供了一个简单的Java类，用于连接SQL Server数据库，执行查询和更新操作。它使用了JDBC API，并展示了如何处理可能发生的异常。这个类可以作为开发者实现数据库交互的参考。