This module expose helper functions
var db_handler_instance = require("oute-services-db-handler-sdk")
- Get client for db connection
state = {}
db_config = {db_type: "postgres", configs: []}
options = {logging: false} //additional options
await db_handler_instance.getClient(state, db_config, options)
- Execute query on the client
query = "select 1 as const"
db_options = {logging: false}
query_options = {type: "SELECT"}
db_config = {db_type: "postgres", configs: []}
state = {}
client_info = await db_handler_instance.getClient(state, db_config)
await db_handler_instance.executeQuery(client_info?.db_client, client_info?.db_type, query, options)
state = {}
db_config = {db_type: "postgres", configs: []}
client_info = await db_handler_instance.getClient(state, db_config)
await db_handler_instance.disconnect(client_info?.db_client, client_info?.db_type)
state = {}
db_config = {db_type: "postgres", configs: []}
options = {logging: false} //additional options
model_dir = __dirname + "/models" //schema name will auto append to this path
sync_info = await db_handler_instance.syncDbModel(state, db_config, options, model_dir)
state = {}
db_config = {}
table_config = {}
fields_config = []
options = {type: "SELECT", logging: false}
client_info = await db_handler_instance.getClient(state, db_config, options)
model_info = await db_handler_instance.getModel(client_info?.db_client, client_info?.orm_type, client_info?.orm_misc?.data_types, client_info?.db_type, table_config, fields_config)
orm_type = "sequelize"
instance = sequelize.define('users', {})
data = {user_id: 1}
await db_handler_instance.crud.insert(orm_type, instance, data)
orm_type = "sequelize"
instance = sequelize.define('users', {})
options = { where: {"user_id": "s1"}}
await db_handler_instance.crud.find(orm_type, instance, options)
orm_type = "sequelize"
instance = sequelize.define('users', {})
update = {first_name: "update"}
options = { where: {"user_id": "s1"}}
await db_handler_instance.crud.updateMany(orm_type, instance, update, options)
orm_type = "sequelize"
instance = sequelize.define('users', {})
options = { where: {"user_id": "s1"}}
await db_handler_instance.crud.deleteMany(orm_type, instance, options)