Code

🎉 JDBC sources: emit cursor counts#15535

Code

Merged

tuliren merged 49 commits intomasterairbytehq/airbyte:masterfrom liren/emit-record-countairbytehq/airbyte:liren/emit-record-countCopy head branch name to clipboardOct 14, 2022

+538-190

Commits

Commits on Aug 11, 2022

• Add cursor_record_count to db stream state

  tuliren

  committed
  32cb097

• Add cursor record count to cursor info

  tuliren

  committed
  ad10bf7

• Emit max cursor record count

  tuliren

  committed
  340ba3e

• Add original cursor record count

  tuliren

  committed
  cd497bb

• Unify logging format

  tuliren

  committed
  c80eaee

Commits on Aug 12, 2022

• Add backward compatible methods

  tuliren

  committed
  8c95bcf

Commits on Sep 6, 2022

• Merge branch 'master' into liren/emit-record-count

  tuliren

  authored
  8db6c21

• Update unit tests for state decorating iterator

  tuliren

  committed
  2ff5bf1

Commits on Oct 10, 2022

• Update test (not done yet)

  tuliren

  committed
  2c5be9c

• Merge branch 'master' of github.com:airbytehq/airbyte into liren/emit-record-count

  tuliren

  committed
  23b4953

• Fix one more unit test

  tuliren

  committed
  e17adeb

• Change where clause operator according to record count

  tuliren

  committed
  04df4fd

• Add branch for null cursor

  tuliren

  committed
  7b2f949

• Skip saving record count when it is 0

  tuliren

  committed
  27327cd

• Fix log wording

  tuliren

  committed
  9537714

• Set mock record count in test

  tuliren

  committed
  bb936a2

• Check cursor value instead of cursor info

  tuliren

  committed
  3248cf5

• Fix source jdbc test

  tuliren

  committed
  6d80323

• Read record count from state

  tuliren

  committed
  1b27a96

• Fix tests

  tuliren

  committed
  7bcf668

Commits on Oct 11, 2022

• Add an acceptance test case

  tuliren

  committed
  28ed907

• Merge branch 'master' into liren/emit-record-count

  tuliren

  authored
  57c01e6

• Fix npe

  tuliren

  committed
  ab22b55

• Change record count from int to long to avoid type conversion

  tuliren

  committed
  7ec2a7c

• Fix references

  tuliren

  committed
  34676c8

• Fix oracle container

  tuliren

  committed
  2a5bbd4

• Use uppercase for snowflake

  tuliren

  committed
  fdfd6e6

• Use uppercase for db2

  tuliren

  committed
  3665f2c

• Fix and use uppercase

  tuliren

  committed
  8b0952f

• Update test case to include the edge case

  tuliren

  committed
  f6086cc

Commits on Oct 13, 2022

• Merge branch 'master' of github.com:airbytehq/airbyte into liren/emit-record-count

  tuliren

  committed
  0a6ac5e

• Format code

  tuliren

  committed
  b8ade77

• Remove extra assertion in clickhouse

  tuliren

  committed
  446909d

• Merge ms sql incremental query method

  tuliren

  committed
  59b308f

• Log query for debugging

  tuliren

  committed
  1d88be9

• Clean up name_and_timestamp table

  tuliren

  committed
  cbd2221

• Fix db2 tests

  tuliren

  committed
  e4e230c

• Fix mssql tests

  tuliren

  committed
  fe04161

• Fix oracle tests

  tuliren

  committed
  43a7173

• Fix oracle tests

  tuliren

  committed
  645a272

• Fix cockroachdb tests

  tuliren

  committed
  9d84d2d

• Fix snowflake tests

  tuliren

  committed
  b9e592d

• Add changelog

  tuliren

  committed
  c44c18a

Commits on Oct 14, 2022

• Fix mssql tests

  tuliren

  committed
  b05c68f

• Fix db2-strict-encrypt tests

  tuliren

  committed
  bd1fe12

• Fix oracle-strict-encrypt tests

  tuliren

  committed
  4811679

• Bump postgres version

  tuliren

  committed
  2da3eae

• Fix oracle-strict-encrypt tests

  tuliren

  committed
  4764b0c

• auto-bump connector version [ci skip]

  octavia-squidington-iii

  committed
  750e002