Database

MongoDB, MySQL, PostgreSQL, and Redis database operations.

9 modules

Module	Description
Insertar en base de datos	Insertar datos en tablas de base de datos
Consulta de base de datos	Ejecutar consultas SQL en bases de datos PostgreSQL, MySQL o SQLite
Actualizar base de datos	Actualizar datos en tablas de base de datos
MongoDB buscar	Consultar documentos de coleccion MongoDB
MongoDB insertar	Insertar uno o mas documentos en coleccion MongoDB
Consulta MySQL	Ejecutar una consulta SQL en base de datos MySQL y devolver resultados
Consulta PostgreSQL	Ejecutar una consulta SQL en base de datos PostgreSQL y devolver resultados
Redis obtener	Obtener un valor de cache Redis
Redis establecer	Establecer un valor en cache Redis

Modules

Insertar en base de datos

database.insert

Insertar datos en tablas de base de datos

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 filas insertadas
returning_data	array	Numero de filas insertadas

Example: Insert single row

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

Consulta de base de datos

database.query

Ejecutar consultas SQL en bases de datos PostgreSQL, MySQL o 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	Filas de resultado de consulta
row_count	number	Filas de resultado de consulta
columns	array	Filas de resultado de consulta

Example: Select with parameters

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

Actualizar base de datos

database.update

Actualizar datos en tablas de base de datos

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 filas actualizadas

Example: Update user status

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

MongoDB buscar

db.mongodb.find

Consultar documentos de coleccion 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 coincidentes
count	number	Array de documentos coincidentes

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 insertar

db.mongodb.insert

Insertar uno o mas documentos en coleccion 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 insertados
inserted_ids	array	Numero de documentos insertados

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

Ejecutar una consulta SQL en base de datos MySQL y devolver 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 filas de resultado como objetos
row_count	number	Array de filas de resultado como objetos
columns	array	Array de filas 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

Ejecutar una consulta SQL en base de datos PostgreSQL y devolver 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 filas de resultado como objetos
row_count	number	Array de filas de resultado como objetos
columns	array	Array de filas 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 obtener

db.redis.get

Obtener un valor de 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	El valor devuelto
exists	boolean	El valor devuelto
key	string	El valor devuelto

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 establecer

db.redis.set

Establecer un valor en 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