我如何导入MySQL数据与Ironpython

我正在寻求帮助的方式，我可以通过Ironpython脚本将数据导入到数据库。我如何导入MySQL数据与Ironpython

目前我的脚本如下，先运行此脚本：

import clr; 
import System; 

clr.AddReference("TCAdmin.SDK"); 
from TCAdmin.SDK.Misc import Random; 
from System import String; 

ThisService.Variables["MySQLUser"] = String.Format("exile_{0}",  ThisService.ServiceId); 
ThisService.Variables["MySQLPassword"] = Random.RandomString(10,True,True); 
ThisService.Save();

那么这个脚本运行后：

import clr; 
import System; 

clr.AddReference("TCAdmin.DatabaseProviders.MySql"); 
clr.AddReference("TCAdmin.SDK"); 
from TCAdmin.DatabaseProviders.MySql import MySqlManager; 
from System import String; 

mysql_server="localhost"; 
mysql_root="root"; 
mysql_password="Password"; 

with MySqlManager() as mysql: 
escapeduser=mysql.PrepareSqlValue(ThisService.Variables["MySQLUser"]); 
escapedpass=mysql.PrepareSqlValue(ThisService.Variables["MySQLPassword"]); 
mysql.Connect(String.Format("Data Source={0};User Id={1};Password={2};Pooling=False;", mysql_server, mysql_root, mysql_password)); 

mysql.ExecuteNonQuery(String.Format("DROP DATABASE IF EXISTS {0};", escapeduser)); 
if mysql.Execute(String.Format("SELECT COUNT(*) as count FROM mysql.user WHERE user='{0}' AND host='localhost';", escapeduser)).Rows[0].Item[0] == 1 : 
    mysql.ExecuteNonQuery(String.Format("DROP USER {0}@localhost;", escapeduser)); 

mysql.ExecuteNonQuery(String.Format("CREATE DATABASE {0};", escapeduser)); 
mysql.ExecuteNonQuery(String.Format("GRANT ALL PRIVILEGES ON {0}.* TO '{0}'@'localhost' IDENTIFIED BY '{1}';", escapeduser, escapedpass)); 

mysql.ExecuteNonQuery(String.Format("USE '{0}';", escapeduser)); 
mysql.ExecuteNonQuery(String.Format("""CREATE TABLE IF NOT EXISTS `account` (
    `uid` varchar(32) NOT NULL, 
    `clan_id` int(11) UNSIGNED DEFAULT NULL, 
    `name` varchar(64) NOT NULL, 
    `money` double NOT NULL DEFAULT '0', 
    `score` int(11) NOT NULL DEFAULT '0', 
    `kills` int(11) UNSIGNED NOT NULL DEFAULT '0', 
    `deaths` int(11) UNSIGNED NOT NULL DEFAULT '0', 
    `first_connect_at` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP, 
    `last_connect_at` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP, 
    `last_disconnect_at` datetime DEFAULT NULL, 
    `total_connections` int(11) UNSIGNED NOT NULL DEFAULT '1' 
) ENGINE=InnoDB DEFAULT CHARSET=utf8;""", escapeduser));

当我运行该脚本，我得到的错误：

你的SQL语法有错误;请检查与您的MySQL服务器版本对应的手册，以获得在第1行''exile_2''附近使用的正确语法。

TCAdmin.SDK.Database.DatabaseException：您在SQL语法中有错误;检查与你的MySQL服务器版本相对应的手册，在第1行的''exile_2''附近使用正确的语法--->你的SQL语法错误;检查与您的MySQL服务器版本相对应的手册，以便在第1行“exile_2”附近使用正确的语法---内部异常堆栈跟踪结束---在Microsoft.Scripting.Interpreter.ThrowInstruction.Run（InterpretedFrame frame ）at Microsoft.Scripting.Interpreter.Interpreter.RunInstructions（InterpretedFrame frame）at Microsoft.Scripting.Interpreter.Interpreter.Run（InterpretedFrame frame）at Microsoft.Scripting.Interpreter.LightLambda.Run2 [T0，T1，TRet]（T0 arg0，在IronPython.Compiler.PythonScriptCode.RunWorker（CodeContext ctx）IronPython.Compiler.RuntimeScriptCode.InvokeTarget（Scope作用域）上的Microsoft.Scripting.Hosting.ScriptSource.Execute（ScriptScope作用域）在TCAdmin.SDK.Scripting.Engines上的T1 arg1）。 TCAdmin.GameHost处的TCAdmin.SDK.Scripting.ScriptEngineManager.Execute（）上的IronPythonEngine.Execute（凭据凭据）TCAdmin.GameHosting.SDK.Objects.GameScript.ExecuteEventScripts（ScriptEngineManager scriptEngineManager，ServiceEvent eventScript，ObjectList脚本）（TCAdmin.GameHosting.Automation.AutomationProcesses.Start（）at TCAdmin.TaskScheduler.ModuleApi.StepBase.Start（Object arguments）

来源

2016-04-23 Justin Thomas

所以我能解决这个问题，通过导入实际SQL文件与以下脚本。

import clr; 
import System; 

clr.AddReference("TCAdmin.DatabaseProviders.MySql"); 
clr.AddReference("TCAdmin.SDK"); 
from TCAdmin.DatabaseProviders.MySql import MySqlManager; 
from System import String; 
from System.IO import File, Path; 

mysql_server="localhost"; 
mysql_root="root"; 
mysql_password="Password"; 

if not ThisService.Variables.HasValue("MySQLUser") : 
Script.Exit(); 


backupfile=Path.Combine(ThisService.RootDirectory, "dbname.sql"); 

with MySqlManager() as mysql: 
escapeduser=mysql.PrepareSqlValue(ThisService.Variables["MySQLUser"]); 
escapedpass=mysql.PrepareSqlValue(ThisService.Variables["MySQLPassword"]); 
mysql.Connect(String.Format("Data Source={0};User Id={1};Password={2};Pooling=False;", mysql_server, mysql_root, mysql_password)); 

mysql.ExecuteNonQuery(String.Format("DROP DATABASE IF EXISTS {0};", escapeduser)); 
if mysql.Execute(String.Format("SELECT * FROM mysql.user WHERE user='{0}' AND host='localhost';", escapeduser)).Rows.Count == 1 : 
mysql.ExecuteNonQuery(String.Format("DROP USER {0}@localhost;", escapeduser)); 

mysql.ExecuteNonQuery(String.Format("CREATE DATABASE {0};", escapeduser)); 
mysql.ExecuteNonQuery(String.Format("GRANT ALL PRIVILEGES ON {0}.* TO '{0}'@'localhost' IDENTIFIED BY '{1}';", escapeduser, escapedpass)); 

if File.Exists(backupfile) : 
with MySqlManager() as mysql2: 
mysql2.Connect(String.Format("Data Source={0};Database={1};User Id= {1};Password={2};Pooling=False;", mysql_server,  ThisService.Variables["MySQLUser"], ThisService.Variables["MySQLPassword"])); 
mysql2.ImportDatabase(backupfile); 
File.Delete(backupfile);

来源

2016-04-26 23:09:52

我如何导入MySQL数据与Ironpython

回答

相关问题