Database

MongoDB, MySQL, PostgreSQL, and Redis database operations.

9 modules

Module	Description
Datenbank-Einfügen	Daten in Datenbanktabellen einfügen
Datenbank-Abfrage	SQL-Abfragen auf PostgreSQL-, MySQL- oder SQLite-Datenbanken ausführen
Datenbank-Update	Daten in Datenbanktabellen aktualisieren
MongoDB-Suche	Dokumente aus MongoDB-Sammlung abfragen
MongoDB-Einfügen	Ein oder mehrere Dokumente in MongoDB-Sammlung einfügen
MySQL-Abfrage	SQL-Abfrage auf MySQL-Datenbank ausführen und Ergebnisse zurückgeben
PostgreSQL-Abfrage	SQL-Abfrage auf PostgreSQL-Datenbank ausführen und Ergebnisse zurückgeben
Redis abrufen	Wert aus Redis-Cache abrufen
Redis setzen	Wert in Redis-Cache setzen

Modules

Datenbank-Einfügen

database.insert

Daten in Datenbanktabellen einfügen

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	Anzahl der eingefügten Zeilen
returning_data	array	Anzahl der eingefügten Zeilen

Example: Insert single row

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

Datenbank-Abfrage

database.query

SQL-Abfragen auf PostgreSQL-, MySQL- oder SQLite-Datenbanken ausführen

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	Abfrageergebniszeilen
row_count	number	Abfrageergebniszeilen
columns	array	Abfrageergebniszeilen

Example: Select with parameters

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

Datenbank-Update

database.update

Daten in Datenbanktabellen aktualisieren

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	Anzahl der aktualisierten Zeilen

Example: Update user status

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

MongoDB-Suche

db.mongodb.find

Dokumente aus MongoDB-Sammlung abfragen

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 von übereinstimmenden Dokumenten
count	number	Array von übereinstimmenden Dokumenten

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-Einfügen

db.mongodb.insert

Ein oder mehrere Dokumente in MongoDB-Sammlung einfügen

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	Anzahl der eingefügten Dokumente
inserted_ids	array	Anzahl der eingefügten Dokumente

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}]

MySQL-Abfrage

db.mysql.query

SQL-Abfrage auf MySQL-Datenbank ausführen und Ergebnisse zurückgeben

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 von Ergebniszeilen als Objekte
row_count	number	Array von Ergebniszeilen als Objekte
columns	array	Array von Ergebniszeilen als Objekte

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"]

PostgreSQL-Abfrage

db.postgresql.query

SQL-Abfrage auf PostgreSQL-Datenbank ausführen und Ergebnisse zurückgeben

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 von Ergebniszeilen als Objekte
row_count	number	Array von Ergebniszeilen als Objekte
columns	array	Array von Ergebniszeilen als Objekte

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 abrufen

db.redis.get

Wert aus Redis-Cache abrufen

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	Der zurückgegebene Wert
exists	boolean	Der zurückgegebene Wert
key	string	Der zurückgegebene Wert

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 setzen

db.redis.set

Wert in Redis-Cache setzen

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