老潘的技術分享部落格: 省錢大作戰從MS-SQL跳槽到MySQL：第三步撰寫 C# 轉檔程式將資料從 MS-SQL Copy 到 MySQL資料庫

撰寫 C# 參數化轉檔程式將資料從 MS-SQL Copy 到 MySQL資料庫：

◎ Windows 轉檔程式：

以系統管理員身份啟動 Visual Stdio --> 檔案 --> 新增 --> 專案 -->

C#新增專案

選擇 Windows Form 應用程式 --> 名稱：MySQLFromMSWinAP --> 確定。

◎ 設計畫面：

轉檔程式畫面設計

Form1 放入 buttonSEARCH，buttonPOST，buttonEXIT三個按鍵。再放入 textBoxMsSql，textBoxMysql，textBoxTimeSpan 三個 TextBox，並且將 Enabled 設為 False。在三個 TextBox 之前放入 Label，並標上適當文字。最後加上 dataGridView。習慣上我還會將 Form1 之 WindowState 放到最大：Maximized。

◎ 確定專案為 .Net Framework 4.0：

專案 --> MySQLFromMSWinAP 屬性 --> 目標 Framework --> 確定為 .Net Framework 4.0 ，如果不是，請改過來。

選擇 .Net Framework 4.0

使用 .NET Framework 4.0 是為了相容於 Windows XP，如果沒有此需求，也可以使用其他版本。

◎ 專案加入參考：

專案 --> 加入參考 --> C:\Program Files (x86)\MySQL\MySQL Connector Net 6.8.3\Assemblies\v4.0\MySql.Data.dll 其中 v4.0 符合 .Net Framework 4.0 。與前一項的 .NET Framework 相符--> 加入 --> 確定。

MySQL Connector Net 6.8.3 v4.0

不過 MySQL Connector Net 6.8.3 最高只支援到 .NET Framework 4.5。

◎撰寫程式：

Form1 上 buttonSEARCH，buttonPOST，buttonEXIT三個按鍵都雙擊一次。開始撰寫參數化的轉檔程式。

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;

using System.Data.SqlClient;
using MySql.Data.MySqlClient;

namespace MySQLFromMSWinAP
{
    public partial class Form1 : Form
    {
        public int MaxWidth = 1024;
        public int MaxHeight = 768;

public string ConnectionStringMsSQL = @"server=localhost;database=PAM;uid=PAM;pwd=12345678";
        public string ConnectionStringMySQL = @"server=192.168.0.250;database=PAM;uid=root;pwd=12345678;charset=utf8;PORT=3306;";

public Form1()
        {
            InitializeComponent();

MaxWidth = (int)System.Windows.Forms.Screen.PrimaryScreen.Bounds.Width;
            MaxHeight = (int)System.Windows.Forms.Screen.PrimaryScreen.Bounds.Height;
            dataGridView1.Size = new Size(MaxWidth - dataGridView1.Location.X - 80, MaxHeight - dataGridView1.Location.Y - 190);
        }

private void buttonSEARCH_Click(object sender, EventArgs e)
        {
            Cursor.Current = Cursors.WaitCursor;

DataSet ds = new DataSet();

DataTable dtTable = ds.Tables.Add("dtTable");
            dtTable.Columns.Add("TABLE", typeof(String));
            dtTable.Columns.Add("MsSQL", typeof(int));
            dtTable.Columns.Add("MySQL", typeof(int));
            dtTable.Columns.Add("Sel", typeof(String));
            dtTable.PrimaryKey = new DataColumn[] { dtTable.Columns["TABLE"] };

string Txt = "";
            int iMySql = 0;
            int iMsSql = 0;

try
            {
                MySqlConnection SC_MySQL = new MySqlConnection(ConnectionStringMySQL);
                SC_MySQL.Open();

Txt = "Show tables";
                MySqlDataAdapter DA_MyTables = new MySqlDataAdapter(Txt, SC_MySQL);
                DataTable DT_MyTables = ds.Tables.Add("DT_MyTables");
                DA_MyTables.Fill(ds, "DT_MyTables");

for (int i = 0; i < DT_MyTables.Rows.Count; i++)
                {
                    if (DT_MyTables.Rows[i].ItemArray[0] != null && DT_MyTables.Rows[i].ItemArray[0].ToString().Length > 0)
                    {
                        string TableName = DT_MyTables.Rows[i].ItemArray[0].ToString();
                        Txt = "SELECT COUNT(*) FROM " + TableName;
                        MySqlCommand cmdMySQL = new MySqlCommand();
                        cmdMySQL.CommandText = Txt;
                        cmdMySQL.Connection = SC_MySQL;
                        int iMy1 = Convert.ToInt32(cmdMySQL.ExecuteScalar());
                        DataRow dr = dtTable.NewRow();
                        dr["TABLE"] = TableName;
                        dr["MySQL"] = iMy1;
                        dtTable.Rows.Add(dr);
                        iMySql += iMy1;
                    }
                }
                SC_MySQL.Close();
                SC_MySQL.Dispose();
            }
            catch (MySqlException ex)
            {
                MessageBox.Show("MySQL 錯誤 : " + Txt + " " + ex.Number + " " + ex.Message);
            }
            catch (Exception ex)
            {
                MessageBox.Show("MySQL 錯誤 : " + Txt + " " + ex.Message);
            }
            finally
            { }

try
            {
                SqlConnection SC_MsSQL = new SqlConnection(ConnectionStringMsSQL);
                SC_MsSQL.Open();

for (int i = 0; i < dtTable.Rows.Count; i++)
                {
                    if (dtTable.Rows[i].ItemArray[0] != null && dtTable.Rows[i].ItemArray[0].ToString().Length > 0)
                    {
                        string TableName = dtTable.Rows[i].ItemArray[0].ToString().ToUpper();
                        DataRow result = dtTable.Rows.Find(TableName);
                        if (result != null)
                        {
                            Txt = "SELECT COUNT(*) FROM " + TableName;
                            SqlCommand cmdSQL = new SqlCommand();
                            cmdSQL.CommandText = Txt;
                            cmdSQL.Connection = SC_MsSQL;
                            int iMs1 = Convert.ToInt32(cmdSQL.ExecuteScalar());
                            int iMy1 = 0;
                            if (result["MySQL"] != null && result["MySQL"].ToString().Length > 0)
                            { iMy1 = int.Parse(result["MySQL"].ToString()); }
                            result["MsSQL"] = iMs1;
                            if (iMs1 != iMy1)
                            { result["Sel"] = "V"; }
                            iMsSql += iMs1;
                        }
                    }
                }
                SC_MsSQL.Close();
                SC_MsSQL.Dispose();
            }
            catch (Exception ex)
            { MessageBox.Show("MSSQL 錯誤 : " + ex.Message); }
            finally
            { }

dataGridView1.DataSource = dtTable;
            if (dataGridView1.Rows.Count > 0)
            {
                dataGridView1.Columns[0].AutoSizeMode = DataGridViewAutoSizeColumnMode.AllCellsExceptHeader;
                dataGridView1.Columns[1].DefaultCellStyle.Format = "n0";
                dataGridView1.Columns[1].DefaultCellStyle.Alignment = DataGridViewContentAlignment.MiddleRight;
                dataGridView1.Columns[2].DefaultCellStyle.Format = "n0";
                dataGridView1.Columns[2].DefaultCellStyle.Alignment = DataGridViewContentAlignment.MiddleRight;
                dataGridView1.Sort(dataGridView1.Columns[0], ListSortDirection.Ascending);
            }

dtTable.Dispose();
            ds.Dispose();

textBoxMySql.Text = String.Format("{0,12:n0}", iMySql);
            textBoxMsSql.Text = String.Format("{0,12:n0}", iMsSql);

Cursor.Current = Cursors.Default;
        }

private void buttonPOST_Click(object sender, EventArgs e)
        {
            if (MessageBox.Show("開始轉檔 ?", "轉檔", MessageBoxButtons.YesNo, MessageBoxIcon.Question, MessageBoxDefaultButton.Button1) == DialogResult.Yes)
            {
                Cursor.Current = Cursors.WaitCursor;
                textBoxTimeSpan.Text = "";
                DateTime t_beg = System.DateTime.Now;

int iPosted = 0;
                for (int i = 0; i < dataGridView1.Rows.Count; i++)
                {
                    if (dataGridView1.Rows[i].Cells[0].Value != null && dataGridView1.Rows[i].Cells[0].Value.ToString().Length > 0 &&
                        dataGridView1.Rows[i].Cells[3].Value != null && dataGridView1.Rows[i].Cells[3].Value.ToString().Length > 0)
                    { 
                        int iPost1 = Post1(dataGridView1.Rows[i].Cells[0].Value.ToString());
                        dataGridView1.Rows[i].Cells[2].Value = iPost1;
                        iPosted += iPost1;
                    }
                }
                DateTime t_end = System.DateTime.Now;
                TimeSpan diff = t_end - t_beg;
                textBoxTimeSpan.Text = String.Format("{0} 時 {1} 分 {2} 秒", diff.Hours, diff.Minutes, diff.Seconds);
                textBoxMySql.Text = String.Format("{0,12:n0}", iPosted);

Cursor.Current = Cursors.Default;
                if (iPosted > 0)
                { MessageBox.Show("轉檔完成"); }
            }
        }

private int Post1(string TableName)
        {
            int iPost1 = 0;
            try
            {
                SqlConnection SC_MsSQL = new SqlConnection(ConnectionStringMsSQL);
                MySqlConnection SC_MySQL = new MySqlConnection(ConnectionStringMySQL);
                SC_MySQL.Open();

DataSet ds = new DataSet();

string Txt = "Select * from " + TableName;
                SqlDataAdapter DA_MsTable = new SqlDataAdapter(Txt, SC_MsSQL);
                DataTable DT_MsTable = ds.Tables.Add("DT_MsTable");
                DA_MsTable.Fill(ds, "DT_MsTable");

Txt = "Show Columns from " + TableName;
                MySqlDataAdapter DA_MyFields = new MySqlDataAdapter(Txt, SC_MySQL);
                DataTable DT_MyFields = ds.Tables.Add("DT_MyFields");
                DA_MyFields.Fill(ds, "DT_MyFields");
                int iKeyCount = 0;
                for (int i = 0; i < DT_MyFields.Rows.Count; i++)
                {
                    string FIELD = DT_MyFields.Rows[i].ItemArray[0].ToString();
                    string NULL = DT_MyFields.Rows[i].ItemArray[2].ToString();
                    int iNULL = NULL.IndexOf("NO");
                    if (iNULL >= 0)
                    { iKeyCount++; }
                }
                //MessageBox.Show(TableName + " " + iKeyCount.ToString());

Txt = "Select * from " + TableName;
                MySqlDataAdapter DA_MyTable = new MySqlDataAdapter(Txt, SC_MySQL);
                DataTable DT_MyTable = ds.Tables.Add("DT_MyTable");
                DA_MyTable.Fill(ds, "DT_MyTable");

DataTable dtMyTable = new DataTable();
                dtMyTable.Columns.Add("KEY_ID", typeof(String));
                dtMyTable.PrimaryKey = new DataColumn[] { dtMyTable.Columns["KEY_ID"] };

string KEY_ID = "";
                for (int i = 0; i < DT_MyTable.Rows.Count; i++)
                {
                    KEY_ID = "";
                    for (int j = 0; j < iKeyCount; j++)
                    {
                        if (DT_MyTable.Rows[i].ItemArray[j] != System.DBNull.Value)
                        { KEY_ID += DT_MyTable.Rows[i].ItemArray[j].ToString() + "|"; }
                    }
                    DataRow result1 = dtMyTable.Rows.Find(KEY_ID);
                    if (result1 == null)
                    {
                        DataRow dr = dtMyTable.NewRow();
                        dr["KEY_ID"] = KEY_ID;
                        dtMyTable.Rows.Add(dr);
                        //MessageBox.Show(KEY_ID);
                    }
                }

for (int i = 0; i < DT_MsTable.Rows.Count; i++)
                {
                    KEY_ID = "";
                    for (int j = 0; j < iKeyCount; j++)
                    {
                        if (DT_MsTable.Rows[i].ItemArray[j] != System.DBNull.Value)
                        { KEY_ID += DT_MsTable.Rows[i].ItemArray[j].ToString() + "|"; }
                    }
                    DataRow result2 = dtMyTable.Rows.Find(KEY_ID);
                    if (result2 == null)
                    {
                        try
                        {
                            Txt = "Insert into " + TableName + " (";
                            for (int j = 0; j < DT_MsTable.Columns.Count - 1; j++)
                            { Txt += DT_MsTable.Columns[j].ColumnName.ToString() + ","; }
                            Txt += DT_MsTable.Columns[DT_MsTable.Columns.Count - 1].ColumnName.ToString() + ") values (";
                            for (int j = 0; j < DT_MsTable.Columns.Count - 1; j++)
                            { Txt += "@" + DT_MsTable.Columns[j].ColumnName.ToString() + ","; }
                            Txt += "@" + DT_MsTable.Columns[DT_MsTable.Columns.Count - 1].ColumnName.ToString() + ")";
                            MySqlCommand mysqlCommand = new MySqlCommand(Txt, SC_MySQL);

for (int j = 0; j < DT_MyFields.Rows.Count; j++)
                            {
                                string FIELD = DT_MyFields.Rows[j].ItemArray[0].ToString();
                                string TYPE = DT_MyFields.Rows[j].ItemArray[1].ToString().ToLower();
                                int iChar = TYPE.IndexOf("char");
                                int iInt = TYPE.IndexOf("int");
                                int iDecimal = TYPE.IndexOf("decimal");
                                string fieldName = "@" + FIELD;
                                if (iChar >= 0)
                                {
                                    int iLength = int.Parse(TYPE.Replace("varchar(", "").Replace(")", ""));
                                    MySqlParameter sqlparameter = new MySqlParameter(fieldName, MySqlDbType.VarChar, iLength);
                                    sqlparameter.Value = DT_MsTable.Rows[i].ItemArray[j];
                                    mysqlCommand.Parameters.Add(sqlparameter);
                                }
                                if (iInt >= 0)
                                {
                                    MySqlParameter sqlparameter = new MySqlParameter(fieldName, MySqlDbType.Int32);
                                    sqlparameter.Value = DT_MsTable.Rows[i].ItemArray[j];
                                    mysqlCommand.Parameters.Add(sqlparameter);
                                }
                                if (iDecimal >= 0)
                                {
                                    MySqlParameter sqlparameter = new MySqlParameter(fieldName, MySqlDbType.Decimal);
                                    sqlparameter.Value = DT_MsTable.Rows[i].ItemArray[j];
                                    mysqlCommand.Parameters.Add(sqlparameter);
                                }
                            }

if (mysqlCommand.ExecuteNonQuery() <= 0)
                            {
                                string ERROR = TableName + " 新增失敗 : " + DT_MsTable.Rows[i].ItemArray[0].ToString();
                                MessageBox.Show(ERROR);
                            }
                            else
                            { iPost1++; }
                        }
                        catch (MySqlException ex)
                        {
                            string ERROR = TableName + " : " + ex.Number + " : " + ex.Message;
                            MessageBox.Show(ERROR);
                        }
                        catch (Exception ex)
                        {
                            string ERROR = TableName + " 新增失敗 : " + Txt + " " + DT_MsTable.Rows[i].ItemArray[0].ToString() + " : " + ex.Message;
                            MessageBox.Show(ERROR);
                        }
                        finally
                        { }
                    }
                }

DT_MsTable.Clear();
                DT_MsTable.Dispose();
                DT_MyFields.Clear();
                DT_MyFields.Dispose();
                DT_MyTable.Clear();
                DT_MyTable.Dispose();
                dtMyTable.Clear();
                dtMyTable.Dispose();
                ds.Dispose();

SC_MsSQL.Close();
                SC_MsSQL.Dispose();

SC_MySQL.Close();
                SC_MySQL.Dispose();
            }
            catch (MySqlException ex)
            { MessageBox.Show(ex.Number + " " + ex.Message); }
            catch (Exception ex)
            { MessageBox.Show(ex.Message); }
            finally
            { }
            return iPost1;
        }

private void buttonEXIT_Click(object sender, EventArgs e)
        {
            this.Close();
        }
    }
}

◎程式解析：

○專案參考命名空間：

using System.Data.SqlClient;
using MySql.Data.MySqlClient;

○連線字串：

public string ConnectionStringMsSQL = @"server=localhost;database=PAM;uid=PAM;pwd=12345678";
public string ConnectionStringMySQL = @"server=192.168.0.250;database=PAM;uid=root;pwd=12345678;charset=utf8;PORT=3306;";

○buttonSEARCH_Click：

建立 dtTable --> 先連結 MySQL 資料庫 --> 用 Show Tables 讀出 PAM 資料庫所有 Tables (Show Tables 為 MySQL 特有的指令，MS-SQL 沒有，必須用其他方法抓取) --> 用 SELECT COUNT(*) 指令讀取每個 Table 的筆數放進 dtTable 之 MySQL 欄位。
再連結 MsSQL 資料庫 --> 仍然用 SELECT COUNT(*) 指令讀取每個 Table 的筆數放進 dtTable 之 MsSQL 欄位，若 MsSQL 之筆數不等於 MySQL 之筆數，Sel 欄位自動標示為 V。
最後將 dataGridView1 之 DataSource 綁訂為 dtTable，為 dataGridView1 做細部設定 --> 然後顯示抓到之總筆數。

○buttonPOST_Click：

用 MessageBox 確認轉檔動作 --> 逐步掃描 dataGridView1 抓取 TableName 與 Sel 欄位都有值者才轉檔。

Post1 --> 先抓取 MsSQL 資料表 --> 用 Show Columns from TableName 讀出 MySQL 資料庫中該 TableName 所有的 Column --> 再抓取 MySQL 資料表 --> 剔除 MySQL 現有的資料，只將 MsSQL 多的資料存入 MySQL 資料表中。最後返回轉檔的筆數。

顯示總轉檔筆數與耗用時間。

○buttonEXIT_Click：
結束轉檔程式

◎執行轉檔程式：

偵錯 --> 開始偵錯 --> 按 Search

MS-SQL --> MySQL 轉檔前筆數對照

接著按 Post --> 開始轉檔 ? --> 是(Y)

MS-SQL --> MySQL 轉檔完成，三萬筆資料耗時22秒。

◎測試轉檔結果 ：

直接執行 C:\PAM\DotNet\MyPAMWinAP\MyPAMWinAP\bin\x64\Debug\MyPAMWinAP.exe --> 使用者名稱：MGR，密碼：MGR --> 簽入。

MyPAMWinAP 順利簽入後之主選單畫面

老潘的技術分享部落格

標籤

2018年7月2日星期一

省錢大作戰從MS-SQL跳槽到MySQL：第三步撰寫 C# 轉檔程式將資料從 MS-SQL Copy 到 MySQL資料庫

◎ Windows 轉檔程式：

◎ 設計畫面：

◎ 確定專案為 .Net Framework 4.0：

◎ 專案加入參考：

◎程式解析：

◎執行轉檔程式：

◎MS-SQL --> MySQL 資料轉檔完成，系統正常運轉。

沒有留言:

張貼留言

標籤

2018年7月2日 星期一

省錢大作戰從MS-SQL跳槽到MySQL：第三步撰寫 C# 轉檔程式將資料從 MS-SQL Copy 到 MySQL資料庫

◎ Windows 轉檔程式：

◎ 設計畫面：

◎ 確定專案為 .Net Framework 4.0：

◎ 專案加入參考：

◎程式解析 ：

◎執行轉檔程式 ：

◎MS-SQL --> MySQL 資料轉檔完成，系統正常運轉。

沒有留言:

張貼留言

2018年7月2日星期一

◎程式解析：

◎執行轉檔程式：