Devart Forums

Code: Select all

static void Main(string[] args)
{
        string str = "User Id=your user;Password=your password;Host=your host;Port=3306;Database=your database;";
        MySqlConnection connection = new MySqlConnection(str);
        connection.LocalFailover = true;
        connection.ConnectionLost += new ConnectionLostEventHandler(connection_ConnectionLost);
        connection.Open();

        MySqlCommand cmd = new MySqlCommand("select * from dept", connection);
        MySqlDependency depend = new MySqlDependency(cmd, 1000);
        depend.OnChange += new Devart.Data.MySql.OnChangeEventHandler(depend_OnChange);
        MySqlDependency.Start(connection);
        Thread.Sleep(500 * 1000); // sleep main thread

        MySqlDependency.Stop(str);
        Console.WriteLine("Finish");
        Console.ReadKey();
}

static void connection_ConnectionLost(object sender, ConnectionLostEventArgs e)
{
        Console.WriteLine("AttemptNumber: {0}", e.AttemptNumber);
        if (e.AttemptNumber < 15)
        {
                // Thread.Sleep(10000)  if need to reduce interval beetween  Reexecute
                e.RetryMode = RetryMode.Reexecute;  // try to reconnect and reexecute check command
        }
        else
                e.RetryMode = RetryMode.Raise; // skip Reexecute and throw exception
}

static void depend_OnChange(object sender, MySqlTableChangeEventArgs e)
{
        Console.WriteLine("{0} was changed.", e.TableName);
}