v0.1.8

Changelog

• 77e0014 Fix MySQL Kafka Topic (#314)
• cca8a08 Handle errors returned from os.Setenv (#311)
• 3231c09 [mysql] Inline buildScanTableQuery (#307)
• 1b2e1b4 [mysql] Kill buildScanTableQueryArgs (#306)
• b5f299e [postgres] Combine scanner.go with cast.go (#304)
• 970631c [postgres] Inline scanTableQuery (#308)
• d627f59 [postgres] Kill scanTableQueryArgs (#305)
• 5eee002 [postgres] Remove casting from primary key values query (#309)
• 637d1ab [postgres] Remove extraneous castColumn test cases (#303)
• 9b870d9 [postgres] Remove unused error return from castColumn (#310)
• 2d3c5db [rdbms] Detect if Scanner is stuck in a loop (#313)
• 7e6d149 [rdbms] Remove error return value from BuildQuery (#312)

v0.1.7

Changelog

• 4ae2868 [debezium] Format time.Time to string in TimestampConverter (#301)
• 98cfb38 [debezium] Return []byte from decimal converters (#302)
• 709c91c [debezium] bytes type for org.apache.kafka.connect.data.Decimal (#296)
• abac22a [postgres] Default to not casting columns (#299)
• 760362b [postgres] Emit float32 values for real columns (#298)
• c094ffa [postgres] Kill PgInetConverter (#297)
• da57cad [postgres] Kill PgTimestampConverter (#295)

v0.1.6

Changelog

• 1790f4b [mysql,postgres] Add option to exclude columns (#289)
• d99c8d2 [postgres] Add native support for inet type (#294)
• 287ae5b [postgres] Remove unused code (#291)
• d100bff [postgres] Support bit primary keys (#293)
• 4ea7bf3 [postgres] Support bytea primary keys (#292)
• b0f1662 [postgres] Use parameterized scanning query (#290)

v0.1.5

Changelog

• e54167b [debezium] Add more DebeziumTransformer test cases (#288)
• aa4a3ca [debezium] Add tests for convertRow (#287)
• 6f32a05 [debezium] Kill Keys.Clone() (#279)
• 144a107 [mysql,postgres] Offset DataTypes by one (#282)
• 3e9ea9a [mysql] Implement ParsePrimaryKeyValue (#283)
• f1aa40b [postgres] Add PgTimeConverter (#274)
• e929431 [postgres] Check primary key data types before scanning (#275)
• ee2b0ce [postgres] Implement ParsePrimaryKeyValue (#281)
• bf16882 [postgres] Kill shouldQuoteValue (#284)
• 0db8d67 [postgres] Make convertToStringForQuery more strict (#278)
• 01877bd [postgres] Reorder data types (#276)
• 2ae4f03 [rdbms] Add generic Column type (#285)
• 9b3ec71 [rdbms] Add scaffolding for parsing primary key value overrides (#280)
• aabe59d [rdbms] Change scanner ParseRow to parse values in-place (#286)

v0.1.4

Changelog

• 7a85861 Bump github.com/stretchr/testify to v1.9.0 (#243)
• 569e8dd Skip MySQL Zero Dates (#262)
• c107e0d [debezium,postgres] Add UUIDConverter (#256)
• 22a3f84 [debezium,postgres] Add geometry value converters (#255)
• 923f831 [debezium] Add transformer package (#259)
• 0c519fa [debezium] Check for negative overflow when coercing ints (#273)
• 608ff84 [debezium] Fix DateConverter for dates > 290 years from 1970 (#265)
• b961365 [debezium] Move RowConverter.Convert to transformer.go (#260)
• 1971532 [debezium] Move partition key building to DebeziumTransformer (#264)
• 173b851 [mysql,postgres] Move row conversion to DebeziumTransformer (#258)
• 6840dfa [mysql] Move handling of 0000-00-00 dates to DateConverter (#263)
• c827c85 [postgers] Add MapConverter for hstore (#254)
• 3f55845 [postgres] Add ArrayConverter (#269)
• 07d0ff4 [postgres] Add MoneyConverter (#248)
• fd5e47c [postgres] Add PgIntervalConverter (#270)
• da415eb [postgres] Add PgTimestampConverter (#252)
• 387fc56 [postgres] Add VariableNumericConverter (#246)
• 06959b1 [postgres] Add passthrough converter for rest of types (#257)
• 9a185de [postgres] Better integration test value for money column type (#249)
• 42a3420 [postgres] Fold values.go into adapter.go (#253)
• ded87b8 [postgres] Reorder ParseValue cases (#272)
• c8f5f96 [postgres] Test variable numeric data type (#247)
• 2ca66f7 [postgres] Use the pgtype package that ships with pgx (#268)
• 38fcf51 [postgres] Use BytesPassthrough converter for bytea type (#244)
• 4ae5894 [postgres] Use DateConverter for date type (#245)
• 42d0f1a [postgres] Use DecimalConverter for numeric columns (#250)
• aaec738 [postgres] Use FloatConverter and DoubleConverter (#271)
• 2a6a410 [postgres] Use JSONConverter for json types (#251)
• dc38dd6 [postgres] Use debezium value converters for bools, ints, and text (#266)

v0.1.3

Changelog

• 03c9fd3 Bump pgx to v5.5.4 (#240)
• 20fc238 [gha] Use prebuilt binary for staticcheck (#242)
• 7fd1a21 [postgres] Add support for bytea type (#241)

v0.1.2

Changelog

• e98415e Update Logging handler (#238)
• e229140 [debezium] Add NewIterator() to Adapter interface (#236)
• 5218f37 [mysql,postgres] Combine shared scanner logic (#230)
• bff4977 [mysql,postgres] Explicit empty table handling (#229)
• 44dd5c5 [mysql,postgres] Load table metadata when initializing (#233)
• 5f5ef6f [mysql,postgres] Move primary key bounds off of Tables (#232)
• acbed69 [mysql,postgres] Remove unused getters (#231)
• cc71d3e [mysql,postgres] Update error messages (#237)
• e4540a5 [mysql] Move Table loading into adapter (#234)
• 182e8c7 [postgres] Move Table loading into adapter (#235)
• 3953d64 [postgres] Stricter column type handling (#239)

v0.1.1

Changelog

• 2b4c6c1 [github] Add GitHub Action to run integration tests (#215)
• 2156dce [mysql] Add integration test scaffolding (#222)
• 2df8894 [mysql] Implement integration test (#223)
• 6a06abf [mysql] Kill InvalidDataType (#221)
• aa65f76 [postgres] Add primary keys integration test (#225)
• 4279a11 [postgres] Add range types to integration test (#213)
• 11d42d9 [postgres] Change castColumn to error for unhandled types (#219)
• 71a3f7b [postgres] Consolidate parsing code in parse package (#217)
• 5c96380 [postgres] Inline keysToValueList (#227)
• ed9600a [postgres] Inline time formatting (#214)
• 62ede9b [postgres] Kill TextThatRequiresEscaping (#212)
• 97e8877 [postgres] Pull out primary key string conversion logic (#226)
• a43127c [postgres] Remove column sanity check (#228)
• ab0b57e [postgres] Rename parse.go to geom.go (#216)
• 60f0d74 [postgres] Rename scan.go to scanner.go (#218)
• fe75cb2 [postgres] Use value type in convertToStringForQuery (#224)

v0.1.0

Changelog

• ca7a833 Allow primary key values to be any type (#170)
• 753aebd Improving our MySQL source work for additional data types (#209)
• 8c9bfb9 Move DebeziumTransformer to lib/debezium (#158)
• c40e263 Move NoRowsError to lib/rdbms (#152)
• ba8b594 Move primary_key package to lib/rdbms (#138)
• d29168c Upgrade to Go 1.22 (#206)
• 9d1e84a [PostgreSQL] Don't escape money. (#182)
• ead713a [debezium] Add DebeziumTransformer tests (#205)
• e32e333 [debezium] Build schema once for transformer (#204)
• 99d1369 [debezium] Implement time converters (#207)
• 5348c08 [dynamodb] Clean up Load method (#169)
• 9727176 [dynamodb] Create separate stores for stream and snapshot mode (#166)
• aa1a646 [dynamodb] Move store methods (#168)
• 6eedbd8 [mysql, postgres] Reorder adapter methods (#162)
• e56fddc [mysql,postgres] Add adapter tests (#167)
• df218e2 [mysql,postgres] Add shared Scanner (#196)
• 0d5c451 [mysql,postgres] Create RetryConfig when building scanners (#178)
• 04b610a [mysql,postgres] Decouple Table structs from config (#174)
• 7b26cb9 [mysql,postgres] Move optional primary key parsing to config (#172)
• 0e5d604 [mysql,postgres] Move pk updating to Scanner (#201)
• 43a98a0 [mysql,postgres] Move primary key overriding to snapshot (#173)
• 4964407 [mysql,postgres] Pull primary_key.Keys out of Tables (#190)
• 5217737 [mysql,postgres] Stop scanning if min pk values = max pk values (#189)
• 637ec1d [mysql] Add Debezium adapter (#160)
• 22dec4f [mysql] Add DescribeTable function (#116)
• 7611e66 [mysql] Add GetPrimaryKeys function (#136)
• 7ee4713 [mysql] Add Table struct (#135)
• b52a6cc [mysql] Add config struct (#112)
• 53065a7 [mysql] Add queries to get primary key bounds (#140)
• 7ceb9bd [mysql] Add scan query (#180)
• 3b17a3e [mysql] Add snapshot stub (#154)
• 7be9955 [mysql] Add stubbed scanner (#161)
• 4bf9639 [mysql] Add value converters (#203)
• cd511c8 [mysql] Always use inclusive upper bound for scans (#188)
• 65b6283 [mysql] Enable MySQL (#117)
• 8d132e1 [mysql] Fix primary keys bug; build scanner query (#181)
• a54c161 [mysql] Implement ConvertRowToDebezium for adapter (#164)
• bdf6f74 [mysql] Implement full MySQL driver type handling (#194)
• 8e206b0 [mysql] Instantiate table primary keys (#141)
• 9fc999b [mysql] Remove NOT from scan query and swap comparison (#186)
• c1f2707 [mysql] Working scanner (#183)
• 8715269 [postgres] Add ColumnToField function (#132)
• 5f40171 [postgres] Add schema.GetPrimaryKeys (#108)
• 228064c [postgres] Add adapter for DebeziumTransformer (#156)
• f2be495 [postgres] Add function to get both upper and lower pk bounds (#111)
• fbab159 [postgres] Add functions to get the bounds of primary keys (#110)
• 2726419 [postgres] Add geometry/geography to integration test (#210)
• 63506fe [postgres] Add integration test (#208)
• edb6d7a [postgres] Add scanning integration test (#211)
• 4cbc565 [postgres] Always use inclusive upper bound for scans (#187)
• 5a41f44 [postgres] Build start and end pk values at same time (#199)
• c592b1b [postgres] Change castColumn to accept Column struct (#119)
• 8e503f1 [postgres] Clean up ParseValue (#202)
• ef9dd12 [postgres] Combine functions for fetching primary key values (#143)
• 5b3d151 [postgres] Convert time.Time values to string at query time (#200)
• 8f3bd45 [postgres] Escape primary keys in scan query (#171)
• 6244a11 [postgres] Fix TestShouldQuoteValue test cases (#146)
• 796e392 [postgres] Fix bug with handling empty tables (#150)
• 02797b9 [postgres] Inline ColumnsToFields and add test (#163)
• d8974a8 [postgres] Inline call to GetOptionalSchema (#144)
• 5099150 [postgres] Kill Comparison (#184)
• 2a1600d [postgres] Kill Fields.fieldKeyToDataTypes (#129)
• 809bdd5 [postgres] Kill Fields (#133)
• 709412e [postgres] Kill context.go (#123)
• 725b759 [postgres] Kill findPrimaryKeys (#109)
• af27bec [postgres] Kill extra query for table columns (#113)
• 5c0217d [postgres] Modify shouldQuoteValue to check types directly (#147)
• 324d086 [postgres] Move Debezium payload creation to MessageBuilder (#130)
• 3653c17 [postgres] Move Fields off of Table (#127)
• 3d7ec28 [postgres] Move KeysToValueList calls to scanTableQuery (#137)
• 9cb36fc [postgres] Move Table.PartitionKey to DebeziumTransformer (#151)
• 8eda351 [postgres] Move TopicSuffix to DebeziumTransformer (#153)
• 0e88262 [postgres] Move fields.go to sources/postgres/transformer (#148)
• 82b21d0 [postgres] Move getOptionalSchema to primary_keys.go (#131)
• 5f6c045 [postgres] Move scanTableQuery to scan.go (#120)
• 624d6a0 [postgres] Move toDebeziumType to fields.go (#142)
• 0d3752f [postgres] Move casting to scan function (#121)
• f3f0ab7 [postgres] Move pg to Debezium conversion (#128)
• d9b7db8 [postgres] Move primary key casting to schema (#124)
• 71cb940 [postgres] Pass DataType to shouldQuoteValue (#149)
• 6d6cec6 [postgres] Pull fields out of ParseValue (#122)
• ed33aac [postgres] Refactor out call to ParseValue (#145)
• 3dfed27 [postgres] Remove redundant pk fmt.Sprint() calls (#197)
• 9ba27f6 [postgres] Remove unused field (#114)
• cb57ebb [postgres] Rename DebeziumTransformer receiver variables (#155)
• 9eaec7e [postgres] Rename MessageBuilder to DebeziumTransformer (#134)
• d602649 [postgres] Rename transformer package to adapter (#159)
• 2cfaa94 [postgres] Return early during scan when no rows (#175)
• 8293c85 [postgres] Stop recording scanned_and_parsed metrics (#157)
• e8ffae8 [postgres] Store Column structs on table (#118)
• 52574c1 [postgres] Test logic for quoting values in scan query (#139)
• a9ff1fc [postgres] Use WithRetries (#177)
• 1804602 [postgres] Use keyColumns for column type (#125)
• 504f0a2 [postgres] Use table columns for types when scanning (#126)
• a7f47c3 [postgres] move PopulateColumns (#115)
• 64dfcd0 [rdbms] Change primary_key Upsert to UpdateStartingValue (#191)
• cdc143d [rdbms] Rename Keys to KeyNames (#193)
• 6c7856f interface{} -> any (#192)

v0.0.25

Changelog

• 45f8eda Add a stateless postgres describe table function (#106)
• e3f6eba Add a test for Fields.AddField (#104)
• 49c882e Add more colKindToDataType tests (#103)
• cb3c59d Consolidate postgres schema code (#105)
• 46933e9 Split up postgres column tests (#102)
• a3a1a3b Using Null metrics provider if none is available (#107)