老潘的技術分享部落格: 省錢大作戰從MS-SQL跳槽到MySQL：第六步從 MsSQL 備份檔還原 MySQL 資料庫

備份的重點在還原，如果不能還原，那備份就白做了。

◎ 從備份檔還原 MS-SQL ：

執行 SQL Server 2014 Management Studio --> 展開資料庫 --> 右擊 KT --> 工作 --> 還原 --> 資料庫 --> 點擊裝置 --> 點擊。。。 --> 加入 --> 尋找備份檔案 C:\KT\BACKSQL\KT6.bak

MsSQL 尋找備份檔案

--> 確定 --> 確定 --> 點擊選項 --> 勾選覆寫現有的資料庫 --> 確定

MsSQL 資料庫還原成功

◎ Windows 還原程式：

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

C#新增專案

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

◎ 設計畫面：

還原程式畫面設計

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

◎ 專案加入參考：

專案 --> 加入參考 --> 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

◎撰寫程式：

Form1 上 buttonSEARCH，buttonAll，buttonTruncate，buttonRESTORE，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 MAINForm : Form
    {
        public int MaxWidth = 1024;
        public int MaxHeight = 768;

public string ConnectionStringMsSql = @"server=localhost\SQLEXPRESS;database=KT;uid=PAM;pwd=1qaz@WSX";
        public string ConnectionStringMySql = @"server=localhost;database=KT;uid=root;pwd=1qaz@WSX;charset=utf8;PORT=3306;";

public MAINForm()
        {
            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 dt = new DataTable();
            dt.Columns.Add("Table", typeof(String));
            dt.Columns.Add("MsSql", typeof(int));
            dt.Columns.Add("MySql", typeof(int));
            dt.Columns.Add("Sel", typeof(String));
            dt.PrimaryKey = new DataColumn[] { dt.Columns["Table"] };

string Txt = "";
            int iMySql = 0;
            int iMsSql = 0;
            try
            {
                SqlConnection SC_MsSql = new SqlConnection(ConnectionStringMsSql);
                SC_MsSql.Open();
                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 mysqlcommand = new MySqlCommand(Txt, SC_MySql);
                        int iMy = int.Parse(mysqlcommand.ExecuteScalar().ToString());
                        SqlCommand sqlcommand = new SqlCommand(Txt, SC_MsSql);
                        int iMs = int.Parse(sqlcommand.ExecuteScalar().ToString());

DataRow dr1 = dt.NewRow();
                        dr1["Table"] = TableName;
                        dr1["MySql"] = iMy;
                        dr1["MsSql"] = iMs;
                        dt.Rows.Add(dr1);

iMySql += iMy;
                        iMsSql += iMs;
                    }
                }

dataGridView1.DataSource = dt;
                if (dataGridView1.Rows.Count > 0)
                {
                    dataGridView1.Sort(dataGridView1.Columns[0], ListSortDirection.Ascending);
                    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;
                }

ds.Dispose();
                SC_MySql.Close();
                SC_MySql.Dispose();
                textBoxMySql.Text = String.Format("{0,12:n0}", iMySql);
                textBoxMsSql.Text = String.Format("{0,12:n0}", iMsSql);
                textBoxTimeSpan.Text = "";
            }
            catch (MySqlException ex)
            {
                MessageBox.Show("MySQL 錯誤 : " + Txt + " " + ex.Number + " " + ex.Message);
            }
            catch (Exception ex)
            {
                MessageBox.Show("MySQL 錯誤 : " + Txt + " " + ex.Message);
            }
            finally
            { }

Cursor.Current = Cursors.Default;
        }

private void buttonTruncate_Click(object sender, EventArgs e)
        {
            if (MessageBox.Show("確定刪除選取的 MySql 舊資料 ?", "刪除舊資料", MessageBoxButtons.YesNo, MessageBoxIcon.Question, MessageBoxDefaultButton.Button1) == DialogResult.Yes)
            {
                Cursor.Current = Cursors.WaitCursor;
                MySqlConnection SC_MySql = new MySqlConnection(ConnectionStringMySql);
                SC_MySql.Open();
                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)
                    {
                        string Txt = "Truncate Table " + dataGridView1.Rows[i].Cells[0].Value.ToString();
                        MySqlCommand mysqlCommand = new MySqlCommand(Txt, SC_MySql);
                        mysqlCommand.ExecuteNonQuery();
                    }
                }
                SC_MySql.Close();
                buttonSEARCH_Click(sender, e);
                Cursor.Current = Cursors.Default;
            }
        }

private void buttonALL_Click(object sender, EventArgs e)
        {
            for (int i = 0; i < dataGridView1.Rows.Count; i++)
            {
                if (dataGridView1.Rows[i].Cells[3].Value != null && dataGridView1.Rows[i].Cells[3].Value.ToString().Length > 0)
                {dataGridView1.Rows[i].Cells[3].Value = ""; }
                else
                { dataGridView1.Rows[i].Cells[3].Value = "V"; }
            }
        }

private void buttonRESTORE_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 iMsSql = 0;
                        int iMySql = 0;
                        if (dataGridView1.Rows[i].Cells[1].Value != null && dataGridView1.Rows[i].Cells[1].Value.ToString().Length > 0)
                        { iMsSql = int.Parse(dataGridView1.Rows[i].Cells[1].Value.ToString()); }
                        if (dataGridView1.Rows[i].Cells[2].Value != null && dataGridView1.Rows[i].Cells[2].Value.ToString().Length > 0)
                        { iMySql = int.Parse(dataGridView1.Rows[i].Cells[2].Value.ToString()); }
                        int iBal = iMsSql - iMySql;
                        int iPost = 0;
                        if (iBal < 10000)
                        { iPost = Post1(dataGridView1.Rows[i].Cells[0].Value.ToString()); }
                        else
                        { iPost = Post10K(dataGridView1.Rows[i].Cells[0].Value.ToString()); }
                        dataGridView1.Rows[i].Cells[2].Value = iPost;
                        iPosted += iPost;
                    }
                }
                Cursor.Current = Cursors.Default;

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);
                if (iPosted > 0)
                { MessageBox.Show("轉檔完成"); }
            }
        }

private int Post1(string TableName)
        {
            int iPost = 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 dtSORT = new DataTable();
                dtSORT.Columns.Add("SORT_ID", typeof(String));
                dtSORT.PrimaryKey = new DataColumn[] { dtSORT.Columns["SORT_ID"] };

try
                {
                    using (MySqlDataAdapter da = new MySqlDataAdapter(Txt, SC_MySql))
                    {
                        MySqlTransaction transaction = SC_MySql.BeginTransaction();

MySqlCommandBuilder bd = new MySqlCommandBuilder(da);
                        DataTable dt = new DataTable();
                        da.Fill(dt);
                        for (int i = 0; i < DT_MsTable.Rows.Count; i++)
                        {
                            SORT_ID = "";
                            for (int j = 0; j < iKeyCount; j++)
                            {
                                if (DT_MsTable.Rows[i].ItemArray[j] != System.DBNull.Value)
                                { SORT_ID += DT_MsTable.Rows[i].ItemArray[j].ToString() + "|"; }
                            }
                            DataRow result2 = dtSORT.Rows.Find(SORT_ID);
                            if (result2 == null)
                            {
                                DataRow dr = dt.NewRow();
                                for (int j = 0; j < DT_MsTable.Columns.Count; j++)
                                { dr[j] = DT_MsTable.Rows[i].ItemArray[j]; }
                                dt.Rows.Add(dr);
                            }
                        }
                        da.UpdateBatchSize = 1000;
                        iPost = da.Update(dt);

transaction.Commit();
                    }
                }
                catch (MySqlException ex)
                {
                    string ERROR = "MySql : " + TableName + ex.Number + " 轉檔失敗 : " + " " + ex.Message;
                    MessageBox.Show(ERROR);
                }
                catch (Exception ex)
                {
                    string ERROR = TableName + " 轉檔失敗 : " + Txt + " " + ex.Message;
                    MessageBox.Show(ERROR);
                }
                finally
                { }

DT_MsTable.Clear();
                DT_MsTable.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 iPost;
        }

private int Post2(string TableName, DataTable dt)
        {
            int iPost3 = 0;
            string Txt = "";
            try
            {
                MySqlConnection SC_MySql = new MySqlConnection(ConnectionStringMySql);
                SC_MySql.Open();
                DataSet ds = new DataSet();
                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++; }
                }

using (MySqlCommand msc = new MySqlCommand())
                {
                    string sTxt = "Insert into " + TableName + " (";
                    for (int j = 0; j < dt.Columns.Count; j++)
                    {
                        sTxt += dt.Columns[j].ColumnName.ToString();
                        if (j < dt.Columns.Count - 1)
                        { sTxt += ","; }
                        else
                        { sTxt += ")"; }
                    }
                    sTxt += " values (";
                    for (int j = 0; j < dt.Columns.Count; j++)
                    {
                        sTxt += "@" + dt.Columns[j].ColumnName.ToString();
                        if (j < dt.Columns.Count - 1)
                        { sTxt += ","; }
                        else
                        { sTxt += ")"; }
                    }
                    msc.Connection = SC_MySql;
                    msc.CommandText = sTxt;
                    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(")", ""));
                            msc.Parameters.Add(fieldName, MySqlDbType.VarChar, iLength);
                        }
                        if (iInt >= 0)
                        {
                            msc.Parameters.AddWithValue(fieldName, MySqlDbType.Int32);
                        }
                        if (iDecimal >= 0)
                        {
                            msc.Parameters.AddWithValue(fieldName, MySqlDbType.Decimal);
                        }
                    }
                    for (int i = 0; i < dt.Rows.Count; i++)
                    {
                        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");
                            if (j < iKeyCount && (dt.Rows[i].ItemArray[j] == null || dt.Rows[i].ItemArray[j].ToString().Length <= 0))
                            {
                                if (iChar >= 0)
                                { msc.Parameters["@" + FIELD].Value = ""; }
                                else
                                { msc.Parameters["@" + FIELD].Value = 0; }
                            }
                            else
                            { msc.Parameters["@" + FIELD].Value = dt.Rows[i].ItemArray[j]; }
                        }
                        msc.ExecuteScalar();
                    }
                }
                SC_MySql.Close();
                SC_MySql.Dispose();
                iPost3 = dt.Rows.Count;
            }
            catch (MySqlException ex)
            {
                string ERROR = TableName + " : " + ex.Number + " : " + ex.Message;
                MessageBox.Show(ERROR);
            }
            catch (Exception ex)
            {
                string ERROR = TableName + " 新增失敗 : " + Txt + " : " + ex.Message;
                MessageBox.Show(ERROR);
            }
            finally
            { }
            return iPost3;
        }

private int Post10K(string TableName)
        {
            int iPost = 0;
            string Txt = "";
            try
            {
                SqlConnection SC_MsSql = new SqlConnection(ConnectionStringMsSql);
                MySqlConnection SC_MySql = new MySqlConnection(ConnectionStringMySql);
                SC_MySql.Open();

DataSet ds = new DataSet();

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");

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

string SORT_ID = "";
                for (int i = 0; i < DT_MyTable.Rows.Count; i++)
                {
                    SORT_ID = "";
                    for (int j = 0; j < iKeyCount; j++)
                    {
                        if (DT_MyTable.Rows[i].ItemArray[j] != System.DBNull.Value)
                        { SORT_ID += DT_MyTable.Rows[i].ItemArray[j].ToString() + "|"; }
                    }
                    DataRow result1 = dtSORT.Rows.Find(SORT_ID);
                    if (result1 == null)
                    {
                        DataRow dr = dtSORT.NewRow();
                        dr["SORT_ID"] = SORT_ID;
                        dtSORT.Rows.Add(dr);
                        //MessageBox.Show(SORT_ID);
                    }
                }
                int ix = 0;
                DataTable dt = new DataTable();
                for (int j = 0; j < DT_MsTable.Columns.Count; j++)
                { dt.Columns.Add(DT_MsTable.Columns[j].ColumnName, DT_MsTable.Columns[j].DataType); }
                foreach (DataRow drMs in DT_MsTable.Rows)
                {
                    SORT_ID = "";
                    for (int j = 0; j < iKeyCount; j++)
                    {
                        if (drMs[j] != System.DBNull.Value)
                        { SORT_ID += drMs[j].ToString() + "|"; }
                    }
                    DataRow result2 = dtSORT.Rows.Find(SORT_ID);
                    if (result2 == null)
                    {
                        ix++;
                        DataRow dr = dt.NewRow();
                        for (int j = 0; j < DT_MsTable.Columns.Count; j++)
                        { dr[j] = drMs[j]; }
                        dt.Rows.Add(dr);
                    }
                    if (ix >= 10000)
                    {
                        iPost += Post2(TableName, dt);
                        dt.Clear();
                        ix = 0;
                    }
                }
                if (ix > 0)
                { iPost += Post2(TableName, dt); }

DT_MsTable.Clear();
                DT_MsTable.Dispose();
                ds.Dispose();

SC_MsSql.Close();
                SC_MsSql.Dispose();

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

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

}
}

--> 然後按執行

◎程式解析：

○專案參考命名空間：

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

○連線字串：
public string ConnectionStringMSSQL = @"server=localhost\SQLEXPRESS;database=KT;uid=PAM;pwd=12345678";

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

○buttonSEARCH_Click：

建立 dt --> 連結 MySQL 資料庫 --> 用 Show Tables 讀出 KT 資料庫所有 Tables --> 用 SELECT COUNT(*) from Table 逐一讀取 MsSQL 與 MySQL 資料表之筆數。
最後將 dataGridView1 之 DataSource 綁訂為 dt，為 dataGridView1 做細部設定 --> 然後顯示抓到之總筆數。

○buttonAll_Click：
逐一檢查 dataGridView1 之 Sel 欄位 --> 無值者放 V；有值者放空白

○buttonTruncate_Click：
逐一檢查 dataGridView1 之 Sel 欄位有值者 --> 用 Truncate Table 清除 MySQL 資料表之資料

○buttonRESTORE_Click：

逐一檢查 dataGridView1 之 Sel 欄位有值者 --> 如果 MsSql 資料表之筆數小於 10000，使用 MySqlDataAdapter 技術來還原；否則以 1000 筆為單位用參數化查詢還原。

顯還原筆數，與還原使用時間。

○buttonEXIT_Click：
結束還原程式

◎執行還原程式：

偵錯 --> 開始偵錯 --> 按 SEARCH --> 全選

共選取 299 萬筆資料要還原到 MySQL

接著按 Restore

299 萬筆資料還原到 MySQL 需要 34 分 49 秒

◎選擇性還原：

本程式可選擇性還原特定資料表，使用此功能時需暸解資料表的關連性。

老潘的技術分享部落格

標籤

2018年7月6日星期五

省錢大作戰從MS-SQL跳槽到MySQL：第六步從 MsSQL 備份檔還原 MySQL 資料庫

◎ 從備份檔還原 MS-SQL ：

◎ 設計畫面：

◎ 專案加入參考：

◎撰寫程式：

◎程式解析：

◎執行還原程式：

沒有留言:

張貼留言

標籤

2018年7月6日 星期五

省錢大作戰從MS-SQL跳槽到MySQL：第六步從 MsSQL 備份檔還原 MySQL 資料庫

◎ 從備份檔還原 MS-SQL ：

◎ 設計畫面：

◎ 專案加入參考：

◎撰寫程式：

◎程式解析 ：

◎執行還原程式 ：

沒有留言:

張貼留言

2018年7月6日星期五

◎程式解析：

◎執行還原程式：