public class org.finos.legend.engine.persistence.components.AnsiTestArtifacts extends java.lang.Object
{
public static java.lang.String expectedMetadataTableCreateQuery;
public static java.lang.String expectedMetadataTableCreateQueryWithUpperCase;
public static java.lang.String expectedMainTableCreateQuery;
public static java.lang.String expectedMainTableCreateQueryWithUpperCase;
public static java.lang.String expectedMainTableBatchIdBasedCreateQuery;
public static java.lang.String expectedMainTableWithMultiPartitionsCreateQuery;
public static java.lang.String expectedMainTableBatchIdAndVersionBasedCreateQuery;
public static java.lang.String expectedMainTableBatchIdAndVersionBasedCreateQueryWithUpperCase;
public static java.lang.String expectedMainTableBatchIdBasedCreateQueryWithUpperCase;
public static java.lang.String expectedMainTableMultiPartitionCreateQueryWithUpperCase;
public static java.lang.String expectedMainTableTimeBasedCreateQuery;
public static java.lang.String expectedMainTableTimeBasedCreateQueryWithUpperCase;
public static java.lang.String expectedBaseTableCreateQuery;
public static java.lang.String expectedBaseStagingTableCreateQuery;
public static java.lang.String expectedBaseTableCreateQueryWithUpperCase;
public static java.lang.String expectedBaseTablePlusDigestCreateQuery;
public static java.lang.String expectedStagingTableWithDigestCreateQuery;
public static java.lang.String expectedBaseTablePlusDigestPlusVersionCreateQuery;
public static java.lang.String expectedBaseTablePlusDigestPlusVersionCreateQueryUpperCase;
public static java.lang.String expectedBaseTableCreateQueryWithNoPKs;
public static java.lang.String expectedBaseStagingTableCreateQueryWithNoPKs;
public static java.lang.String expectedLockInfoTableCreateQuery;
public static java.lang.String expectedLockInfoTableUpperCaseCreateQuery;
public static java.lang.String lockInitializedQuery;
public static java.lang.String lockInitializedUpperCaseQuery;
public static java.lang.String lockAcquiredQuery;
public static java.lang.String lockAcquiredUpperCaseQuery;
public static java.lang.String expectedBaseTablePlusDigestCreateQueryWithUpperCase;
public static java.lang.String expectedBaseTablePlusDigestPlusUpdateTimestampCreateQuery;
public static java.lang.String expectedBaseTablePlusDigestPlusUpdateTimestampCreateQueryUpperCase;
public static java.lang.String expectedBaseTablePlusDigestPlusUpdateTimestampAndBatchNumberCreateQuery;
public static java.lang.String expectedBaseTableWithAuditPkCreateQuery;
public static java.lang.String expectedBaseTempStagingTablePlusDigest;
public static java.lang.String expectedBaseTempStagingTableWithCount;
public static java.lang.String expectedBaseTempStagingTableWithVersionAndCount;
public static java.lang.String expectedBaseTempStagingTablePlusDigestWithCount;
public static java.lang.String expectedBaseTempStagingTablePlusDigestWithCountUpperCase;
public static java.lang.String expectedBaseTempStagingTablePlusDigestWithVersionUpperCase;
public static java.lang.String expectedBaseTempStagingTablePlusDigestWithDataSplit;
public static java.lang.String expectedBaseTempStagingTablePlusDigestWithCountAndDataSplit;
public static java.lang.String expectedBaseTempStagingTablePlusDigestWithDataSplitAndCount;
public static java.lang.String expectedBitemporalMainTableCreateQuery;
public static java.lang.String expectedBitemporalStagingTableCreateQuery;
public static java.lang.String expectedBitemporalMainTableWithVersionWithBatchIdDatetimeCreateQuery;
public static java.lang.String expectedBitemporalMainTableWithVersionBatchDateTimeCreateQuery;
public static java.lang.String expectedBitemporalFromOnlyMainTableCreateQuery;
public static java.lang.String expectedBitemporalFromOnlyMainTableWithVersionCreateQuery;
public static java.lang.String expectedBitemporalFromOnlyStagingTableCreateQuery;
public static java.lang.String expectedBitemporalFromOnlyMainTableBatchIdAndTimeBasedCreateQuery;
public static java.lang.String expectedBitemporalFromOnlyMainTableDateTimeBasedCreateQuery;
public static java.lang.String expectedBitemporalMainTableCreateQueryUpperCase;
public static java.lang.String expectedBitemporalFromOnlyTempTableCreateQuery;
public static java.lang.String expectedBitemporalFromOnlyTempTableWithVersionCreateQuery;
public static java.lang.String expectedBitemporalFromOnlyTempTableBatchIdAndTimeBasedCreateQuery;
public static java.lang.String expectedBitemporalFromOnlyTempTableDateTimeBasedCreateQuery;
public static java.lang.String expectedBitemporalFromOnlyStageWithoutDuplicatesTableCreateQuery;
public static java.lang.String expectedBitemporalFromOnlyTempTableWithDeleteIndicatorCreateQuery;
public static java.lang.String expectedBitemporalFromOnlyStageWithVersionWithDataSplitWithoutDuplicatesTableCreateQuery;
public static java.lang.String expectedBitemporalFromOnlyStageWithDeleteIndicatorWithoutDuplicatesTableCreateQuery;
public static java.lang.String expectedStagingCleanupQuery;
public static java.lang.String expectedTempStagingCleanupQuery;
public static java.lang.String expectedTempStagingCleanupQueryInUpperCase;
public static java.lang.String expectedDropTableQuery;
public static java.lang.String expectedMetadataTableIngestQuery;
public static java.lang.String expectedMetadataTableIngestQueryWithUpperCase;
public static java.lang.String expectedMetadataTableIngestQueryWithPlaceHolders;
public static java.lang.String expectedMetadataTableIngestQueryWithBatchSuccessValue;
public static java.lang.String expectedMetadataTableIngestQueryWithAdditionalMetadata;
public static java.lang.String expectedMetadataTableIngestQueryWithAdditionalMetadataWithUpperCase;
public static java.lang.String expectedMetadataTableIngestQueryWithAdditionalMetadataWithBatchSuccessWithUpperCase;
public static java.lang.String expectedInsertIntoBaseTempStagingWithMaxVersionAndFilterDuplicates;
public static java.lang.String expectedInsertIntoBaseTempStagingWithFilterDuplicates;
public static java.lang.String expectedInsertIntoBaseTempStagingWithFilterDupsAndMaxVersion;
public static java.lang.String expectedInsertIntoBaseTempStagingPlusDigestWithFilterDuplicates;
public static java.lang.String expectedInsertIntoBaseTempStagingPlusDigestWithMaxVersionAndFilterDuplicates;
public static java.lang.String expectedInsertIntoBaseTempStagingPlusDigestWithMaxVersionAndAllowDuplicates;
public static java.lang.String expectedInsertIntoBaseTempStagingPlusDigestWithMaxVersionAndFilterDuplicatesUpperCase;
public static java.lang.String expectedInsertIntoBaseTempStagingPlusDigestWithAllVersionAndFilterDuplicates;
public static java.lang.String expectedInsertIntoBaseTempStagingPlusDigestWithAllVersionAndAllowDups;
public static java.lang.String maxDupsErrorCheckSql;
public static java.lang.String dupRowsSql;
public static java.lang.String maxPkDupsErrorCheckSql;
public static java.lang.String dupPkRowsSql;
public static java.lang.String dataErrorCheckSqlWithBizDateVersion;
public static java.lang.String dataErrorCheckSql;
public static java.lang.String dataErrorCheckSqlUpperCase;
public static java.lang.String dataErrorCheckSqlWithBizDateAsVersionUpperCase;
public static java.lang.String dataErrorsSqlWithBizDateVersion;
public static java.lang.String dataErrorsSqlWithBizDateVersionUpperCase;
public static java.lang.String dataErrorsSqlUpperCase;
public static java.lang.String dataErrorsSql;
public void <init>()
{
org.finos.legend.engine.persistence.components.AnsiTestArtifacts v;
v := @this: org.finos.legend.engine.persistence.components.AnsiTestArtifacts;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static java.lang.String getDropTempTableQuery(java.lang.String)
{
java.lang.Object[] v;
java.lang.String v, v;
v := @parameter: java.lang.String;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("DROP TABLE IF EXISTS %s CASCADE", v);
return v;
}
static void <clinit>()
{
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMetadataTableCreateQuery> = "CREATE TABLE IF NOT EXISTS batch_metadata(\"table_name\" VARCHAR(255),\"batch_start_ts_utc\" DATETIME,\"batch_end_ts_utc\" DATETIME,\"batch_status\" VARCHAR(32),\"table_batch_id\" INTEGER,\"ingest_request_id\" VARCHAR(64),\"batch_source_info\" JSON,\"additional_metadata\" JSON,\"batch_statistics\" JSON)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMetadataTableCreateQueryWithUpperCase> = "CREATE TABLE IF NOT EXISTS BATCH_METADATA(\"TABLE_NAME\" VARCHAR(255),\"BATCH_START_TS_UTC\" DATETIME,\"BATCH_END_TS_UTC\" DATETIME,\"BATCH_STATUS\" VARCHAR(32),\"TABLE_BATCH_ID\" INTEGER,\"INGEST_REQUEST_ID\" VARCHAR(64),\"BATCH_SOURCE_INFO\" JSON,\"ADDITIONAL_METADATA\" JSON,\"BATCH_STATISTICS\" JSON)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMainTableCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR,\"batch_id_in\" INTEGER NOT NULL,\"batch_id_out\" INTEGER,\"batch_time_in\" DATETIME,\"batch_time_out\" DATETIME,PRIMARY KEY (\"id\", \"name\", \"batch_id_in\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMainTableCreateQueryWithUpperCase> = "CREATE TABLE IF NOT EXISTS \"MYDB\".\"MAIN\"(\"ID\" INTEGER NOT NULL,\"NAME\" VARCHAR NOT NULL,\"AMOUNT\" DOUBLE,\"BIZ_DATE\" DATE,\"DIGEST\" VARCHAR,\"BATCH_ID_IN\" INTEGER NOT NULL,\"BATCH_ID_OUT\" INTEGER,\"BATCH_TIME_IN\" DATETIME,\"BATCH_TIME_OUT\" DATETIME,PRIMARY KEY (\"ID\", \"NAME\", \"BATCH_ID_IN\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMainTableBatchIdBasedCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR,\"batch_id_in\" INTEGER NOT NULL,\"batch_id_out\" INTEGER,PRIMARY KEY (\"id\", \"name\", \"batch_id_in\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMainTableWithMultiPartitionsCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"account_type\" INTEGER,\"biz_date\" DATE,\"digest\" VARCHAR,\"batch_id_in\" INTEGER NOT NULL,\"batch_id_out\" INTEGER,PRIMARY KEY (\"id\", \"name\", \"batch_id_in\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMainTableBatchIdAndVersionBasedCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR,\"version\" INTEGER,\"batch_id_in\" INTEGER NOT NULL,\"batch_id_out\" INTEGER,PRIMARY KEY (\"id\", \"name\", \"batch_id_in\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMainTableBatchIdAndVersionBasedCreateQueryWithUpperCase> = "CREATE TABLE IF NOT EXISTS \"MYDB\".\"MAIN\"(\"ID\" INTEGER NOT NULL,\"NAME\" VARCHAR NOT NULL,\"AMOUNT\" DOUBLE,\"BIZ_DATE\" DATE,\"DIGEST\" VARCHAR,\"VERSION\" INTEGER,\"BATCH_ID_IN\" INTEGER NOT NULL,\"BATCH_ID_OUT\" INTEGER,PRIMARY KEY (\"ID\", \"NAME\", \"BATCH_ID_IN\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMainTableBatchIdBasedCreateQueryWithUpperCase> = "CREATE TABLE IF NOT EXISTS \"MYDB\".\"MAIN\"(\"ID\" INTEGER NOT NULL,\"NAME\" VARCHAR NOT NULL,\"AMOUNT\" DOUBLE,\"BIZ_DATE\" DATE,\"DIGEST\" VARCHAR,\"BATCH_ID_IN\" INTEGER NOT NULL,\"BATCH_ID_OUT\" INTEGER,PRIMARY KEY (\"ID\", \"NAME\", \"BATCH_ID_IN\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMainTableMultiPartitionCreateQueryWithUpperCase> = "CREATE TABLE IF NOT EXISTS \"MYDB\".\"MAIN\"(\"ID\" INTEGER NOT NULL,\"NAME\" VARCHAR NOT NULL,\"AMOUNT\" DOUBLE,\"ACCOUNT_TYPE\" INTEGER,\"BIZ_DATE\" DATE,\"DIGEST\" VARCHAR,\"BATCH_ID_IN\" INTEGER NOT NULL,\"BATCH_ID_OUT\" INTEGER,PRIMARY KEY (\"ID\", \"NAME\", \"BATCH_ID_IN\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMainTableTimeBasedCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR,\"batch_time_in\" DATETIME NOT NULL,\"batch_time_out\" DATETIME,PRIMARY KEY (\"id\", \"name\", \"batch_time_in\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMainTableTimeBasedCreateQueryWithUpperCase> = "CREATE TABLE IF NOT EXISTS \"MYDB\".\"MAIN\"(\"ID\" INTEGER NOT NULL,\"NAME\" VARCHAR NOT NULL,\"AMOUNT\" DOUBLE,\"BIZ_DATE\" DATE,\"DIGEST\" VARCHAR,\"BATCH_TIME_IN\" DATETIME NOT NULL,\"BATCH_TIME_OUT\" DATETIME,PRIMARY KEY (\"ID\", \"NAME\", \"BATCH_TIME_IN\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTableCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"batch_id\" INTEGER,PRIMARY KEY (\"id\", \"name\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseStagingTableCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"staging\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,PRIMARY KEY (\"id\", \"name\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTableCreateQueryWithUpperCase> = "CREATE TABLE IF NOT EXISTS \"MYDB\".\"MAIN\"(\"ID\" INTEGER NOT NULL,\"NAME\" VARCHAR NOT NULL,\"AMOUNT\" DOUBLE,\"BIZ_DATE\" DATE,\"BATCH_ID\" INTEGER,PRIMARY KEY (\"ID\", \"NAME\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTablePlusDigestCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR,\"batch_id\" INTEGER,PRIMARY KEY (\"id\", \"name\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedStagingTableWithDigestCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"staging\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR,PRIMARY KEY (\"id\", \"name\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTablePlusDigestPlusVersionCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR,\"version\" INTEGER,\"batch_id\" INTEGER,PRIMARY KEY (\"id\", \"name\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTablePlusDigestPlusVersionCreateQueryUpperCase> = "CREATE TABLE IF NOT EXISTS \"MYDB\".\"MAIN\"(\"ID\" INTEGER NOT NULL,\"NAME\" VARCHAR NOT NULL,\"AMOUNT\" DOUBLE,\"BIZ_DATE\" DATE,\"DIGEST\" VARCHAR,\"VERSION\" INTEGER,\"BATCH_ID\" INTEGER,PRIMARY KEY (\"ID\", \"NAME\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTableCreateQueryWithNoPKs> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER,\"name\" VARCHAR,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR,\"batch_id\" INTEGER)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseStagingTableCreateQueryWithNoPKs> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"staging\"(\"id\" INTEGER,\"name\" VARCHAR,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedLockInfoTableCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main_legend_persistence_lock\"(\"insert_ts_utc\" DATETIME,\"last_used_ts_utc\" DATETIME,\"batch_id\" INTEGER)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedLockInfoTableUpperCaseCreateQuery> = "CREATE TABLE IF NOT EXISTS \"MYDB\".\"MAIN_LEGEND_PERSISTENCE_LOCK\"(\"INSERT_TS_UTC\" DATETIME,\"LAST_USED_TS_UTC\" DATETIME,\"BATCH_ID\" INTEGER)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String lockInitializedQuery> = "INSERT INTO \"mydb\".\"main_legend_persistence_lock\" (\"insert_ts_utc\") (SELECT \'2000-01-01 00:00:00.000000\' WHERE NOT (EXISTS (SELECT * FROM \"mydb\".\"main_legend_persistence_lock\" as main_legend_persistence_lock)))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String lockInitializedUpperCaseQuery> = "INSERT INTO \"MYDB\".\"MAIN_LEGEND_PERSISTENCE_LOCK\" (\"INSERT_TS_UTC\") (SELECT \'2000-01-01 00:00:00.000000\' WHERE NOT (EXISTS (SELECT * FROM \"MYDB\".\"MAIN_LEGEND_PERSISTENCE_LOCK\" as MAIN_LEGEND_PERSISTENCE_LOCK)))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String lockAcquiredQuery> = "UPDATE \"mydb\".\"main_legend_persistence_lock\" as main_legend_persistence_lock SET main_legend_persistence_lock.\"last_used_ts_utc\" = \'2000-01-01 00:00:00.000000\'";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String lockAcquiredUpperCaseQuery> = "UPDATE \"MYDB\".\"MAIN_LEGEND_PERSISTENCE_LOCK\" as MAIN_LEGEND_PERSISTENCE_LOCK SET MAIN_LEGEND_PERSISTENCE_LOCK.\"LAST_USED_TS_UTC\" = \'2000-01-01 00:00:00.000000\'";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTablePlusDigestCreateQueryWithUpperCase> = "CREATE TABLE IF NOT EXISTS \"MYDB\".\"MAIN\"(\"ID\" INTEGER NOT NULL,\"NAME\" VARCHAR NOT NULL,\"AMOUNT\" DOUBLE,\"BIZ_DATE\" DATE,\"DIGEST\" VARCHAR,\"BATCH_ID\" INTEGER,PRIMARY KEY (\"ID\", \"NAME\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTablePlusDigestPlusUpdateTimestampCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR,\"batch_update_time\" DATETIME NOT NULL,\"batch_id\" INTEGER,PRIMARY KEY (\"id\", \"name\", \"batch_update_time\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTablePlusDigestPlusUpdateTimestampCreateQueryUpperCase> = "CREATE TABLE IF NOT EXISTS \"MYDB\".\"MAIN\"(\"ID\" INTEGER NOT NULL,\"NAME\" VARCHAR NOT NULL,\"AMOUNT\" DOUBLE,\"BIZ_DATE\" DATE,\"DIGEST\" VARCHAR,\"BATCH_UPDATE_TIME\" DATETIME NOT NULL,\"BATCH_ID\" INTEGER,PRIMARY KEY (\"ID\", \"NAME\", \"BATCH_UPDATE_TIME\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTablePlusDigestPlusUpdateTimestampAndBatchNumberCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR,\"batch_update_time\" DATETIME NOT NULL,\"batch_number\" INTEGER,PRIMARY KEY (\"id\", \"name\", \"batch_update_time\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTableWithAuditPkCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"batch_update_time\" DATETIME NOT NULL,\"batch_id\" INTEGER,PRIMARY KEY (\"id\", \"name\", \"batch_update_time\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTempStagingTablePlusDigest> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"staging_temp_staging_lp_yosulf\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTempStagingTableWithCount> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"staging_temp_staging_lp_yosulf\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"legend_persistence_count\" INTEGER)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTempStagingTableWithVersionAndCount> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"staging_temp_staging_lp_yosulf\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR,\"version\" INTEGER,\"legend_persistence_count\" INTEGER)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTempStagingTablePlusDigestWithCount> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"staging_temp_staging_lp_yosulf\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR,\"legend_persistence_count\" INTEGER)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTempStagingTablePlusDigestWithCountUpperCase> = "CREATE TABLE IF NOT EXISTS \"MYDB\".\"STAGING_TEMP_STAGING_LP_YOSULF\"(\"ID\" INTEGER NOT NULL,\"NAME\" VARCHAR NOT NULL,\"AMOUNT\" DOUBLE,\"BIZ_DATE\" DATE,\"DIGEST\" VARCHAR,\"LEGEND_PERSISTENCE_COUNT\" INTEGER)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTempStagingTablePlusDigestWithVersionUpperCase> = "CREATE TABLE IF NOT EXISTS \"MYDB\".\"STAGING_TEMP_STAGING_LP_YOSULF\"(\"ID\" INTEGER NOT NULL,\"NAME\" VARCHAR NOT NULL,\"AMOUNT\" DOUBLE,\"BIZ_DATE\" DATE,\"DIGEST\" VARCHAR,\"VERSION\" INTEGER)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTempStagingTablePlusDigestWithDataSplit> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"staging_temp_staging_lp_yosulf\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR,\"data_split\" INTEGER NOT NULL)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTempStagingTablePlusDigestWithCountAndDataSplit> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"staging_temp_staging_lp_yosulf\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR,\"legend_persistence_count\" INTEGER,\"data_split\" INTEGER NOT NULL)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBaseTempStagingTablePlusDigestWithDataSplitAndCount> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"staging_temp_staging_lp_yosulf\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"biz_date\" DATE,\"digest\" VARCHAR,\"data_split\" BIGINT NOT NULL,\"legend_persistence_count\" INTEGER)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalMainTableCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"digest\" VARCHAR,\"batch_id_in\" INTEGER NOT NULL,\"batch_id_out\" INTEGER,\"validity_from_target\" DATETIME NOT NULL,\"validity_through_target\" DATETIME,PRIMARY KEY (\"id\", \"name\", \"batch_id_in\", \"validity_from_target\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalStagingTableCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"staging\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"validity_from_reference\" DATETIME NOT NULL,\"validity_through_reference\" DATETIME,\"digest\" VARCHAR,PRIMARY KEY (\"id\", \"name\", \"validity_from_reference\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalMainTableWithVersionWithBatchIdDatetimeCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"digest\" VARCHAR,\"version\" INTEGER,\"batch_id_in\" INTEGER NOT NULL,\"batch_id_out\" INTEGER,\"batch_time_in\" DATETIME,\"batch_time_out\" DATETIME,\"validity_from_target\" DATETIME NOT NULL,\"validity_through_target\" DATETIME,PRIMARY KEY (\"id\", \"name\", \"batch_id_in\", \"validity_from_target\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalMainTableWithVersionBatchDateTimeCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"digest\" VARCHAR,\"version\" INTEGER,\"batch_time_in\" DATETIME NOT NULL,\"batch_time_out\" DATETIME,\"validity_from_target\" DATETIME NOT NULL,\"validity_through_target\" DATETIME,PRIMARY KEY (\"id\", \"name\", \"batch_time_in\", \"validity_from_target\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalFromOnlyMainTableCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"digest\" VARCHAR,\"batch_id_in\" INTEGER NOT NULL,\"batch_id_out\" INTEGER,\"validity_from_target\" DATETIME NOT NULL,\"validity_through_target\" DATETIME,PRIMARY KEY (\"id\", \"name\", \"batch_id_in\", \"validity_from_target\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalFromOnlyMainTableWithVersionCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"digest\" VARCHAR,\"version\" INTEGER,\"batch_id_in\" INTEGER NOT NULL,\"batch_id_out\" INTEGER,\"validity_from_target\" DATETIME NOT NULL,\"validity_through_target\" DATETIME,PRIMARY KEY (\"id\", \"name\", \"batch_id_in\", \"validity_from_target\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalFromOnlyStagingTableCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"staging\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"validity_from_reference\" DATETIME NOT NULL,\"digest\" VARCHAR,PRIMARY KEY (\"id\", \"name\", \"validity_from_reference\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalFromOnlyMainTableBatchIdAndTimeBasedCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"digest\" VARCHAR,\"batch_id_in\" INTEGER NOT NULL,\"batch_id_out\" INTEGER,\"batch_time_in\" DATETIME,\"batch_time_out\" DATETIME,\"validity_from_target\" DATETIME NOT NULL,\"validity_through_target\" DATETIME,PRIMARY KEY (\"id\", \"name\", \"batch_id_in\", \"validity_from_target\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalFromOnlyMainTableDateTimeBasedCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"main\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"digest\" VARCHAR,\"batch_time_in\" DATETIME NOT NULL,\"batch_time_out\" DATETIME,\"validity_from_target\" DATETIME NOT NULL,\"validity_through_target\" DATETIME,PRIMARY KEY (\"id\", \"name\", \"batch_time_in\", \"validity_from_target\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalMainTableCreateQueryUpperCase> = "CREATE TABLE IF NOT EXISTS \"MYDB\".\"MAIN\"(\"ID\" INTEGER NOT NULL,\"NAME\" VARCHAR NOT NULL,\"AMOUNT\" DOUBLE,\"DIGEST\" VARCHAR,\"BATCH_ID_IN\" INTEGER NOT NULL,\"BATCH_ID_OUT\" INTEGER,\"VALIDITY_FROM_TARGET\" DATETIME NOT NULL,\"VALIDITY_THROUGH_TARGET\" DATETIME,PRIMARY KEY (\"ID\", \"NAME\", \"BATCH_ID_IN\", \"VALIDITY_FROM_TARGET\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalFromOnlyTempTableCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"temp\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"digest\" VARCHAR,\"batch_id_in\" INTEGER NOT NULL,\"batch_id_out\" INTEGER,\"validity_from_target\" DATETIME NOT NULL,\"validity_through_target\" DATETIME,PRIMARY KEY (\"id\", \"name\", \"batch_id_in\", \"validity_from_target\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalFromOnlyTempTableWithVersionCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"temp\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"digest\" VARCHAR,\"version\" INTEGER,\"batch_id_in\" INTEGER NOT NULL,\"batch_id_out\" INTEGER,\"validity_from_target\" DATETIME NOT NULL,\"validity_through_target\" DATETIME,PRIMARY KEY (\"id\", \"name\", \"batch_id_in\", \"validity_from_target\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalFromOnlyTempTableBatchIdAndTimeBasedCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"temp\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"digest\" VARCHAR,\"batch_id_in\" INTEGER NOT NULL,\"batch_id_out\" INTEGER,\"batch_time_in\" DATETIME,\"batch_time_out\" DATETIME,\"validity_from_target\" DATETIME NOT NULL,\"validity_through_target\" DATETIME,PRIMARY KEY (\"id\", \"name\", \"batch_id_in\", \"validity_from_target\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalFromOnlyTempTableDateTimeBasedCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"temp\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"digest\" VARCHAR,\"batch_time_in\" DATETIME NOT NULL,\"batch_time_out\" DATETIME,\"validity_from_target\" DATETIME NOT NULL,\"validity_through_target\" DATETIME,PRIMARY KEY (\"id\", \"name\", \"batch_time_in\", \"validity_from_target\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalFromOnlyStageWithoutDuplicatesTableCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"stagingWithoutDuplicates\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"validity_from_reference\" DATETIME NOT NULL,\"digest\" VARCHAR,PRIMARY KEY (\"id\", \"name\", \"validity_from_reference\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalFromOnlyTempTableWithDeleteIndicatorCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"tempWithDeleteIndicator\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"digest\" VARCHAR,\"batch_id_in\" INTEGER NOT NULL,\"batch_id_out\" INTEGER,\"validity_from_target\" DATETIME NOT NULL,\"validity_through_target\" DATETIME,\"delete_indicator\" VARCHAR,PRIMARY KEY (\"id\", \"name\", \"batch_id_in\", \"validity_from_target\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalFromOnlyStageWithVersionWithDataSplitWithoutDuplicatesTableCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"stagingWithoutDuplicates\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"validity_from_reference\" DATETIME NOT NULL,\"digest\" VARCHAR,\"version\" INTEGER,\"data_split\" BIGINT NOT NULL,PRIMARY KEY (\"id\", \"name\", \"validity_from_reference\", \"data_split\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedBitemporalFromOnlyStageWithDeleteIndicatorWithoutDuplicatesTableCreateQuery> = "CREATE TABLE IF NOT EXISTS \"mydb\".\"stagingWithoutDuplicates\"(\"id\" INTEGER NOT NULL,\"name\" VARCHAR NOT NULL,\"amount\" DOUBLE,\"validity_from_reference\" DATETIME NOT NULL,\"digest\" VARCHAR,\"delete_indicator\" VARCHAR,PRIMARY KEY (\"id\", \"name\", \"validity_from_reference\"))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedStagingCleanupQuery> = "DELETE FROM \"mydb\".\"staging\" as stage";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedTempStagingCleanupQuery> = "DELETE FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedTempStagingCleanupQueryInUpperCase> = "DELETE FROM \"MYDB\".\"STAGING_TEMP_STAGING_LP_YOSULF\" as stage";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedDropTableQuery> = "DROP TABLE IF EXISTS \"mydb\".\"staging\" CASCADE";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMetadataTableIngestQuery> = "INSERT INTO batch_metadata (\"table_name\", \"table_batch_id\", \"batch_start_ts_utc\", \"batch_end_ts_utc\", \"batch_status\") (SELECT \'main\',(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),\'2000-01-01 00:00:00.000000\',CURRENT_TIMESTAMP(),\'DONE\')";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMetadataTableIngestQueryWithUpperCase> = "INSERT INTO BATCH_METADATA (\"TABLE_NAME\", \"TABLE_BATCH_ID\", \"BATCH_START_TS_UTC\", \"BATCH_END_TS_UTC\", \"BATCH_STATUS\") (SELECT \'MAIN\',(SELECT COALESCE(MAX(BATCH_METADATA.\"TABLE_BATCH_ID\"),0)+1 FROM BATCH_METADATA as BATCH_METADATA WHERE UPPER(BATCH_METADATA.\"TABLE_NAME\") = \'MAIN\'),\'2000-01-01 00:00:00.000000\',CURRENT_TIMESTAMP(),\'DONE\')";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMetadataTableIngestQueryWithPlaceHolders> = "INSERT INTO batch_metadata (\"table_name\", \"table_batch_id\", \"batch_start_ts_utc\", \"batch_end_ts_utc\", \"batch_status\") (SELECT \'main\',{BATCH_ID_PATTERN},\'{BATCH_START_TS_PATTERN}\',\'{BATCH_END_TS_PATTERN}\',\'DONE\')";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMetadataTableIngestQueryWithBatchSuccessValue> = "INSERT INTO batch_metadata (\"table_name\", \"table_batch_id\", \"batch_start_ts_utc\", \"batch_end_ts_utc\", \"batch_status\") (SELECT \'main\',(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),\'2000-01-01 00:00:00.000000\',CURRENT_TIMESTAMP(),\'SUCCEEDED\')";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMetadataTableIngestQueryWithAdditionalMetadata> = "INSERT INTO batch_metadata (\"table_name\", \"table_batch_id\", \"batch_start_ts_utc\", \"batch_end_ts_utc\", \"batch_status\", \"additional_metadata\") (SELECT \'main\',(SELECT COALESCE(MAX(batch_metadata.\"table_batch_id\"),0)+1 FROM batch_metadata as batch_metadata WHERE UPPER(batch_metadata.\"table_name\") = \'MAIN\'),\'2000-01-01 00:00:00.000000\',CURRENT_TIMESTAMP(),\'DONE\',PARSE_JSON(\'{\"watermark\":\"my_watermark_value\"}\'))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMetadataTableIngestQueryWithAdditionalMetadataWithUpperCase> = "INSERT INTO BATCH_METADATA (\"TABLE_NAME\", \"TABLE_BATCH_ID\", \"BATCH_START_TS_UTC\", \"BATCH_END_TS_UTC\", \"BATCH_STATUS\", \"ADDITIONAL_METADATA\") (SELECT \'MAIN\',(SELECT COALESCE(MAX(BATCH_METADATA.\"TABLE_BATCH_ID\"),0)+1 FROM BATCH_METADATA as BATCH_METADATA WHERE UPPER(BATCH_METADATA.\"TABLE_NAME\") = \'MAIN\'),\'2000-01-01 00:00:00.000000\',CURRENT_TIMESTAMP(),\'DONE\',PARSE_JSON(\'{\"watermark\":\"my_watermark_value\"}\'))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedMetadataTableIngestQueryWithAdditionalMetadataWithBatchSuccessWithUpperCase> = "INSERT INTO BATCH_METADATA (\"TABLE_NAME\", \"TABLE_BATCH_ID\", \"BATCH_START_TS_UTC\", \"BATCH_END_TS_UTC\", \"BATCH_STATUS\", \"ADDITIONAL_METADATA\") (SELECT \'MAIN\',(SELECT COALESCE(MAX(BATCH_METADATA.\"TABLE_BATCH_ID\"),0)+1 FROM BATCH_METADATA as BATCH_METADATA WHERE UPPER(BATCH_METADATA.\"TABLE_NAME\") = \'MAIN\'),\'2000-01-01 00:00:00.000000\',CURRENT_TIMESTAMP(),\'SUCCEEDED\',PARSE_JSON(\'{\"watermark\":\"my_watermark_value\"}\'))";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedInsertIntoBaseTempStagingWithMaxVersionAndFilterDuplicates> = "INSERT INTO \"mydb\".\"staging_temp_staging_lp_yosulf\" (\"id\", \"name\", \"amount\", \"biz_date\", \"legend_persistence_count\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"legend_persistence_count\" as \"legend_persistence_count\" FROM (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"legend_persistence_count\" as \"legend_persistence_count\",DENSE_RANK() OVER (PARTITION BY stage.\"id\",stage.\"name\" ORDER BY stage.\"biz_date\" DESC) as \"legend_persistence_rank\" FROM (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",COUNT(*) as \"legend_persistence_count\" FROM \"mydb\".\"staging\" as stage GROUP BY stage.\"id\", stage.\"name\", stage.\"amount\", stage.\"biz_date\") as stage) as stage WHERE stage.\"legend_persistence_rank\" = 1)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedInsertIntoBaseTempStagingWithFilterDuplicates> = "INSERT INTO \"mydb\".\"staging_temp_staging_lp_yosulf\" (\"id\", \"name\", \"amount\", \"biz_date\", \"legend_persistence_count\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",COUNT(*) as \"legend_persistence_count\" FROM \"mydb\".\"staging\" as stage GROUP BY stage.\"id\", stage.\"name\", stage.\"amount\", stage.\"biz_date\")";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedInsertIntoBaseTempStagingWithFilterDupsAndMaxVersion> = "INSERT INTO \"mydb\".\"staging_temp_staging_lp_yosulf\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"legend_persistence_count\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"legend_persistence_count\" as \"legend_persistence_count\" FROM (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"legend_persistence_count\" as \"legend_persistence_count\",DENSE_RANK() OVER (PARTITION BY stage.\"id\",stage.\"name\" ORDER BY stage.\"biz_date\" DESC) as \"legend_persistence_rank\" FROM (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",COUNT(*) as \"legend_persistence_count\" FROM \"mydb\".\"staging\" as stage GROUP BY stage.\"id\", stage.\"name\", stage.\"amount\", stage.\"biz_date\", stage.\"digest\") as stage) as stage WHERE stage.\"legend_persistence_rank\" = 1)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedInsertIntoBaseTempStagingPlusDigestWithFilterDuplicates> = "INSERT INTO \"mydb\".\"staging_temp_staging_lp_yosulf\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"legend_persistence_count\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",COUNT(*) as \"legend_persistence_count\" FROM \"mydb\".\"staging\" as stage GROUP BY stage.\"id\", stage.\"name\", stage.\"amount\", stage.\"biz_date\", stage.\"digest\")";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedInsertIntoBaseTempStagingPlusDigestWithMaxVersionAndFilterDuplicates> = "INSERT INTO \"mydb\".\"staging_temp_staging_lp_yosulf\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"legend_persistence_count\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"legend_persistence_count\" as \"legend_persistence_count\" FROM (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"legend_persistence_count\" as \"legend_persistence_count\",DENSE_RANK() OVER (PARTITION BY stage.\"id\",stage.\"name\" ORDER BY stage.\"biz_date\" DESC) as \"legend_persistence_rank\" FROM (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",COUNT(*) as \"legend_persistence_count\" FROM \"mydb\".\"staging\" as stage GROUP BY stage.\"id\", stage.\"name\", stage.\"amount\", stage.\"biz_date\", stage.\"digest\") as stage) as stage WHERE stage.\"legend_persistence_rank\" = 1)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedInsertIntoBaseTempStagingPlusDigestWithMaxVersionAndAllowDuplicates> = "INSERT INTO \"mydb\".\"staging_temp_staging_lp_yosulf\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\" FROM (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",DENSE_RANK() OVER (PARTITION BY stage.\"id\",stage.\"name\" ORDER BY stage.\"biz_date\" DESC) as \"legend_persistence_rank\" FROM \"mydb\".\"staging\" as stage) as stage WHERE stage.\"legend_persistence_rank\" = 1)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedInsertIntoBaseTempStagingPlusDigestWithMaxVersionAndFilterDuplicatesUpperCase> = "INSERT INTO \"MYDB\".\"STAGING_TEMP_STAGING_LP_YOSULF\" (\"ID\", \"NAME\", \"AMOUNT\", \"BIZ_DATE\", \"DIGEST\", \"LEGEND_PERSISTENCE_COUNT\") (SELECT stage.\"ID\",stage.\"NAME\",stage.\"AMOUNT\",stage.\"BIZ_DATE\",stage.\"DIGEST\",stage.\"LEGEND_PERSISTENCE_COUNT\" as \"LEGEND_PERSISTENCE_COUNT\" FROM (SELECT stage.\"ID\",stage.\"NAME\",stage.\"AMOUNT\",stage.\"BIZ_DATE\",stage.\"DIGEST\",stage.\"LEGEND_PERSISTENCE_COUNT\" as \"LEGEND_PERSISTENCE_COUNT\",DENSE_RANK() OVER (PARTITION BY stage.\"ID\",stage.\"NAME\" ORDER BY stage.\"BIZ_DATE\" DESC) as \"LEGEND_PERSISTENCE_RANK\" FROM (SELECT stage.\"ID\",stage.\"NAME\",stage.\"AMOUNT\",stage.\"BIZ_DATE\",stage.\"DIGEST\",COUNT(*) as \"LEGEND_PERSISTENCE_COUNT\" FROM \"MYDB\".\"STAGING\" as stage GROUP BY stage.\"ID\", stage.\"NAME\", stage.\"AMOUNT\", stage.\"BIZ_DATE\", stage.\"DIGEST\") as stage) as stage WHERE stage.\"LEGEND_PERSISTENCE_RANK\" = 1)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedInsertIntoBaseTempStagingPlusDigestWithAllVersionAndFilterDuplicates> = "INSERT INTO \"mydb\".\"staging_temp_staging_lp_yosulf\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"legend_persistence_count\", \"data_split\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",stage.\"legend_persistence_count\" as \"legend_persistence_count\",DENSE_RANK() OVER (PARTITION BY stage.\"id\",stage.\"name\" ORDER BY stage.\"biz_date\" ASC) as \"data_split\" FROM (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",COUNT(*) as \"legend_persistence_count\" FROM \"mydb\".\"staging\" as stage GROUP BY stage.\"id\", stage.\"name\", stage.\"amount\", stage.\"biz_date\", stage.\"digest\") as stage)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String expectedInsertIntoBaseTempStagingPlusDigestWithAllVersionAndAllowDups> = "INSERT INTO \"mydb\".\"staging_temp_staging_lp_yosulf\" (\"id\", \"name\", \"amount\", \"biz_date\", \"digest\", \"data_split\") (SELECT stage.\"id\",stage.\"name\",stage.\"amount\",stage.\"biz_date\",stage.\"digest\",DENSE_RANK() OVER (PARTITION BY stage.\"id\",stage.\"name\" ORDER BY stage.\"biz_date\" ASC) as \"data_split\" FROM \"mydb\".\"staging\" as stage)";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String maxDupsErrorCheckSql> = "SELECT MAX(stage.\"legend_persistence_count\") as \"MAX_DUPLICATES\" FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String dupRowsSql> = "SELECT \"id\",\"name\",\"legend_persistence_count\" FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage WHERE stage.\"legend_persistence_count\" > 1 LIMIT 20";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String maxPkDupsErrorCheckSql> = "SELECT MAX(\"legend_persistence_pk_count\") as \"MAX_PK_DUPLICATES\" FROM (SELECT COUNT(*) as \"legend_persistence_pk_count\" FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage GROUP BY \"id\", \"name\") as stage";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String dupPkRowsSql> = "SELECT \"id\",\"name\",COUNT(*) as \"legend_persistence_pk_count\" FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage GROUP BY \"id\", \"name\" HAVING \"legend_persistence_pk_count\" > 1 LIMIT 20";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String dataErrorCheckSqlWithBizDateVersion> = "SELECT MAX(\"legend_persistence_distinct_rows\") as \"MAX_DATA_ERRORS\" FROM (SELECT COUNT(DISTINCT(\"digest\")) as \"legend_persistence_distinct_rows\" FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage GROUP BY \"id\", \"name\", \"biz_date\") as stage";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String dataErrorCheckSql> = "SELECT MAX(\"legend_persistence_distinct_rows\") as \"MAX_DATA_ERRORS\" FROM (SELECT COUNT(DISTINCT(\"digest\")) as \"legend_persistence_distinct_rows\" FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage GROUP BY \"id\", \"name\", \"version\") as stage";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String dataErrorCheckSqlUpperCase> = "SELECT MAX(\"LEGEND_PERSISTENCE_DISTINCT_ROWS\") as \"MAX_DATA_ERRORS\" FROM (SELECT COUNT(DISTINCT(\"DIGEST\")) as \"LEGEND_PERSISTENCE_DISTINCT_ROWS\" FROM \"MYDB\".\"STAGING_TEMP_STAGING_LP_YOSULF\" as stage GROUP BY \"ID\", \"NAME\", \"VERSION\") as stage";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String dataErrorCheckSqlWithBizDateAsVersionUpperCase> = "SELECT MAX(\"LEGEND_PERSISTENCE_DISTINCT_ROWS\") as \"MAX_DATA_ERRORS\" FROM (SELECT COUNT(DISTINCT(\"DIGEST\")) as \"LEGEND_PERSISTENCE_DISTINCT_ROWS\" FROM \"MYDB\".\"STAGING_TEMP_STAGING_LP_YOSULF\" as stage GROUP BY \"ID\", \"NAME\", \"BIZ_DATE\") as stage";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String dataErrorsSqlWithBizDateVersion> = "SELECT \"id\",\"name\",\"biz_date\",COUNT(DISTINCT(\"digest\")) as \"legend_persistence_error_count\" FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage GROUP BY \"id\", \"name\", \"biz_date\" HAVING \"legend_persistence_error_count\" > 1 LIMIT 20";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String dataErrorsSqlWithBizDateVersionUpperCase> = "SELECT \"ID\",\"NAME\",\"BIZ_DATE\",COUNT(DISTINCT(\"DIGEST\")) as \"LEGEND_PERSISTENCE_ERROR_COUNT\" FROM \"MYDB\".\"STAGING_TEMP_STAGING_LP_YOSULF\" as stage GROUP BY \"ID\", \"NAME\", \"BIZ_DATE\" HAVING \"LEGEND_PERSISTENCE_ERROR_COUNT\" > 1 LIMIT 20";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String dataErrorsSqlUpperCase> = "SELECT \"ID\",\"NAME\",\"VERSION\",COUNT(DISTINCT(\"DIGEST\")) as \"LEGEND_PERSISTENCE_ERROR_COUNT\" FROM \"MYDB\".\"STAGING_TEMP_STAGING_LP_YOSULF\" as stage GROUP BY \"ID\", \"NAME\", \"VERSION\" HAVING \"LEGEND_PERSISTENCE_ERROR_COUNT\" > 1 LIMIT 10";
<org.finos.legend.engine.persistence.components.AnsiTestArtifacts: java.lang.String dataErrorsSql> = "SELECT \"id\",\"name\",\"version\",COUNT(DISTINCT(\"digest\")) as \"legend_persistence_error_count\" FROM \"mydb\".\"staging_temp_staging_lp_yosulf\" as stage GROUP BY \"id\", \"name\", \"version\" HAVING \"legend_persistence_error_count\" > 1 LIMIT 20";
return;
}
}