C# uygulamasında * .sql mysql dosyası nasıl çalıştırılır

Question

Benim C# uygulamamdan yürütmek için gereken bir dosyada mysql betiğim var.

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 ; 

bunu saklı usul ve bazı damla diyoruz ve diğer saklı yordamlar güncelleştirmek için ifadeler oluşturun çizgilerin bir karışımı vardır görebileceğiniz gibi: İşte script ne içerdiğini gösteren bir örnektir.

Senaryoyu yürütmek için iki farklı yöntem denedim ve de başarısız olmuş:

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

Bu istisna atar: Dizin, dizi sınırlarının dışındaydı.

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

Bu, sql sözdizimimde bir hata olduğuna dair bir istisna atar.

Komut dosyasının tamamını dbForge Studio'da el ile çalıştırdığımda, tam olarak çalışır. C# app

Answer 1

Bir göz atın here. MySqlScript için bir sınırlayıcı belirtmelisiniz (oradaki prosedürü kaydettiğiniz için).

-- 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 
$$ 

Ve sonra kod: Ve sorgu gibi görünmelidir

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

Answer 2

'dan doğru şekilde yürütmek için bu komut dosyasını nasıl alabilirim? Komutu yürütmek için ayrı bir İşlemi çalıştırabilirsiniz. Örneğin:

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

Muhtemelen biraz mysql yürütülebilir veya sql komut dosyasına yolları içerecek şekilde çevreye bağlı olarak onunla uğraşmak ihtiyacımız olacak.

Answer 3

Yerel MySql sözdiziminin ne olduğundan% 100 emin değilim, ancak Sql Server için benzer işlevleri gerçekleştirdiğimizde, sql dosyasını yalnızca sorgu tarafından kullanılan literal değerlere (GO) göre parçalara ayırmamız gerekir. executor (Sql Sunucu Yönetim Konsolu).

DEFINE ifadesi gibi yukarıdaki isteğinizde bulunan benzer bilgiler olabileceğinden şüpheleniyorum.

MySql'nin şikayet ettiği şeyi tam olarak bilmek, çözümün iyileştirilmesine yardımcı olur.

Answer 4

Nasıl bir saklı yordam içinde sql komut koyarsanız? halen kullanmakta istiyorsanız bu yolu (dosyalar .resx) uygulama kaynaklarına dosyası olarak uygulamaya sql dosyası eklemek ve bunu böyle yürütün:

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