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)