database
TIP
数据库连接、查询
executeMysqlQuery(code,sql)
Mysql数据库执行查询SQL
| 参数 | 类型 | 作用 | 备注 |
|---|---|---|---|
| code | string | Mysql数据库数据端点编码 | |
| sql | array | 需要执行的SQL |
例:
const queryResult = await api.database.executeMysqlQuery('dNkGMjTekFGrrDNB', 'select * from user');
executeOracleQuery(code,sql[,params])
Oracle数据库执行查询SQL
| 参数 | 类型 | 作用 | 备注 |
|---|---|---|---|
| code | string | Oracle数据库数据端点编码 | |
| sql | array | 需要执行的SQL | |
| params | string | SQL参数 | 可选参数 |
例:
const queryResult = await api.database.executeOracleQuery('dNkGMjTekFGrrDNB', 'select * from user');
const namePar = 'abc'
const codePar = '456'
const queryResult = await api.database.executeOracleQuery
('dNkGMjTekFGrrDNB',
'select * from user where name=:0 and code =:1',
[
namePar,
codePar
]
)
executeOracleUpdate(code, sql, params)
Oracle数据库执行更新SQL
| 参数 | 类型 | 作用 | 备注 |
|---|---|---|---|
| code | string | Oracle数据库数据端点编码 | |
| sql | array | 需要执行的SQL | |
| params | string | SQL参数 | 可选参数 |
例:
const executeUpdate = `insert into test_table(id, name) values(sys_guid(),'test name')`
await api.database.executeOracleUpdate('dNkGMjTekFGrrDNB', executeUpdate)
const executeUpdate = `insert into test_table(id, name) values(:id,:name)`
const data = {
id: '123',
name: 'test name'
}
await api.database.executeOracleUpdate('dNkGMjTekFGrrDNB', executeUpdate, data)
executeOracleUpdateBatch(code, sql, params)
Oracle数据库执行更新批处理SQL
| 参数 | 类型 | 作用 | 备注 |
|---|---|---|---|
| code | string | Oracle数据库数据端点编码 | |
| sql | array | 需要执行的SQL | |
| params | string | SQL参数 | 可选参数 |
例:
const executeUpdate = `insert into test_table(id, name) values(:id,:name)`
const dataList = [
{
id: '123',
name: 'test name'
},
{
id: '456',
name: 'test name2'
}
]
await api.database.executeOracleUpdateBatch('dNkGMjTekFGrrDNB', executeUpdate, dataList)
getMongoConnection(code)
获取Mongo数据库连接
| 参数 | 类型 | 作用 | 备注 |
|---|---|---|---|
| code | string | Mongo数据库数据端点编码 |
例:
const connection = await api.database.getMongoConnection('dNkGMjTekFGrrDNB');
getMssqlInstance (code)
获取Mssql Instance
返回类型:Database Instance
| 参数 | 类型 | 作用 | 备注 |
|---|---|---|---|
| code | string | Mssql数据库数据端点编码 |
例:
const instance = await api.database.getMssqlInstance('dNkGMjTekFGrrDNB')
getMysqlConnection(code)
获取Mysql数据库连接
| 参数 | 类型 | 作用 | 备注 |
|---|---|---|---|
| code | string | Mysql数据库数据端点编码 |
例:
const connection = await api.database.getMysqlConnection('dNkGMjTekFGrrDNB');
getMysqlInstance (code)
获取Mysql Instance
返回类型:Database Instance
| 参数 | 类型 | 作用 | 备注 |
|---|---|---|---|
| code | string | Mysql数据库数据端点编码 |
例:
const instance = await api.database.getMysqlInstance('dNkGMjTekFGrrDNB')
getOracleConnection(code)
获取Oracle数据库连接
| 参数 | 类型 | 作用 | 备注 |
|---|---|---|---|
| code | string | Oracl数据库数据端点编码 |
例:
const connection = await api.database.getOracleConnection('dNkGMjTekFGrrDNB');
getOracleInstance (code)
获取Oracle Instance
返回类型:Database Instance
| 参数 | 类型 | 作用 | 备注 |
|---|---|---|---|
| code | string | Oracle数据库数据端点编码 |
例:
const instance = await api.database.getOracleInstance('dNkGMjTekFGrrDNB')
getPostgresConnection(code)
获取系统Postgres数据库连接
| 参数 | 类型 | 作用 | 备注 |
|---|---|---|---|
| code | string | Postgres数据库数据端点编码 |
例:
const connection = await api.database.getPostgresConnection('dNkGMjTekFGrrDNB');
getPostgresInstance (code)
获取Postgres Instance
返回类型:Database Instance
| 参数 | 类型 | 作用 | 备注 |
|---|---|---|---|
| code | string | Postgres数据库数据端点编码 |
例:
const instance = await api.database.getPostgresInstance('dNkGMjTekFGrrDNB')
getRedisConnection(code)
获取Redis连接
| 参数 | 类型 | 作用 | 备注 |
|---|---|---|---|
| code | string | Redis数据端点编码 |
例:
const connection = await api.database.getRedisConnection('dNkGMjTekFGrrDNB');
getSystemMongoConnection()
获取系统Mongo数据库连接
例:
const connection = await api.database.getSystemMongoConnection();
getSystemRedisConnection()
获取系统Redis数据库连接
返回类型:Redis Instance
例:
const connection = await api.database.getSystemRedisConnection();