使用 Java 连接达梦数据库232

达梦数据库是一款优秀的国产数据库管理系统，在国内政企领域有着广泛的应用。对于 Java 开发者来说，可以通过 JDBC 驱动程序来连接达梦数据库，实现数据访问和操作。

添加依赖

在使用 JDBC 驱动程序之前，需要在项目中添加达梦数据库的 JDBC 驱动程序依赖。可以通过 Maven 或 Gradle 等构建工具来添加依赖，具体如下：

dm7-jdbc
7.1.0.0

dependencies {
compile ':dm7-jdbc:7.1.0.0'
}

其中，7.1.0.0 为达梦数据库的驱动程序版本，可以根据实际情况进行调整。

建立连接

添加依赖后，就可以使用 DriverManager 类来建立与达梦数据库的连接。连接的建立需要提供数据库的 URL、用户名和密码，具体如下：
import ;
import ;
public class ConnectExample {
public static void main(String[] args) {
// 达梦数据库的 URL
String url = "jdbc:dm7://localhost:5236/mydb";
// 数据库用户名
String username = "user";
// 数据库密码
String password = "password";
try {
// 建立连接
Connection conn = (url, username, password);
("连接成功！");
} catch (Exception e) {
();
}
}
}

url 参数中指定了数据库的 IP 地址、端口号和数据库名称，username 和 password 参数分别指定了数据库的用户名和密码。如果连接成功，将会输出 "连接成功！"。

执行查询

建立连接后，就可以使用 Statement 类来执行 SQL 查询。Statement 类提供了 executeQuery() 方法，可以执行查询并返回一个 ResultSet 对象，其中包含了查询结果。
import ;
import ;
import ;
import ;
import ;
public class QueryExample {
public static void main(String[] args) {
// 达梦数据库的 URL
String url = "jdbc:dm7://localhost:5236/mydb";
// 数据库用户名
String username = "user";
// 数据库密码
String password = "password";
try {
// 建立连接
Connection conn = (url, username, password);
// 创建 Statement 对象
Statement stmt = ();
// 执行查询
ResultSet rs = ("SELECT * FROM STUDENT");
// 处理查询结果
while (()) {
int id = ("ID");
String name = ("NAME");
(id + " " + name);
}
// 关闭结果集和 Statement 对象
();
();
// 关闭连接
();
} catch (SQLException e) {
();
}
}
}

在这个示例中，Statement 对象执行了 "SELECT * FROM STUDENT" 查询，并将查询结果存储在 ResultSet 对象中。然后，可以通过 next() 方法逐行遍历结果集，并获取每行的列值。

增删改操作

除了查询操作，JDBC 驱动程序还支持增删改等数据操作。可以通过 Statement 对象的 executeUpdate() 方法来执行增删改操作，具体如下：
import ;
import ;
import ;
import ;
public class UpdateExample {
public static void main(String[] args) {
// 达梦数据库的 URL
String url = "jdbc:dm7://localhost:5236/mydb";
// 数据库用户名
String username = "user";
// 数据库密码
String password = "password";
try {
// 建立连接
Connection conn = (url, username, password);
// 创建 Statement 对象
Statement stmt = ();
// 执行更新操作
int count = ("INSERT INTO STUDENT (NAME) VALUES ('示例')");
// 输出更新记录数
("更新 " + count + " 条记录");
// 关闭 Statement 对象
();
// 关闭连接
();
} catch (SQLException e) {
();
}
}
}