[SOLUCIONADO] Openquery y merge

[Azor]

Buenos días a todos!

En un servidor de SQL Server2012 tengo vinculado/linkado uno de MySql. Intento actualizar datos desde SQLServer hacia Mysql con merge, de la siguiente forma:

Código SQL:

MERGE INTO OPENQUERY(SERVIDOR_MYSQL, 'SELECT campo1, campo2, campo3, campo4 FROM [SRV_VINCULADO].[bd].[tabla1]') AS DESTINO
USING [BD_ORIGEN].[dbo].[tabla1] AS ORIGEN
    ON (ORIGEN.campo1 = DESTINO.campo1 AND ORIGEN.campo2 = DESTINO.campo2)
WHEN MATCHED THEN UPDATE
    SET DESTINO.campo3 = ORIGEN.campo3,
        DESTINO.campo4 = ORIGEN.campo4
WHEN NOT MATCHED THEN INSERT 
    VALUES(ORIGEN.campo1,
           ORIGEN.campo2,
           ORIGEN.campo3,
           ORIGEN.campo4)
WHEN NOT MATCHED BY SOURCE THEN DELETE;
 

El problema está en el alias 'DESTINO', pues no me lo reconoce y no puedo hacer el update.

He probado varias opciones para intentar solucionarlo como ésto

Código SQL:

MERGE INTO OPENQUERY(SERVIDOR_MYSQL, 'SELECT campo1, campo2, campo3, campo4 FROM tabla1') AS DESTINO
MERGE INTO OPENQUERY(SERVIDOR_MYSQL, 'SELECT campo1, campo2, campo3, campo4 FROM [SRV_VINCULADO].[tabla1]') AS DESTINO
 

pero nada , por favor alguien me podría ayudar?

Saludos y gracias

[Azor]

Bueno, por suerte una alma caritativa (a la que le agradezco mucho la ayuda), me echó una mano indicándome que utilizara una CTE para mi sql, quedando algo parecido a ésto:

Código SQL:

WITH DESTINO AS (
   SELECT empresa, campo1, campo2, campo3, campo4
   FROM OPENQUERY(SERVIDOR_MYSQL, 'campo1, campo2, campo3, campo4 FROM SRV_VINCULADO.bd.tabla1')
)
MERGE INTO DESTINO
USING ([BD_ORIGEN].[dbo].[tabla1]) AS ORIGEN
   ON (ORIGEN.campo1 = DESTINO.campo1 AND ORIGEN.campo2 = DESTINO.campo2)
 WHEN MATCHED THEN UPDATE
      SET DESTINO.campo3 = ORIGEN.campo3,
          DESTINO.campo4 = ORIGEN.campo4
WHEN NOT MATCHED THEN INSERT 
      VALUES(ORIGEN.campo1,
             ORIGEN.campo2,
             ORIGEN.campo3,
             ORIGEN.campo4)
WHEN NOT MATCHED BY SOURCE THEN DELETE;
 

Con lo cual, el alias ya no es un problema, pero la selec ahora me devuelve el siguiente error:

"El destino de una instrucción MERGE no puede ser una tabla remota, una vista remota o una vista sobre tablas remotas"

Merge me facilita mucho el trabajo a la hora de estar actualizando/insertando registros en mysql, pero parece que tiene la "limitación" que describe el error anterior.

El servidor de SQLSERVER lo tengo en local, pero el de MYSQL está alojado fuera.

El sentido de la inserción siempre sería de SQLSERVER > MYSQL, nunca a la inversa.

Alguien se ha encontrado con algo parecido?


Muchas gracias!

[Azor]

Hola de nuevo!

Igual estoy intentando solucionar el problema de forma equivocada, por lo que les planteo el objetivo de nuevo a ver si alguien me puede orientar de alguna forma.

Objetivo general:
Necesito poder leer registros de tablas de una bd sqlserver que está en local y grabarlos o actualizarlos en una bd mysql remota.

Para conseguir el objetivo pensé en linkar los dos servidores de SQLServer.
Utilizar la sentencia Merge me parecía la opción ideal para sincronizar la información entre los dos servidores, pero parece "merge" no puede grabar datos en una tabla de un servidor remoto, ¿qué otro planteamiento podrían ofrecerme para conseguir mi objetivo?

¿Alguna idea?

Saludos.

[Libras]

El clasico insert donde no esta update donde si usando left joins :)

Código SQL:

INSERT INTO tabla_destino
SELECT * FROM tabla_origen AS t1
LEFT JOIN tabla_destino AS t2 ON (t1.id=t2.id)
WHERE t2.id IS NULL
 
UPDATE tabla_destino
SET valor=completa.valor
FROM
(
SELECT * FROM tabla_origen AS t1
LEFT JOIN tabla destino AS t2 ON (t1.id=t2.id)
WHERE t2.id IS NOT NULL
) AS completa WHERE completa.id=tabla_destino.id
 

Que eso es lo miso que hace un merge......

[Azor]

Hola Libras!

Muchas gracias por la ayuda , voy a probar lo que me comentas.

Disculpa mi ignorancia, entiendo que lo ideal para automatizar la tarea, sería crear un primer job en la bd para hacer el insert y cuando éste acabe lanzar un segundo para el update, no?

Gracias de nuevo.

[Libras]

No, no ocupas 2 jobs con uno solo puedes hacer las 2 operaciones, cual seria el objetivo de los 2 jobs???

Ahora si estas haciendo esto para tener replicados tus datos en ambos servidores, porque no investigas acerca de las tecnologias de alta disponibilidad de sql server

[Azor]

Lo de los dos Jobs seria para asegurarme que no se ejecuta el update sin haber acabado el insert primero, sobretodo cuan son muchos los registros a tratar

No trato de replicar toda la información de la bd de sql server, más bien quiero tener información actualizada con registros de ciertos campos y tablas en un base de datos a parte, para poder atacarla desde una aplicación.

De todas formas me viene que ni pintando lo que me comentas de las tecnologías de alta capacidad de sql server, pues tengo pendiente el tema de replicación la bd en otro servidor por si cae el principal. Todo llegará

[iislas]

Si no va a MODIFICAR los datos que estaran en la base "replicada", puede implementar la creacion de una base de tipo INSTANTANEA (Snapshot), solo como observacion, debe tener la edicion ENTERPRISE

[Libras]

Iniciado por Azor

Lo de los dos Jobs seria para asegurarme que no se ejecuta el update sin haber acabado el insert primero, sobretodo cuan son muchos los registros a tratar

Los queries en sql se ejecutan de manera secuencial, hasta que termina el primero sigue con el segundo por lo que un

insert......

update....

primero insertara los registros y cuando termine de insertar continuara con la parte del update

[Azor]

Iniciado por iislas

Si no va a MODIFICAR los datos que estaran en la base "replicada", puede implementar la creacion de una base de tipo INSTANTANEA (Snapshot), solo como observacion, debe tener la edicion ENTERPRISE

Hola iislas!
No en principio no se van a modificar los datos del servidor replicado, solo se modificarían o utilizarían en el caso de que el servidor principal fallara.
Muchas gracias por el apunte.

Iniciado por Libras

Los queries en sql se ejecutan de manera secuencial, hasta que termina el primero sigue con el segundo por lo que un
insert......
update....
primero insertara los registros y cuando termine de insertar continuara con la parte del update

Hola Libras!
Entendido y muchísimas gracias por la ayuda y la paciencia.
Sólo un apunte más, creo que en ocasiones no se valora lo suficiente lo que supone encontrar respuestas cuando uno necesita soluciones y acude a foros como éste.
Es de admirar lo que haces tú y el resto de usuarios aportando de forma altruista su tiempo, conocimientos y experiencia para AYUDAR a los demás.
GRACIAS

[Azor]

Hola de nuevo Libras!

He estado probando y con el insert no tengo problemas, quedaría el sql así:

Código SQL:

INSERT INTO OPENQUERY(SERVIDOR_MYSQL,'SELECT campo1, campo2, campo3, campo4 FROM BD.tabla1')
   SELECT ORIGEN.campo1, ORIGEN.campo2, ORIGEN.campo3, ORIGEN.campo4
     FROM [BD_ORIGEN].[dbo].[tabla1] AS ORIGEN
LEFT JOIN OPENQUERY(SERVIDOR_MYSQL,'SELECT campo1, campo2, campo3, campo4 FROM BD.tabla1') AS DESTINO 
       ON (ORIGEN.campo1 = DESTINO.campo1 AND ORIGEN.campo2 = DESTINO.campo2) 
    WHERE (DESTINO.campo1 IS NULL AND DESTINO.campo2 IS NULL)
 

pero con el update me da el siguiente error, aunque acaba haciendo los cambios:

"El proveedor OLE DB "MSDASQL" del servidor vinculado "XXXXXXXX" devolvió el mensaje "No se puede encontrar la fila para su actualización: algunos valores han cambiado desde la última vez que se leyó.".
Mens. 7343, Nivel 16, Estado 4, Línea 1
El proveedor OLE DB "MSDASQL" del servidor vinculado "XXXXXXXXI" no pudo UPDATE la tabla "[MSDASQL]". El conjunto de filas utiliza simultaneidad optimista y el valor de una columna ha cambiado desde que se capturó o"

La sql sería ésta:

Código SQL:

WITH DESTINO AS (
   SELECT campo1, campo2, campo3, campo4
   FROM OPENQUERY(SERVIDOR_MYSQL, 'SELECT campo1, campo2, campo3, campo4 FROM BD.tabla1')
)
UPDATE DESTINO
  SET DESTINO.campo1 = COMPLETA.campo1,
      DESTINO.campo2 = COMPLETA.campo2,
      DESTINO.campo3 = COMPLETA.campo3,
      DESTINO.campo4 = COMPLETA.campo4
FROM
(
SELECT ORIGEN.campo1, ORIGEN.campo2, ORIGEN.campo3, ORIGEN.campo4
     FROM [BD_ORIGEN].[dbo].[tabla1] AS ORIGEN
LEFT JOIN OPENQUERY(SERVIDOR_MYSQL,'SELECT campo1, campo2, campo3, campo4 FROM BD.tabla1') AS DESTINO 
       ON (ORIGEN.campo1 = DESTINO.campo1 AND ORIGEN.campo2 = DESTINO.campo2) 
    WHERE (DESTINO.campo1 IS NOT NULL AND DESTINO.campo2 IS NOT NULL)
) AS COMPLETA 
WHERE (COMPLETA.campo1 = DESTINO.campo1 AND COMPLETA.campo2 = DESTINO.campo2)
 

Ves alguna o varias cosas mal en la sql del update?

[Azor]

Me da la impresión que el error se produce por la select del with y la del left join, pero no sé cómo darle otro enfoque a pesar de haber deshecho y rehecho la select varias veces..
alguna idea?

[Azor]

Por lo que he estado viendo el servidor de sql server se puede configurar de maneras distintas:
En modo "simultaneidad optimista" o "simultaneidad pesimista".
Mi servidor lo tengo configurado con la primera opción y de ahí el mensaje que me aparece cuando intento el update, por culpa de las dos selects con openquerrry que hago (o eso entiendo yo). Una sobre la parte del with y la otra sobre la línea de left join. No voy a cambiar la configuración del servidor dado que tengo otras bds.

Por lo que creo que debería intentar cambiar mi sql. He estado mirando otro caso similar al mío en el foro que no había visto antes, (lo siento), es éste:
http://www.forosdelweb.com/f87/delet...culado-819142/

En el que se cambia la select que se hace y consigue evitar el error. Si inteno readaptar mi sentencia de update me encuentro que donde se cambia el join por el exist se hace sobre dos tablas de la misma bd, en cambio yo tengo una tabla en el servidor de remoto o linkado de MySql y la otra sobre el servidor local Sql Server y no se como retocar la sql para que funcione.

Por favor ¿alguna ayuda u orientación?

Gracias.

[Azor]

No sé si es la solución o sólo una chapuzilla pero dejando la sql de la siguiente forma funciona:

Código SQL:

WITH DESTINO AS (
   SELECT empresa, alm, txt, orden, admitepedidos, email
   FROM OPENQUERY(SERVIDOR_MYSQL, 'SELECT empresa, alm, txt, orden, admitepedidos, email FROM SERVIDOR_MYSQL.almacen')
)
UPDATE DESTINO
  SET DESTINO.txt = COMPLETA.txt,
      DESTINO.orden = COMPLETA.orden,
      DESTINO.admitepedidos = COMPLETA.admitepedidos,
      DESTINO.email = COMPLETA.email
FROM (SELECT ORIGEN.empresa, ORIGEN.alm, ORIGEN.txt, ORIGEN.orden, ORIGEN.admitepedidos, ORIGEN.email 
        FROM [SERVIDOR_SQL_SERVER].[dbo].[almacen] ORIGEN
   LEFT JOIN OPENQUERY(SERVIDOR_MYSQL,'SELECT empresa, alm, txt, orden, admitepedidos, email FROM SERVIDOR_MYSQL.almacen') AS DESTINO 
          ON (ORIGEN.empresa = DESTINO.empresa AND ORIGEN.alm COLLATE Modern_Spanish_100_CI_AS = DESTINO.alm COLLATE Modern_Spanish_100_CI_AS) 
       WHERE (DESTINO.empresa IS NOT NULL AND DESTINO.alm IS NOT NULL)
         AND ((DESTINO.txt COLLATE Modern_Spanish_100_CI_AS <> ORIGEN.txt COLLATE Modern_Spanish_100_CI_AS)
          OR (DESTINO.orden <> ORIGEN.orden)
          OR (DESTINO.admitepedidos <> ORIGEN.admitepedidos)
          OR (DESTINO.email COLLATE Modern_Spanish_100_CI_AS  <> ORIGEN.email COLLATE Modern_Spanish_100_CI_AS))) AS COMPLETA 
WHERE (COMPLETA.empresa = DESTINO.empresa AND COMPLETA.alm COLLATE Modern_Spanish_100_CI_AS = DESTINO.alm COLLATE Modern_Spanish_100_CI_AS);
 

Cuando hacía el update sobre registros en los que no se cambiaba nada, es decir que los campos de la tabla origen tenía los mismos valores que los de la tabla destino, se producía el archiconocido error, pero al añadir las líneas:

Código SQL:

...
          OR (DESTINO.orden <> ORIGEN.orden)
          OR (DESTINO.admitepedidos <> ORIGEN.admitepedidos)
          OR (DESTINO.email COLLATE Modern_Spanish_100_CI_AS  <> ORIGEN.email COLLATE Modern_Spanish_100_CI_AS)))
 

funciona todo correcto. Si existían registros en los que si se hacía el update de los datos, no me daba error alguno.

También resulta curioso que cuando hago un update directamente sobre la tabla almacen de la base de datos de mysql desde el workbenchy y los campos a actualizar tienen el mismo valor que los campos destino, secillamente dice: 0 rows afected, pero no da ningún error.

En fin, seguro que existen soluciones mejores, pero es lo único que he podido hacer.