DB Structure Tasks

Beyond tables and views, ETLBox gives you tools to manage broader database structures—like schemas, indexes, stored procedures, and entire databases—using the same consistent task-based approach. These tasks help automate setup, teardown, and validation across different database systems.

Database Tasks#

You can use Control Flow Tasks to manage entire databases. These tasks are helpful when your ETL workflow includes provisioning or cleaning up database instances.

CreateDatabaseTask#

Creates a new database or alters it if supported.

CreateDatabaseTask.CreateOrAlter("AnalyticsDB");

DropDatabaseTask#

Drops a database if it exists.

DropDatabaseTask.DropIfExists("AnalyticsDB");

IfDatabaseExistsTask#

Checks if a database exists on the server.

bool exists = IfDatabaseExistsTask.IsExisting("AnalyticsDB");

Note: When creating or checking a database, ensure your connection points to a master or system database, not the one you want to create.

Connecting Without a Catalog#

When creating a database, you often need to connect to the server without referencing the target database—because it doesn’t exist yet. ETLBox provides connection string wrappers that help you get a suitable “master” connection for this scenario.

For example, in PostgreSQL:

var conStringWrapper = new PostgresConnectionString("Server=10.37.128.2;Database=ETLBox_DataFlow;User Id=postgres;Password=etlboxpassword;");
var connectionWithoutCatalog = conStringWrapper.GetMasterConnection();
var connectionManager = new PostgresConnectionManager(connectionWithoutCatalog);

This will connect to the default postgres database instead of ETLBox_DataFlow.

Equivalent behavior applies for:

• SQL Server → connects to master
• MySQL/MariaDB → connects to mysql

Use this pattern whenever you need to create a new database or check its existence.

Schema Tasks#

CreateSchemaTask#

Creates or replaces a schema.

CreateSchemaTask.CreateOrAlter("reporting");

DropSchemaTask#

Drops a schema if it exists.

DropSchemaTask.DropIfExists("reporting");

IfSchemaExistsTask#

Checks if a schema exists.

bool exists = IfSchemaExistsTask.IsExisting("reporting");

Index Tasks#

Index tasks are useful when managing performance optimizations on tables.

CreateIndexTask#

Creates or recreates an index on a table.

CreateIndexTask.CreateOrRecreate("idx_customer_name", "Customer", new List<string> { "Name" });

DropIndexTask#

Drops an index if it exists.

DropIndexTask.DropIfExists("idx_customer_name", "Customer");

IfIndexExistsTask#

Checks if a given index exists on a table.

bool exists = IfIndexExistsTask.IsExisting("idx_customer_name", "Customer");

Procedure Tasks#

Use these tasks to define and manage stored procedures programmatically.

CreateProcedureTask#

Creates or alters a stored procedure.

var parameters = new List<ProcedureParameter> {
    new ProcedureParameter("Par1", "VARCHAR(50)"),
    new ProcedureParameter("Par2", "INT", "0")
};

CreateProcedureTask.CreateOrAlter("MyProcedure", "SELECT 1;", parameters);

DropProcedureTask#

Drops a procedure if it exists.

DropProcedureTask.DropIfExists("MyProcedure");

IfProcedureExistsTask#

Checks if a procedure exists.

bool exists = IfProcedureExistsTask.IsExisting("MyProcedure");