Add more columns

getdozer · Mar 20, 2024 · 6ceca51 · 6ceca51
1 parent a7fdf85
commit 6ceca51
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/dozer-ingestion/aerospike/src/connector.rs b/dozer-ingestion/aerospike/src/connector.rs
@@ -489,7 +489,7 @@ impl Connector for AerospikeConnector {
                                     .iter()
                                     .map(|name| FieldDefinition {
                                         name: name.clone(),
-                                        typ: if name == "inserted_at" {
+                                        typ: if name == "lut" {
                                             FieldType::Timestamp
                                         } else if name == "PK" {
                                             FieldType::UInt
@@ -715,7 +715,7 @@ async fn map_record(
         }
     }
 
-    if let Some((index, _)) = columns_map.get("inserted_at") {
+    if let Some((index, _)) = columns_map.get("lut") {
         // Create a NaiveDateTime from the timestamp
         let naive = NaiveDateTime::from_timestamp_millis(event.lut as i64)
             .ok_or(AerospikeConnectorError::InvalidTimestamp(event.lut as i64))?;

diff --git a/dozer-sink-oracle/src/lib.rs b/dozer-sink-oracle/src/lib.rs
@@ -299,7 +299,7 @@ impl OracleSinkFactory {
         }
 
         if !(self.validate_table(connection, table, schema)?) {
-            let table_query = format!("CREATE TABLE {table} ({})", column_defs.join(",\n"));
+            let table_query = format!("CREATE TABLE {table} ({}, DST_INSERTED_AT TIMESTAMP DEFAULT CURRENT_TIMESTAMP)", column_defs.join(",\n"));
             info!("### CREATE TABLE ####\n{}", table_query);
             connection.execute(&table_query, &[])?;
         }