Database

MongoDB, MySQL, PostgreSQL, and Redis database operations.

9 modules

Module	Description
Inserir no Banco de Dados	Inserir dados em tabelas de banco de dados
Consulta de Banco de Dados	Executar consultas SQL em bancos de dados PostgreSQL, MySQL ou SQLite
Atualizar Banco de Dados	Atualizar dados em tabelas de banco de dados
MongoDB Find	Consultar documentos de colecao MongoDB
MongoDB Insert	Inserir um ou mais documentos em colecao MongoDB
Consulta MySQL	Executar consulta SQL no banco de dados MySQL e retornar resultados
Consulta PostgreSQL	Executar consulta SQL no banco de dados PostgreSQL e retornar resultados
Redis Get	Obter valor do cache Redis
Redis Set	Definir valor no cache Redis

Modules

Inserir no Banco de Dados

database.insert

Inserir dados em tabelas de banco de dados

Parameters:

Name	Type	Required	Default	Description
table	string	Yes	-	Name of the table
data	object	Yes	-	Data to insert or update
database_type	select (postgresql, mysql, sqlite)	No	postgresql	Database type to connect to
connection_string	string	No	-	Database connection string
host	string	No	-	Database host
port	number	No	-	Database port
database	string	No	-	Database name
user	string	No	-	Database username
password	string	No	-	Database password
returning	array	No	-	Columns to return after insert (PostgreSQL)

Output:

Field	Type	Description
inserted_count	number	Numero de linhas inseridas
returning_data	array	Numero de linhas inseridas

Example: Insert single row

table: users
data: {"name": "John", "email": "john@example.com"}
database_type: postgresql

Consulta de Banco de Dados

database.query

Executar consultas SQL em bancos de dados PostgreSQL, MySQL ou SQLite

Parameters:

Name	Type	Required	Default	Description
query	string	Yes	-	SQL query to execute
params	array	No	[]	Parameters for parameterized queries (prevents SQL injection)
database_type	select (postgresql, mysql, sqlite)	No	postgresql	Database type to connect to
connection_string	string	No	-	Database connection string
host	string	No	-	Database host
port	number	No	-	Database port
database	string	No	-	Database name
user	string	No	-	Database username
password	string	No	-	Database password
fetch	select (all, one, none)	No	all	How many rows to return from the query

Output:

Field	Type	Description
rows	array	Linhas do resultado da consulta
row_count	number	Linhas do resultado da consulta
columns	array	Linhas do resultado da consulta

Example: Select with parameters

query: SELECT * FROM users WHERE status = $1
params: ["active"]
database_type: postgresql

Atualizar Banco de Dados

database.update

Atualizar dados em tabelas de banco de dados

Parameters:

Name	Type	Required	Default	Description
table	string	Yes	-	Name of the table
data	object	Yes	-	Data to insert or update
where	object	Yes	-	WHERE conditions (column: value for equality)
database_type	select (postgresql, mysql, sqlite)	No	postgresql	Database type to connect to
connection_string	string	No	-	Database connection string
host	string	No	-	Database host
port	number	No	-	Database port
database	string	No	-	Database name
user	string	No	-	Database username
password	string	No	-	Database password

Output:

Field	Type	Description
updated_count	number	Numero de linhas atualizadas

Example: Update user status

table: users
data: {"status": "active"}
where: {"id": 123}
database_type: postgresql

MongoDB Find

db.mongodb.find

Consultar documentos de colecao MongoDB

Parameters:

Name	Type	Required	Default	Description
connection_string	string	No	-	MongoDB connection string (defaults to env.MONGODB_URL)
database	string	Yes	-	Database name
collection	string	Yes	-	Collection name
filter	object	No	{}	MongoDB query filter (empty object {} returns all)
projection	object	No	-	Fields to include/exclude in results
limit	number	No	100	Maximum number of documents to return
sort	object	No	-	Sort order (1 for ascending, -1 for descending)

Output:

Field	Type	Description
documents	array	Array de documentos correspondentes
count	number	Array de documentos correspondentes

Example: Find all active users

database: myapp
collection: users
filter: {"status": "active"}
limit: 50

Example: Find with projection and sort

database: myapp
collection: orders
filter: {"total": {"$gt": 100}}
projection: {"_id": 0, "order_id": 1, "total": 1, "created_at": 1}
sort: {"created_at": -1}
limit: 20

MongoDB Insert

db.mongodb.insert

Inserir um ou mais documentos em colecao MongoDB

Parameters:

Name	Type	Required	Default	Description
connection_string	string	No	-	MongoDB connection string (defaults to env.MONGODB_URL)
database	string	Yes	-	Database name
collection	string	Yes	-	Collection name
document	object	No	-	Document to insert (for single insert)
documents	array	No	-	Array of documents to insert (for bulk insert)

Output:

Field	Type	Description
inserted_count	number	Numero de documentos inseridos
inserted_ids	array	Numero de documentos inseridos

Example: Insert single document

database: myapp
collection: users
document: {"name": "John Doe", "email": "john@example.com", "created_at": "${timestamp}"}

Example: Insert multiple documents

database: myapp
collection: products
documents: [{"name": "Product A", "price": 19.99}, {"name": "Product B", "price": 29.99}]

Consulta MySQL

db.mysql.query

Executar consulta SQL no banco de dados MySQL e retornar resultados

Parameters:

Name	Type	Required	Default	Description
host	string	No	-	Database host
port	number	No	3306	Database port
user	string	No	-	Database username
password	string	No	-	Database password
database	string	No	-	Database name
query	string	Yes	-	SQL query to execute
params	array	No	[]	Parameters for parameterized queries (prevents SQL injection)

Output:

Field	Type	Description
rows	array	Array de linhas de resultado como objetos
row_count	number	Array de linhas de resultado como objetos
columns	array	Array de linhas de resultado como objetos

Example: Select products

query: SELECT id, name, price FROM products WHERE stock > 0 ORDER BY price DESC LIMIT 20

Example: Parameterized query

query: SELECT * FROM orders WHERE customer_id = %s AND created_at > %s
params: ["${customer_id}", "2024-01-01"]

Consulta PostgreSQL

db.postgresql.query

Executar consulta SQL no banco de dados PostgreSQL e retornar resultados

Parameters:

Name	Type	Required	Default	Description
connection_string	string	No	-	Database connection string
query	string	Yes	-	SQL query to execute
params	array	No	[]	Parameters for parameterized queries (prevents SQL injection)

Output:

Field	Type	Description
rows	array	Array de linhas de resultado como objetos
row_count	number	Array de linhas de resultado como objetos
columns	array	Array de linhas de resultado como objetos

Example: Select users

query: SELECT id, email, created_at FROM users WHERE active = true LIMIT 10

Example: Parameterized query

query: SELECT * FROM orders WHERE user_id = $1 AND status = $2
params: ["${user_id}", "completed"]

Redis Get

db.redis.get

Obter valor do cache Redis

Parameters:

Name	Type	Required	Default	Description
key	string	Yes	-	Redis key
host	string	No	-	Redis host (from env.REDIS_HOST or explicit)
port	number	No	6379	Redis port
db	number	No	0	Redis database number

Output:

Field	Type	Description
value	any	O valor retornado
exists	boolean	O valor retornado
key	string	O valor retornado

Example: Get cached value

key: user:123:profile
host: ${env.REDIS_HOST}

Example: Get from remote Redis

key: session:abc
host: redis.example.com
port: 6379
db: 1

Redis Set

db.redis.set

Definir valor no cache Redis

Parameters:

Name	Type	Required	Default	Description
key	string	Yes	-	Redis key
value	any	Yes	-	Value to store
ttl	number	No	-	Time to live in seconds (optional)
host	string	No	-	Redis host (from env.REDIS_HOST or explicit)
port	number	No	6379	Redis port
db	number	No	0	Redis database number

Output:

Field	Type	Description
success	boolean	Whether the operation completed successfully
key	string	Key identifier

Example: Cache user profile

key: user:123:profile
value: {"name": "John", "email": "john@example.com"}
ttl: 3600

Example: Set session data

key: session:abc
value: active
ttl: 1800
host: redis.example.com