Skip to content

Commit 92e1f31

Browse files
committed
changes according to feedback
1 parent 0063de5 commit 92e1f31

File tree

9 files changed

+27
-76
lines changed

9 files changed

+27
-76
lines changed

embulk-input-oracle/README.md

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -149,3 +149,21 @@ in:
149149
```
150150
$ ./gradlew gem
151151
```
152+
153+
Running tests:
154+
You need to add ojdbcj.jar to embulk-input-oracle/driver
155+
156+
Also oracle.yml is needed
157+
```
158+
type: oracle
159+
host: localhost
160+
port: 1521
161+
database: xe
162+
user: system
163+
password: pass
164+
```
165+
166+
To run tests for oracle project only
167+
```
168+
$ EMBULK_INPUT_ORACLE_TEST_CONFIG=oracle.yml ./gradlew :embulk-input-oracle:check --info
169+
```

embulk-input-oracle/src/main/java/org/embulk/input/oracle/getter/OracleColumnGetterFactory.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
import org.embulk.input.jdbc.JdbcInputConnection;
77
import org.embulk.input.jdbc.getter.ColumnGetter;
88
import org.embulk.input.jdbc.getter.ColumnGetterFactory;
9-
import org.embulk.input.jdbc.getter.TimestampWithTimeZoneIncrementalHandler;
9+
import org.embulk.input.jdbc.getter.TimestampWithoutTimeZoneIncrementalHandler;
1010
import org.embulk.spi.PageBuilder;
1111
import org.joda.time.DateTimeZone;
1212

@@ -25,9 +25,9 @@ public ColumnGetter newColumnGetter(JdbcInputConnection con, AbstractJdbcInputPl
2525

2626
switch (column.getTypeName()) {
2727
case "DATE":
28-
return new TimestampWithTimeZoneIncrementalHandler(getter);
28+
return new TimestampWithoutTimeZoneIncrementalHandler(getter);
2929
case "TIMESTAMP":
30-
return new TimestampWithTimeZoneIncrementalHandler(getter);
30+
return new TimestampWithoutTimeZoneIncrementalHandler(getter);
3131
default:
3232
return getter;
3333
}

embulk-input-oracle/src/main/java/org/embulk/input/oracle/getter/OracleTimestampWithTimeZoneIncrementalHandler.java

Lines changed: 0 additions & 67 deletions
This file was deleted.
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
11
table: load
2-
last_record: ['2016-11-02T02:00:04.000000Z']
2+
last_record: ['2016-11-02T04:00:04.000000']
33
incremental: true
44
incremental_columns: [dt]
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,3 @@
11
in:
2-
last_record: ['2016-11-02T02:00:04.000000Z']
2+
last_record: ['2016-11-02T04:00:04.000000']
33
out: {}
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,3 @@
11
in:
2-
last_record: ['2016-11-02T02:00:06.000000Z']
2+
last_record: ['2016-11-02T04:00:06.000000']
33
out: {}
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
11
table: load
2-
last_record: ['2016-11-02T02:00:05.333003Z']
2+
last_record: ['2016-11-02T04:00:05.333003']
33
incremental: true
44
incremental_columns: [ts]
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,3 @@
11
in:
2-
last_record: ['2016-11-02T02:00:05.333003Z']
2+
last_record: ['2016-11-02T04:00:05.333003']
33
out: {}
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,3 @@
11
in:
2-
last_record: ['2016-11-02T02:00:06.000000Z']
2+
last_record: ['2016-11-02T04:00:06.000000']
33
out: {}

0 commit comments

Comments
 (0)