MySQLReader simple application
The following application will write change data for the specified table to SysOut. Replace wauser
and ******
with the user name and password for the MySQL account you created for use by MySQLReader (see MySQL setup) and mydb
and mytable
with the names of the database and table(s) to be read.
CREATE APPLICATION MySQLTest; CREATE SOURCE MySQLCDCIn USING MySQLReader ( Username:'striim', Password:'******', ConnectionURL:'mysql://192.168.1.10:3306', Database:'mydb', Tables:'mytable' ) OUTPUT TO MySQLCDCStream; CREATE TARGET MySQLCDCOut USING SysOut(name:MySQLCDC) INPUT FROM MySQLCDCStream; END APPLICATION MySQLTest;