@@ -87,7 +87,7 @@ STEP 5: Look at the program:
87
87
slave::Slave* sl = NULL;
88
88
89
89
void callback(const slave::RecordSet& event) {
90
- slave::Slave::binlog_pos_t sBinlogPos = sl->getLastBinlog ();
90
+ slave::Position sBinlogPos = sl->getLastBinlogPos ();
91
91
switch (event.type_event) {
92
92
case slave::RecordSet::Update: std::cout << "UPDATE" << "\n"; break;
93
93
case slave::RecordSet::Delete: std::cout << "DELETE" << "\n"; break;
@@ -104,6 +104,7 @@ STEP 5: Look at the program:
104
104
int main(int argc, char** argv)
105
105
{
106
106
slave::MasterInfo masterinfo;
107
+ slave::Position position("mysql-bin", 0);
107
108
masterinfo.conn_options.mysql_host = "127.0.0.1";
108
109
masterinfo.conn_options.mysql_port = 3306;
109
110
masterinfo.conn_options.mysql_user = "root";
@@ -113,7 +114,7 @@ STEP 5: Look at the program:
113
114
slave::DefaultExtState sDefExtState;
114
115
slave::Slave slave(masterinfo, sDefExtState);
115
116
sl = &slave;
116
- sDefExtState.setMasterLogNamePos("mysql-bin", 0 );
117
+ sDefExtState.setMasterPosition(position );
117
118
slave.setCallback("test", "test", callback);
118
119
slave.init();
119
120
slave.createDatabaseStructure();
0 commit comments