Skip to content

Commit 6bb351d

Browse files
author
taherkl
committed
widerow: add missing changes
1 parent 757988d commit 6bb351d

File tree

4 files changed

+6
-6821
lines changed

4 files changed

+6
-6821
lines changed

v2/spanner-to-sourcedb/src/test/java/com/google/cloud/teleport/v2/templates/SpannerToMySqlSourceDbWideRowMaxColumnsIT.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -150,15 +150,15 @@ public void spannerToMySQLSourceDbMaxColTest()
150150
private void writeRowsInSpanner() {
151151
List<Mutation> mutations = new ArrayList<>();
152152
Mutation.WriteBuilder mutationBuilder =
153-
Mutation.newInsertOrUpdateBuilder(TABLE1).set("Id").to("SampleTest");
153+
Mutation.newInsertOrUpdateBuilder(TABLE1).set("id").to("SampleTest");
154154

155-
for (int i = 1; i < 1024; i++) {
156-
mutationBuilder.set("Col_" + i).to("TestValue_" + i);
155+
for (int i = 1; i <= 100; i++) {
156+
mutationBuilder.set("col_" + i).to("TestValue_" + i);
157157
}
158158

159159
mutations.add(mutationBuilder.build());
160160
spannerResourceManager.write(mutations);
161-
LOG.info("Inserted row with 1,024 columns into Spanner using Mutations");
161+
LOG.info("Inserted row with 100 columns into Spanner using Mutations");
162162
}
163163

164164
private final List<Throwable> assertionErrors = new ArrayList<>();
@@ -175,7 +175,7 @@ private void assertRowInMySQL() throws MultipleFailureException {
175175
assertThat(rows).hasSize(1);
176176
Map<String, Object> row = rows.get(0);
177177
for (int i = 1; i <= 100; i++) {
178-
String columnName = "Col_" + i;
178+
String columnName = "col_" + i;
179179
String expectedValue = "TestValue_" + i;
180180

181181
try {

0 commit comments

Comments
 (0)