数据库管理
更新时间:2026-08-06
数据库管理
修改数据库端口
使用以下代码可以修改数据库端口
Go
1// import "github.com/baidubce/bce-sdk-go/services/rds"
2args := &rds.UpdateDatabasePortArgs{
3 EntryPort: 3309,
4})
5err := client.UpdateDatabasePort(instanceId, args)
6if err != nil {
7 fmt.Printf("update database port error: %+v\n", err)
8 return
9}
10fmt.Printf("update database port success\n")
获取数据库列表
使用以下代码可以获取数据库列表
Go
1// import "github.com/baidubce/bce-sdk-go/services/rds"
2result, err := client.ListDatabases(instanceId)
3if err != nil {
4 fmt.Printf("get database list error: %+v\n", err)
5 return
6}
7fmt.Printf("get database list success\n")
8jsonData, _ := json.Marshal(result)
9fmt.Println(string(jsonData))
修改数据库描述
使用以下代码可以修改数据库描述
Go
1// import "github.com/baidubce/bce-sdk-go/services/rds"
2args := &rds.ModifyDatabaseDesc{
3 Remark: "test",
4}
5err := client.ModifyDatabaseDesc(instanceId, "test_db", args)
6if err != nil {
7 fmt.Printf("modify database discription error: %+v\n", err)
8 return
9}
10fmt.Printf("modify database discriptio success\n")
删除数据库
使用以下代码可以删除数据库
Go
1// import "github.com/baidubce/bce-sdk-go/services/rds"
2
3err := client.DeleteDatabase(instanceId, "test_db")
4if err != nil {
5 fmt.Printf("delete database error: %+v\n", err)
6 return
7}
8fmt.Printf("delete database success\n")
创建数据库
使用以下代码可以创建数据库
Go
1// import "github.com/baidubce/bce-sdk-go/services/rds"
2args := &rds.CreateDatabaseArgs{
3 CharacterSetName: "utf8",
4 DbName: "test_db",
5 Remark: "test_db",
6 AccountPrivileges: []AccountPrivilege{
7 {
8 AccountName: "baidu",
9 AuthType: "ReadOnly",
10 },
11 },
12}
13err := client.CreateDatabase(instanceId, args)
14if err != nil {
15 fmt.Printf("create database error: %+v\n", err)
16 return
17}
18fmt.Printf("create database success\n")
修改数据库 CDC 状态
接口描述:批量开启或关闭 SQL Server 实例中指定数据库的 CDC 功能。该操作异步执行。
请求方式:POST
请求 URI:/v1/rds/instance/{instanceId}/databases/cdc
请求体参数:
| 参数 | 类型 | 必填 | 说明 |
|---|---|---|---|
| dbNames | []string | 是 | 待修改的数据库名称列表 |
| modifyType | string | 是 | 修改类型,enable 为开启,disable 为关闭 |
返回结果:ModifyDatabaseCdcResult,包含异步任务 ID taskId。
Go
1args := &rds.ModifyDatabaseCdcArgs{
2 DbNames: []string{"db1", "db2"},
3 ModifyType: "enable",
4}
5result, err := client.ModifyDatabaseCdc(instanceId, args)
6if err != nil {
7 return err
8}
9fmt.Println(result.TaskId)
数据库列表返回对象 Database 同时新增 cdcEnabled 字段,用于表示 CDC 是否已开启。
评价此篇文章
