Skip to content

Latest commit

 

History

History
 
 

mysql

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
DEVELOPMENT_NOTES.md
DEVELOPMENT_NOTES.md
 
 
README.md
README.md
 
 
adaptor_test.go
adaptor_test.go
 
 
client.go
client.go
 
 
client_test.go
client_test.go
 
 
logo-mysql-170x115.png
logo-mysql-170x115.png
 
 
mysql.go
mysql.go
 
 
mysql_test.go
mysql_test.go
 
 
reader.go
reader.go
 
 
reader_test.go
reader_test.go
 
 
session.go
session.go
 
 
tailer.go
tailer.go
 
 
tailer_test.go
tailer_test.go
 
 
writer.go
writer.go
 
 
writer_test.go
writer_test.go
 
 

README.md

MySQL adaptor

Using the adaptor

You need to specify a sink and source like so:

var source = mysql({
  "uri": "mysql://user:[email protected]:11111/database?ssl=custom",
  "tail": true,
  "cacert": "/path/to/source.crt",
})

var sink = mysql({
  "uri": "mysql://user:[email protected]:22222/database?ssl=custom",
  "cacert": "/path/to/sink.crt",
  "servername": "sink.host.com",
})

t.Source("source", source, "/.*/").Save("sink", sink, "/.*/")
  • tailing is optional and only makes sense on the source
  • For TLS you can use ssl=true which does unverified TLS or ssl=custom in which case you need to supply the cacert.
  • You don't need to supply the servername, but if you do the certificate will be verified against it

Requirements

  • The source must allow the connecting user to query the binlog
  • Per Postgresql you need to create the sink/destination table structure first

Limitations

  • Note that per the Postgresql adaptor this probably isn't very performant at copying huge databases as there is no bulk option yet.
  • Has only been developed and tested using MySQL as the sink and source. Unsure how it will function when combined with other adaptors.