Skip to content

Commit fa95b67

Browse files
committed
fix table name
1 parent 4c47096 commit fa95b67

File tree

5 files changed

+9
-9
lines changed

5 files changed

+9
-9
lines changed

v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/SpannerTransactionWriterDoFnTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -204,7 +204,7 @@ public void testProcessElement() {
204204
Mutation.WriteBuilder shadowBuilder = Mutation.newInsertOrUpdateBuilder("shadow_Users");
205205
shadowBuilder.set("first_name").to("Johnny");
206206
shadowBuilder.set("last_name").to("Depp");
207-
shadowBuilder.set("timestamp").to(12345);
207+
shadowBuilder.set("shadow_timestamp").to(12345);
208208
shadowBuilder.set("log_file").to("");
209209
shadowBuilder.set("log_position").to(-1);
210210
Mutation expectedShadowMutation = shadowBuilder.build();

v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/datastream/MySqlChangeEventSequenceTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ public void testCreateFromShadowTableWithUseSqlStatements() throws Exception {
111111
.column("id")
112112
.int64()
113113
.endColumn()
114-
.column("timestamp")
114+
.column("shadow_timestamp")
115115
.int64()
116116
.endColumn()
117117
.column("log_file")
@@ -131,7 +131,7 @@ public void testCreateFromShadowTableWithUseSqlStatements() throws Exception {
131131
// Mock the behavior of the transaction context
132132
Struct mockRow = mock(Struct.class);
133133
when(mockRow.getLong("id")).thenReturn(1L);
134-
when(mockRow.getLong("timestamp")).thenReturn(1615159728L); // Updated to match new column
134+
when(mockRow.getLong("shadow_timestamp")).thenReturn(1615159728L); // Updated to match new column
135135
when(mockRow.getString("log_file")).thenReturn("file1.log");
136136
when(mockRow.getLong("log_position")).thenReturn(2L); // Updated to match new column
137137

v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/datastream/OracleChangeEventSequenceTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ public void testCreateFromShadowTableWithUseSqlStatements_Oracle() throws Except
7575
.column("id")
7676
.int64()
7777
.endColumn()
78-
.column("timestamp")
78+
.column("shadow_timestamp")
7979
.int64()
8080
.endColumn()
8181
.column("scn")
@@ -92,7 +92,7 @@ public void testCreateFromShadowTableWithUseSqlStatements_Oracle() throws Except
9292
// Mock the behavior of the transaction context
9393
Struct mockRow = mock(Struct.class);
9494
when(mockRow.getLong("id")).thenReturn(1L);
95-
when(mockRow.getLong("timestamp")).thenReturn(1615159728L);
95+
when(mockRow.getLong("shadow_timestamp")).thenReturn(1615159728L);
9696
when(mockRow.getLong("scn")).thenReturn(100L);
9797

9898
ResultSet mockResultSet = mock(ResultSet.class);

v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/datastream/PostgresChangeEventSequenceTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,7 @@ public void testCreateFromShadowTableWithUseSqlStatements_Postgres() throws Exce
124124
.column("id")
125125
.int64()
126126
.endColumn()
127-
.column("timestamp")
127+
.column("shadow_timestamp")
128128
.int64()
129129
.endColumn()
130130
.column("lsn")
@@ -141,7 +141,7 @@ public void testCreateFromShadowTableWithUseSqlStatements_Postgres() throws Exce
141141
// Mock the behavior of the transaction context
142142
Struct mockRow = mock(Struct.class);
143143
when(mockRow.getLong("id")).thenReturn(1L);
144-
when(mockRow.getLong("timestamp")).thenReturn(1615159728L);
144+
when(mockRow.getLong("shadow_timestamp")).thenReturn(1615159728L);
145145
when(mockRow.getString("lsn")).thenReturn("0/123456");
146146

147147
ResultSet mockResultSet = mock(ResultSet.class);

v2/datastream-to-spanner/src/test/java/com/google/cloud/teleport/v2/templates/spanner/ProcessInformationSchemaTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -455,7 +455,7 @@ public void canCreateShadowTablesInSpanner() throws Exception {
455455
+ "\t`timestamp_field` TIMESTAMP,\n"
456456
+ "\t`date_field` DATE,\n"
457457
+ "\t`id` INT64,\n"
458-
+ "\t`timestamp` INT64,\n"
458+
+ "\t`shadow_timestamp` INT64,\n"
459459
+ "\t`log_file` STRING(MAX),\n"
460460
+ "\t`log_position` INT64,\n"
461461
+ ") PRIMARY KEY (`first_name` ASC, `last_name` DESC, `age` ASC, `bool_field` ASC, `int64_field` ASC, `float64_field` ASC, `string_field` ASC, `bytes_field` ASC, `timestamp_field` ASC, `date_field` ASC, `id` ASC)");
@@ -500,7 +500,7 @@ public void canCreateShadowTablesInSpanner_separateDb() throws Exception {
500500
Collections.singletonList(
501501
"CREATE TABLE `shadow_table2` (\n"
502502
+ "\t`id` INT64,\n"
503-
+ "\t`timestamp` INT64,\n"
503+
+ "\t`shadow_timestamp` INT64,\n"
504504
+ "\t`log_file` STRING(MAX),\n"
505505
+ "\t`log_position` INT64,\n"
506506
+ ") PRIMARY KEY (`id` ASC)");

0 commit comments

Comments
 (0)