Início / dba / Perguntas / 334895
Accepted
Tony Stephens
Asked: 2024-01-16 10:59:04 +0800 CST

Criando um Trigger no MySQL que possui um JOIN

  • 772

PROBLEMA: Estou tentando criar um TRIGGER que irá copiar registros de 2 tabelas diferentes ( usuários , endereços ) no banco de dados A para uma única tabela ( usuários ) no banco de dados B.

Basicamente, estou tentando consolidar dados em uma única tabela em um banco de dados diferente.

Eu tenho o seguinte TRIGGER

CREATE TRIGGER `Copy db1_user to db2_users` 
AFTER INSERT ON `user`
FOR EACH ROW 
BEGIN 
    INSERT INTO database2.users(user_id, user_email, user_firstname, user_lastname) 
        VALUES (NEW.user_id, NEW.email, NEW.first_name, NEW.last_name);
END

O procedimento acima funciona bem, onde eu dobro meu cérebro para obter o outro pedaço de dados da tabela de endereços. Criei um diagrama do que estou tentando alcançar, espero que faça sentido. Ah, ele também precisa ter certeza de que o user_id ainda não existe na tabela de destino, o que não deveria acontecer, pois o campo user_id na tabela de origem é AUTO INCREMENT.

Diagrama de TRIGGER

Minha outra pergunta é: como as duas tabelas de origem são gravadas em momentos ligeiramente diferentes, não tenho certeza de onde disparar esse TRIGGER. Se eu ativá-lo AFTER INSERT na tabela (usuários), a tabela (endereços) já terá sido gravada? Não tenho certeza - não é meu código (é um aplicativo WordPress que estou analisando), então qualquer conselho sobre onde manter esse TRIGGER seria ótimo.

Sugestões ou assistência seriam muito apreciadas.

mysql

1 respostas

  1. Best Answer

    Com 2 gatilhos você pode resolver o problema se seus esquemas estiverem no mesmo servidor.

    Isto pode ser conseguido usando INSERT....ON DUPLICATE KEY UPDATE.

    Gatilho1

    use database1;
CREATE TRIGGER after_users_insert AFTER INSERT ON users
 FOR EACH ROW
   INSERT INTO database2.users (user_id,user_email,user_firstname,user_lastname,user_address1,user_address2,user_city,user_state,user_zip,user_country,user_phone) 
   VALUES (NEW.user_id,NEW.email,NEW.first_name,NEW.last_name,null,null,null,null,null,null,null) 
       ON DUPLICATE KEY UPDATE  user_email     = NEW.email      ,
                                user_firstname = NEW.first_name ,
                                user_lastname  = NEW.last_name  ;

    Gatilho2

    CREATE TRIGGER after_addresses_insert AFTER INSERT ON addresses
 FOR EACH ROW
   INSERT INTO database2.users (user_id,user_email,user_firstname,user_lastname,user_address1,user_address2,user_city,user_state,user_zip,user_country,user_phone) 
   VALUES (NEW.user_id,null,null,null,NEW.address_line_1,NEW.address_line_2,NEW.city,NEW.state,NEW.zip,NEW.country,NEW.phone) 
           ON DUPLICATE KEY UPDATE  user_address1 = NEW.address_line_1 ,
                                    user_address2 = NEW.address_line_2 ,
                                    user_city     = NEW.city           ,
                                    user_state    = NEW.state          ,
                                    user_zip      = NEW.zip            ,
                                    user_country  = NEW.country        ,
                                    user_phone    = NEW.phone          ;

    consultar exemplo

    Nota , usei nullpara as colunas que não estão presentes.

    Outro método é testar se user_idexiste e depois atualizar, caso contrário faça um insert com todas as colunas presentes na userstabela em database2.

    Gatilho1

    use database1;

CREATE TRIGGER after_users_insert AFTER INSERT ON users
 FOR EACH ROW
  BEGIN
    IF EXISTS (SELECT user_id FROM  database2.users WHERE user_id = NEW.user_id )
     THEN 
       UPDATE database2.users SET user_email     = NEW.email     ,
                                  user_firstname = NEW.first_name,
                                  user_lastname  = NEW.last_name ;
      ELSE
         INSERT INTO database2.users (user_id,user_email,user_firstname,user_lastname,user_address1,user_address2,user_city,user_state,user_zip,user_country,user_phone) 
          VALUES (NEW.user_id,NEW.email,NEW.first_name,NEW.last_name,null,null,null,null,null,null,null);
    END IF;
  END;

    Gatilho2

    CREATE TRIGGER after_addresses_insert AFTER INSERT ON addresses
 FOR EACH ROW
  BEGIN
   IF EXISTS ( SELECT user_id FROM  database2.users WHERE user_id = NEW.user_id )
     THEN 
         UPDATE database2.users SET user_address1 = NEW.address_line_1 ,
                                    user_address2 = NEW.address_line_2 ,
                                    user_city     = NEW.city           ,
                                    user_state    = NEW.state          ,
                                    user_zip      = NEW.zip            ,
                                    user_country  = NEW.country        ,
                                    user_phone    = NEW.phone          ;
     ELSE
         INSERT INTO database2.users (user_id,user_email,user_firstname,user_lastname,user_address1,user_address2,user_city,user_state,user_zip,user_country,user_phone) 
         VALUES (NEW.user_id,null,null,null,NEW.address_line_1,NEW.address_line_2,NEW.city,NEW.state,NEW.zip,NEW.country,NEW.phone) ;
   END IF;
  END;

    consultar exemplo

    • 2

relate perguntas