MariaDB initial load
Use Database Reader for initial load to create a point-in-time copy of your existing source MariaDB dataset at the target. This establishes a baseline for subsequent continuous updates.
You can leverage Database Reader's parallel processing capabilities to accelerate data loading for large datasets, while the system automatically handles schema creation and data type mapping between MariaDB and target systems. You can configure table selection with wildcard support, create custom SQL queries for selective data extraction, and optimize batch sizes for performance tuning..
When you deploy Database Reader to a Forwarding Agent, you must install the required JDBC driver as described in Install the MariaDB JDBC driver in a Forwarding Agent.
If not using an automatic pipeline wizard, before running the initial load application, see Switching from initial load to continuous replication of MariaDB sources.
MariaDB setup for initial load
In MariaDB, create a user for use by Striim with SELECT privileges on the tables to be read.
Database Reader properties for MariaDB sources
property | type | default value | notes |
|---|---|---|---|
Connection Profile Name | enum | Not applicable to MariaDB in this release. | |
Connection URL | String | When connecting through an SSH tunnel (see Using an SSH tunnel to connect to a source or target), specify the IP address of the tunnel. for MariaDB: for MariaDB Galera Cluster: specify the IP address and port for each server in the cluster, separated by commas: | |
Create Schema | Boolean | False | If set to True, when Database Reader's output stream is the input stream of an Azure Synapse Writer, BigQuery Writer, Database Writer (for MariaDB, MariaDB Xpand, MySQL, Oracle, PostgreSQL, SQL Server, or YugabyteDB only), Databricks Writer, Fabric Data Warehouse Writer, Fabric Mirror Writer, Iceberg Writer, Snowflake Writer, or Spanner Writer target, the schema(s) and tables specified in the Tables property in the writer will be created in the target. For example, if the Tables property in the writer is Data types will be mapped as per Target data type support & mapping for MariaDB and MySQL sources. Single-column PRIMARY KEY constraints will be replicated in the target. DEFAULT, FOREIGN KEY, NOT NULL, composite PRIMARY KEY, and UNIQUE KEY constraints will not be replicated. If a table already exists in the target, Striim will verify that the source and target structure match. If they do not, the application will halt and log a TargetTableSchemaMismatchException. MON output for the target tables will include a schemaCreationStatus of Pending, InProgress, Success, or Failed. |
Database Provider Type | String | Default | Set to Maria DB or Maria DB Xpand. Controls which icon appears in the Flow Designer. |
Excluded Tables | String | Data for any tables specified here will not be returned. For example, if | |
Fetch Size | Integer | 100 | Sets the maximum number of records to be fetched from the database in a single JDBC method execution (see the discussion of fetchsize in the documentation for your JDBC driver). |
JAAS Configuration | String | Not applicable to MariaDB in this release. | |
Password | encrypted password | The password for the specified user. See Encrypted passwords. | |
Parallel Threads | Integer | 1 | For Fast Snapshot Loading to Azure Synapse, BiqQuery, Databricks, Fabric Data Warehouse, Microsoft Dataverse, or Snowflake, specify the number of threads Database Reader will use. This value should not be higher than the number of tables to be read. For other targets, leave set to the default of 1. When Database Reader is started, the tables will be distributed among the threads in round-robin fashion, then each thread will read one table at a time. When the Tables property is a list of tables, the tables are read in that order. If the Tables property uses a wildcard, the sequence is determined by the order in which the JDBC driver gives Database Reader the list of tables. Known issue DEV-49013: the maximum number of tables supported by Parallel Threads is 255. |
Query | String | Optionally, specify a single SQL SELECT statement specifying the data to return. You may query tables, aliases, synonyms, and views. Query is not supported when Create Schema is True, Parallel Threads is greater than 1, or Restart Behavior on IL Interruption is Truncate_target_table or Replace_target_table. When If the query includes a synonym containing a period, it must be enclosed in escaped quotes. For example: If using a query when the output of a DatabaseReader source is the input of a DatabaseWriter target, specify the target table name as the value of DatabaseReader's Tables field. | |
Quiesce on IL Completion | Boolean | False | |
Restart Behavior on IL Interruption | Enum | Keep target table data | |
Return DateTime As | String | Joda | Set to Set to |
SSL Config | String | Not applicable to MariaDB in this release. | |
Tables | String | Specify the table(s) or view(s) to be read. Specify names as You may specify multiple tables and views as a list separated by semicolons or with the If you are using the Query property, specify QUERY as the table name. Modifying this property can interfere with recovery. If recovery is enabled for the application and it is necessary to modify the tables list, export the application (see Apps page), drop it, update the exported TQL with the new values, and import it (see Apps page). | |
Use Connection Profile | Boolean | False | Not applicable to MariaDB in this release. |
Username | String | Specify the user name the adapter will use to log in to the server specified in ConnectionURL. This user must have SELECT permission or privileges on the tables specified in the Tables property. | |
Vendor Configuration | Striing | Not applicable to MariaDB in this release. |
Sample Database Reader WAEvent
For the following row:
id first_name last_name phone street city state zip_code 1 Deborah Burks NULL 9273 Thorne AV Orchard Park NY 14127
The WAEvent would be similar to:
WAEvent{
data: [1,"Deborah","Burks",null,"9273 Thorne AV","Orchard Park","NY","14127"]
metadata: {"TableName":"BikeStores.sales.customers","ColumnCount":8,
"OperationName":"SELECT","OPERATION_TS":1681412863364}
userdata: null
before: null
dataPresenceBitMap: "fwM="
beforePresenceBitMap: "AAA="
typeUUID: {"uuidstring":"01edda2e-77f7-9b21-83c2-8e859085da65"}
};The operation name for Database Reader WAEvents is always SELECT.
For more information about WAEvent, see WAEvent contents for change data.
Database Reader data type support and correspondence for MariaDB sources
JDBC column type | TQL type |
|---|---|
Types.ARRAY | java.lang.String |
Types.BIGINT | java.lang.Long |
Types.BIT | java.lang.Boolean |
Types.CHAR | java.lang.String |
Types.DATE | org.joda.time.LocalDate |
Types.DECIMAL | java.lang.String |
Types.DOUBLE | java.lang.Double |
Types.FLOAT | java.lang.Double |
Types.INTEGER | java.lang.Integer |
Types.NUMERIC | java.lang.String |
Types.REAL | java.lang.Float |
Types.SMALLINT | java.lang.Short |
Types.TIMESTAMP | org.joda.time.DateTime |
Types.TINYINT | java.lang.Short |
Types.VARCHARCHAR | java.lang.String |
other types | java.lang.String |