Cómo ejecutar * .sql archivo mysql en mi aplicación C#

Question

Tengo un script mysql en un archivo que necesito poder ejecutar desde mi aplicación C#. Este es un ejemplo de lo que contiene la secuencia de comandos:

USE osae; 

-- Set DB version 
CALL osae_sp_object_property_set('SYSTEM', 'DB Version', '0.3.5', '', ''); 
CALL osae_sp_object_property_set('SYSTEM', 'Debug', 'FALSE', '', ''); 
CALL osae_sp_object_type_property_add ('Prune Logs','Boolean','TRUE','SYSTEM',0); 
CALL osae_sp_object_property_set ('SYSTEM','Prune Logs','TRUE','',''); 

DELIMITER $$ 

DROP PROCEDURE IF EXISTS osae_sp_object_event_script_update$$ 
CREATE DEFINER = 'root'@'localhost' 
PROCEDURE osae_sp_object_event_script_update(IN pobject varchar(200), IN pevent varchar(200), IN ptext text) 
BEGIN 
DECLARE vObjectCount INT; 
DECLARE vObjectID INT; 
DECLARE vObjectTypeID INT; 
DECLARE vEventCount INT; 
DECLARE vEventID INT; 
    SELECT COUNT(object_id) INTO vObjectCount FROM osae_object WHERE UPPER(object_name)=UPPER(pobject); 
    IF vObjectCount > 0 THEN 
       SELECT object_id,object_type_id INTO vObjectID,vObjectTypeID FROM osae_object WHERE UPPER(object_name)=UPPER(pobject); 
     SELECT COUNT(event_id) INTO vEventCount FROM osae_object_type_event WHERE object_type_id=vObjectTypeID AND (UPPER(event_name)=UPPER(pevent) OR UPPER(event_label)=UPPER(pevent)); 
     IF vEventCount = 1 THEN  
      SELECT event_id INTO vEventID FROM osae_object_type_event WHERE object_type_id=vObjectTypeID AND (UPPER(event_name)=UPPER(pevent) OR UPPER(event_label)=UPPER(pevent)); 
      UPDATE osae_object_event_script SET event_script=ptext WHERE object_id=vObjectID AND event_id=vEventID; 
     -- CALL osae_sp_debug_log_add(CONCAT('Updated ',vObjectID,' - ',vEventID,ptext),''); 
     END IF; 
    END IF; 
END 
$$ 

DELIMITER ; 

Como se puede ver que tiene una mezcla de líneas que llaman a procedimientos almacenados y alguna gota y CREATE para actualizar otros procedimientos almacenados.

me han tratado dos métodos diferentes para ejecutar la secuencia de comandos y ambos han fallado:

MySqlScript script = new MySqlScript(connection, File.ReadAllText("script.sql")); 
script.Execute(); 

Esto produce la excepción: Índice fuera de los límites de la matriz.

MySqlCommand upgCommand = new MySqlCommand(); 
upgCommand.Connection = connection; 
upgCommand.CommandText = File.ReadAllText("script.sql"); 
upgCommand.ExecuteNonQuery(); 

Esto arroja la excepción de que hay un error en mi sintaxis sql.

Cuando ejecuto todo el script manualmente en dbForge Studio, se ejecuta perfectamente. ¿Cómo puedo obtener este script para que se ejecute correctamente desde mi aplicación C#

Answer 1

Echa un vistazo a here. Debe especificar un delimitador para MySqlScript (ya que tiene el procedimiento almacenado allí). Y la consulta debe verse como:

-- Set DB version 
CALL osae_sp_object_property_set('SYSTEM', 'DB Version', '0.3.5', '', '')$$ 
CALL osae_sp_object_property_set('SYSTEM', 'Debug', 'FALSE', '', '')$$ 
CALL osae_sp_object_type_property_add ('Prune Logs','Boolean','TRUE','SYSTEM',0)$$ 
CALL osae_sp_object_property_set ('SYSTEM','Prune Logs','TRUE','','')$$ 



DROP PROCEDURE IF EXISTS osae_sp_object_event_script_update$$ 
CREATE DEFINER = 'root'@'localhost' 
PROCEDURE osae_sp_object_event_script_update(IN pobject varchar(200), IN pevent varchar(200), IN ptext text) 
BEGIN 
DECLARE vObjectCount INT; 
DECLARE vObjectID INT; 
DECLARE vObjectTypeID INT; 
DECLARE vEventCount INT; 
DECLARE vEventID INT; 
    SELECT COUNT(object_id) INTO vObjectCount FROM osae_object WHERE UPPER(object_name)=UPPER(pobject); 
    IF vObjectCount > 0 THEN 
       SELECT object_id,object_type_id INTO vObjectID,vObjectTypeID FROM osae_object WHERE UPPER(object_name)=UPPER(pobject); 
     SELECT COUNT(event_id) INTO vEventCount FROM osae_object_type_event WHERE object_type_id=vObjectTypeID AND (UPPER(event_name)=UPPER(pevent) OR UPPER(event_label)=UPPER(pevent)); 
     IF vEventCount = 1 THEN  
      SELECT event_id INTO vEventID FROM osae_object_type_event WHERE object_type_id=vObjectTypeID AND (UPPER(event_name)=UPPER(pevent) OR UPPER(event_label)=UPPER(pevent)); 
      UPDATE osae_object_event_script SET event_script=ptext WHERE object_id=vObjectID AND event_id=vEventID; 
     -- CALL osae_sp_debug_log_add(CONCAT('Updated ',vObjectID,' - ',vEventID,ptext),''); 
     END IF; 
    END IF; 
END 
$$ 

y entonces su código:

MySqlScript script = new MySqlScript(connection, File.ReadAllText("script.sql")); 
script.Delimiter = "$$"; 
script.Execute(); 

Answer 2

Puede ejecutar un proceso separado para ejecutar el script. Por ejemplo:

Process.Start("mysql < script.sql"); 

Usted está probablemente va a tener que jugar con él un poco dependiendo de su entorno para incluir rutas de acceso al ejecutable mysql o la secuencia de comandos SQL.

Answer 3

No estoy 100% seguro de cuál es la sintaxis MySql nativa, pero cuando realizamos funcionalidades similares para Sql Server, tenemos que dividir el archivo sql en fragmentos basados ​​en los valores literales (GO) que solo utiliza la consulta ejecutor (Sql Server Management Console).

Sospecho que puede haber información similar incrustada en su solicitud anterior, como la sentencia DEFINE.

Saber exactamente de qué se quejaba MySql ayudaría a refinar la solución.

Answer 4

Cómo si usted pone su secuencia de comandos SQL en un procedimiento almacenado? Si aún desea utilizar esta forma adjuntar el archivo sql para aplicación como archivo para los recursos de la aplicación (.resx) y ejecutarlo así:

MySql.Data.MySqlClient.MySqlCommand cmdMySQL = newMySqlConnection.CreateCommand(); 
cmdMySQL.CommandText = (System.String)globalResource.your_file_name;