Skip to content

Commit

Permalink
add source
Browse files Browse the repository at this point in the history
  • Loading branch information
maksenius committed Jan 23, 2023
1 parent 2115493 commit 63210cc
Show file tree
Hide file tree
Showing 10 changed files with 4 additions and 1,326 deletions.
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ If a record contains a `sqlserver.table` property in its metadata it will be ins
to use the table configured in the connector. Thus, a Destination can support multiple tables in a single connector,
as long as the user has proper access to those tables.

### Source
## Source

The source connects to the database using the provided connection and starts creating records for each table row
and each detected change.
Expand Down
4 changes: 2 additions & 2 deletions columntypes/columntypes.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,8 +29,8 @@ import (
const (
// sql server date, time column types.
dateType = "date"
datetime2Type = "datetime2Type"
datetimeType = "datetimeType"
datetime2Type = "datetime2"
datetimeType = "datetime"
datetimeOffsetType = "datetimeoffset"
smallDateTimeType = "smalldatetime"
timeType = "time"
Expand Down
3 changes: 1 addition & 2 deletions connector.go
Original file line number Diff line number Diff line change
Expand Up @@ -17,12 +17,11 @@ package sqlserver
import (
sdk "github.com/conduitio/conduit-connector-sdk"

"github.com/conduitio-labs/conduit-connector-sql-server/destination"
"github.com/conduitio-labs/conduit-connector-sql-server/source"
)

var Connector = sdk.Connector{
NewSpecification: Specification,
NewSource: source.New,
NewDestination: destination.New,
NewDestination: nil,
}
118 changes: 0 additions & 118 deletions destination/destination.go

This file was deleted.

Loading

0 comments on commit 63210cc

Please sign in to comment.