在AnyLogic中,可以使用Java的JDBC(Java Database Connectivity)来连接分布式数据库。以下是一个使用JDBC连接分布式数据库的示例代码:
import java.sql.*;
public class DatabaseConnectionExample {
public static void main(String[] args) {
Connection connection = null;
Statement statement = null;
try {
// 1. 加载数据库驱动
Class.forName("com.mysql.jdbc.Driver");
// 2. 设置数据库连接信息
String url = "jdbc:mysql://localhost:3306/database_name";
String username = "username";
String password = "password";
// 3. 建立数据库连接
connection = DriverManager.getConnection(url, username, password);
// 4. 创建Statement对象
statement = connection.createStatement();
// 5. 执行SQL查询
String sql = "SELECT * FROM table_name";
ResultSet resultSet = statement.executeQuery(sql);
// 6. 处理查询结果
while (resultSet.next()) {
// 处理每一行记录
int id = resultSet.getInt("id");
String name = resultSet.getString("name");
// 其他字段...
// 输出结果
System.out.println("ID: " + id + ", Name: " + name);
}
// 7. 关闭ResultSet、Statement和Connection
resultSet.close();
statement.close();
connection.close();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
// 8. 清理资源
try {
if (statement != null) statement.close();
if (connection != null) connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
在上面的示例代码中,需要将url
、username
和password
分别替换为实际的数据库连接信息和凭据。同时,还需要替换SELECT * FROM table_name
为实际的SQL查询语句。
这是一个简单的示例,演示了如何使用JDBC连接分布式数据库并执行查询操作。根据实际情况,您可以根据需要进行修改和扩展。