Hi all! I m trying to synchronize two databases, one local and one remote. The problem is that I have two connections open at once and do not know how. If the two databases I have them locally if I correctly updated because they use the same connection. The problem I have is that the local board to update the program does not see it because the connection is not open, how I can do? This is my code. Two databases have the same table estructure but user/pass and different database name. Thank you!
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using MySql.Data;
using MySql.Data.MySqlClient;
namespace sincronizacion
{
public partial class Form1 : Form
{
private string stringConexionLocal ="server=localhost;database=kiosco_m;UID=root;pwd=toor";
private string stringConexionRemota = "server="ipserverremote";database=grupoorb_kioscom;UID=user_remote;pwd=pass_remote";
//Instanciado de objetos conexión local
MySqlConnection conexionLocal;
MySqlDataAdapter dataAdapterLocal;
DataSet dataSetLocal;
MySqlCommandBuilder builderLocal;
//Instanciado de objetos conexión remota
MySqlConnection conexionRemota;
MySqlDataAdapter dataAdapterRemota;
DataSet dataSetRemoto;
MySqlCommandBuilder builderRemoto;
public Form1()
{
InitializeComponent();
时 时
private void CargarDatosLocal()
{
string Consulta = "SELECT * FROM empresas";
try
{
conexionLocal = new MySqlConnection(this.stringConexionLocal);
dataAdapterLocal = new MySqlDataAdapter(Consulta, conexionLocal);
dataSetLocal = new DataSet();
dataAdapterLocal.Fill(dataSetLocal, "empresas");
builderLocal = new MySqlCommandBuilder(dataAdapterLocal);
dataGridView1.DataSource = dataSetLocal;
dataGridView1.DataMember = "empresas";
时 时
catch (MySqlException ex)
{
MessageBox.Show(ex.Message, "Error al intentar conectarse a la BBDD local.", MessageBoxButtons.OK, MessageBoxIcon.Error);
时 时
时 时
private void CargarDatosRemoto()
{
string Consulta = "SELECT * FROM empresas";
try
{
conexionRemota = new MySqlConnection(this.stringConexionRemota);
dataAdapterRemota = new MySqlDataAdapter(Consulta, conexionRemota);
dataSetRemoto = new DataSet();
dataAdapterRemota.Fill(dataSetRemoto, "empresas");
builderRemoto = new MySqlCommandBuilder(dataAdapterRemota);
dataGridView2.DataSource = dataSetRemoto;
dataGridView2.DataMember = "empresas";
时 时
catch (MySqlException ex)
{
MessageBox.Show(ex.Message, "Error al intentar conectarse a la BBDD Remota.", MessageBoxButtons.OK, MessageBoxIcon.Error);
时 时
时 时
private void Sincronizar(string miConexionRemota)
{
MySqlConnection miConexion = new MySqlConnection(miConexionRemota);
miConexion.Open();
MySqlCommand comando = new MySqlCommand();
MySqlTransaction transaccion;
// Empieza la transacción
transaccion = miConexion.BeginTransaction(System.Data.IsolationLevel.ReadCommitted);
comando.Transaction = transaccion;
comando.Connection = miConexion;
try
{
comando.CommandText = "UPDATE kiosco_remoto.empresas INNER JOIN kiosco_m.empresas ON kiosco_remoto.empresas.Id = kiosco_m.empresas.Id SET kiosco_remoto.empresas.direccion = kiosco_m.empresas.direccion";
comando.ExecuteNonQuery();
transaccion.Commit();
MessageBox.Show("Se han sincronizado las BBDD correctamente.", "Información", MessageBoxButtons.OK, MessageBoxIcon.Information);
时 时
catch (MySqlException ex)
{
transaccion.Rollback();
MessageBox.Show(ex.Message, "Error al intentar sincronizar.", MessageBoxButtons.OK, MessageBoxIcon.Error);
//throw ex;
时 时
finally
{
CargarDatosLocal();
CargarDatosRemoto();
miConexion.Close();
时 时
时 时
/* * *
*
* Eventos
*
* * */
private void botonLocal_Click(object sender, EventArgs e)
{
CargarDatosLocal();
时 时
private void botonCargaDatosRemoto_Click(object sender, EventArgs e)
{
CargarDatosRemoto();
时 时
private void botonGrabarBDLocal_Click(object sender, EventArgs e)
{
try
{
builderLocal.GetUpdateCommand();
dataAdapterLocal.Update(dataSetLocal, "empresas");
CargarDatosLocal();
时 时
catch (NullReferenceException ex)
{
MessageBox.Show(ex.Message, "No hay ninguna BBDD abierta.", MessageBoxButtons.OK, MessageBoxIcon.Error);
时 时
时 时
private void botonGrabarBDRemota_Click(object sender, EventArgs e)
{
try
{
builderRemoto.GetUpdateCommand();
dataAdapterRemota.Update(dataSetRemoto, "empresas");
CargarDatosRemoto();
时 时
catch (NullReferenceException ex)
{
MessageBox.Show(ex.Message, "No hay ninguna BBDD abierta.", MessageBoxButtons.OK, MessageBoxIcon.Error);
时 时
时 时
private void Form1_FormClosing(object sender, FormClosingEventArgs e)
{
try
{
conexionLocal.Close();
conexionRemota.Close();
if ((conexionLocal != null) || (conexionRemota != null))
{
MessageBox.Show("Se han cerrado todas las conexiones abiertas.", "Información", MessageBoxButtons.OK, MessageBoxIcon.Information);
时 时
时 时
catch
{
// No hago nada.
时 时
时 时
private void botonSincro_Click(object sender, EventArgs e)
{
Sincronizar(stringConexionRemota);
时 时
时 时
时 时