1. 介绍
GaussDB(for MySQL)是华为自研的最新一代企业级高扩展海量存储分布式数据库,完全兼容MySQL。基于华为最新一代DFV存储,采用计算存储分离架构,128TB的海量存储,无需分库分表,数据0丢失,既拥有商业数据库的高可用和性能,又具备开源低成本效益。本示例展示如何通过java版本的SDK方式查询和创建数据库用户。
2.流程图

3. 前置条件
2.获取华为云开发工具包(SDK),您也可以查看安装JAVA SDK。
3.已获取华为云账号对应的Access Key(AK)和Secret Access Key(SK)。请在华为云控制台“我的凭证 > 访问密钥”页面上创建和查看您的AK/SK。具体请参见 访问密钥 。
4.已具备开发环境 ,支持Java JDK 1.8及其以上版本。
4. SDK获取和安装
您可以通过Maven方式获取和安装SDK,首先需要在您的操作系统中下载并安装Maven ,安装完成后您只需要在Java项目的pom.xml文件中加入相应的依赖项即可。
具体的SDK版本号请参见 SDK开发中心 。
<dependency>
<groupId>com.huaweicloud.sdk</groupId>
<artifactId>huaweicloud-sdk-gaussdb</artifactId>
<version>3.1.1</version>
</dependency>
5.关键代码片段
以下代码展示如何使用SDK查询和创建数据库用户:
public class DatabaseUserDemo {
private static final Logger logger = LoggerFactory.getLogger(DatabaseUserDemo.class.getName());
public static void main(String[] args) {
String ak = "<YOUR AK>";
String sk = "<YOUR SK>";
String instanceId = "<YOUR INSTANCE_ID>";
String regionId = "<YOUR REGION_ID>";
ICredential auth = new BasicCredentials()
.withAk(ak)
.withSk(sk);
GaussDBClient client = GaussDBClient.newBuilder()
.withCredential(auth)
.withRegion(GaussDBRegion.valueOf(regionId))
.build();
// 查询数据库用户
listDatabaseUser(client, instanceId);
// 数据库用户名称和密码
String username = "<Your USER_NAME>";
String password = "<YOUR PASSWORD>";
// 创建数据库用户
createDatabaseUser(client, instanceId, username, password);
//查询数据库用户
listDatabaseUser(client, instanceId);
}
private static void listDatabaseUser(GaussDBClient client, String instanceId) {
ListGaussMySqlDatabaseUserRequest request = new ListGaussMySqlDatabaseUserRequest();
request.withInstanceId(instanceId);
try {
ListGaussMySqlDatabaseUserResponse response = client.listGaussMySqlDatabaseUser(request);
logger.info(response.toString());
} catch (ConnectionException e) {
logger.error("ConnectionException", e);
} catch (RequestTimeoutException e) {
logger.error("RequestTimeoutException ", e);
} catch (ServiceResponseException e) {
logger.error("httpStatusCode: {}, errorCode: {}, errorMsg: {}", e.getHttpStatusCode(), e.getErrorCode(), e.getErrorMsg());
}
}
private static void createDatabaseUser(GaussDBClient client, String instanceId, String username, String password) {
CreateGaussMySqlDatabaseUserRequest request = new CreateGaussMySqlDatabaseUserRequest();
CreateDatabaseUserRequest body = new CreateDatabaseUserRequest();
CreateDatabaseUserList users = new CreateDatabaseUserList().
withName(username).
withPassword(password);
body.withUsers(Collections.singletonList(users));
request.withInstanceId(instanceId);
request.withBody(body);
try {
CreateGaussMySqlDatabaseUserResponse response = client.createGaussMySqlDatabaseUser(request);
logger.info(response.toString());
} catch (ConnectionException e) {
logger.error("ConnectionException", e);
} catch (RequestTimeoutException e) {
logger.error("RequestTimeoutException ", e);
} catch (ServiceResponseException e) {
logger.error("httpStatusCode: {}, errorCode: {}, errorMsg: {}", e.getHttpStatusCode(), e.getErrorCode(), e.getErrorMsg());
}
}
}
6.返回结果示例
- 查询数据库用户(ListGaussMySqlDatabaseUser)接口的返回值:
class ListGaussMySqlDatabaseUserResponse {
users: [class ListGaussMySqlDatabaseUser {
name: user_test_1
host: 127.0.0.1
databases: []
}]
totalCount: 1
}
- 创建数据库用户(CreateGaussMySqlDatabaseUser)接口的返回值:
class CreateGaussMySqlDatabaseUserResponse {
jobId: f725af33-af02-48af-a5e4-8197e8515372
}
- 查看数据库用户(ListGaussMySqlDatabaseUser)接口的返回值:
class ListGaussMySqlDatabaseUserResponse {
users: [class ListGaussMySqlDatabaseUser {
name: user_test_1
host: 127.0.0.1
databases: []
}, class ListGaussMySqlDatabaseUser {
name: user_test_2
host: %
databases: []
}]
totalCount: 2
}
7.参考链接
请见 查询数据库用户API 您可以在 API Explorer 中直接运行调试该接口。
请见 创建数据库用户API 您可以在 API Explorer 中直接运行调试该接口。
修订记录
| 发布日期 | 文档版本 | 修订说明 |
|---|---|---|
| 2022-09-19 | 1.0 | 文档首次发布 |