老潘的技術分享部落格: 2018

2018年7月6日星期五

省錢大作戰從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 秒

◎選擇性還原：

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

省錢大作戰從MS-SQL跳槽到MySQL：第五步透過 MsSQL 備份 MySQL 資料庫

MySQLDUMP 是官方推薦的資料庫備份工具，只是遇到中文就有一堆問題，乾脆自己寫一個備份程式。

◎ 安裝 MS-SQL Express：

下載並執行 SQLEXPRADV_x64_CHT.exe 安裝 MS-SQL Express，目前使用的是 2014 版。

◎ 建立資料庫：

執行 SQL Server 2014 Management Studio --> 連上資料庫 --> Create DataBase KT; --> Use KT; --> 在 Query 視窗輸入：

CREATE TABLE ADJ (
       ADJ_ID             NVarChar(12) NOT NULL,
       D_TRAN             NVarChar(10) NULL,
       PART_NO            NVarChar(10) NULL,
       PART_SP            NVarChar(10) NULL,
       STR_ID             NVarChar(4) NULL,
       AM                 NVarChar(1) NULL,
       P_TRAN             NUMERIC(16, 2) NULL,
       Q_ONHAND           NUMERIC(16, 2) NULL,
       Q_TRAN             NUMERIC(16, 2) NULL,
       EMP_ID             NVarChar(10) NULL,
       REMARK             NVarChar(40) NULL,
       DESC_C             NVarChar(40) NULL,
       DESC_E             NVarChar(40) NULL,
       UM                 NVarChar(6) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(ADJ_ID));

CREATE TABLE ADL (
       PART_NO            NVarChar(10) NOT NULL,
       PART_SP            NVarChar(10) NOT NULL,
       DLR_VND            NVarChar(10) NOT NULL,
       P_ORD              NUMERIC(16, 2) NULL,
       Q_ORD              NUMERIC(16, 2) NULL,
       D_ORD              NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(PART_NO, PART_SP, DLR_VND));

CREATE TABLE APM (
       DLR_VND            NVarChar(10) NOT NULL,
       YY                 SMALLINT NOT NULL,
       MM                 SMALLINT NOT NULL,
       MC                 NVarChar(1) NOT NULL,
       NAME               NVarChar(40) NULL,
       EMP_ID             NVarChar(10) NULL,
       RCM_CNT            SMALLINT NULL,
       A_RCV              NUMERIC(16, 2) NULL,
       A_RTV              NUMERIC(16, 2) NULL,
       A_CASH             NUMERIC(16, 2) NULL,
       A_CHECK            NUMERIC(16, 2) NULL,
       A_DISC_INT         NUMERIC(16, 2) NULL,
       A_DISC_BAL         NUMERIC(16, 2) NULL,
       A_DISC_ITEM        NUMERIC(16, 2) NULL,
       A_DISC_OTHER       NUMERIC(16, 2) NULL,
       A_INV              NUMERIC(16, 2) NULL,
       A_BEG              NUMERIC(16, 2) NULL,
       D_AP               NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(DLR_VND, YY, MM, MC));

CREATE TABLE ARM (
       DLR_VND            NVarChar(10) NOT NULL,
       YY                 SMALLINT NOT NULL,
       MM                 SMALLINT NOT NULL,
       NAME               NVarChar(40) NULL,
       EMP_ID             NVarChar(10) NULL,
       DOC_NO             NVarChar(10) NULL,
       SHM_CNT            SMALLINT NULL,
       A_SHIP             NUMERIC(16, 2) NULL,
       A_RFD              NUMERIC(16, 2) NULL,
       A_CASH             NUMERIC(16, 2) NULL,
       A_CHECK            NUMERIC(16, 2) NULL,
       A_DISC_INT         NUMERIC(16, 2) NULL,
       A_DISC_BAL         NUMERIC(16, 2) NULL,
       A_DISC_ITEM        NUMERIC(16, 2) NULL,
       A_DISC_OTHER       NUMERIC(16, 2) NULL,
       A_INV              NUMERIC(16, 2) NULL,
       A_BEG              NUMERIC(16, 2) NULL,
       REMARK             NVarChar(40) NULL,
       D_AR               NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(DLR_VND, YY, MM));

CREATE TABLE AVL (
       PART_NO            NVarChar(10) NOT NULL,
       PART_SP            NVarChar(10) NOT NULL,
       DLR_VND            NVarChar(10) NOT NULL,
       P_ORD              NUMERIC(16, 2) NULL,
       Q_ORD              NUMERIC(16, 2) NULL,
       D_ORD              NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(PART_NO, PART_SP, DLR_VND));

CREATE TABLE BNK (
       BNK_ID             NVarChar(12) NOT NULL,
       TYPE               NVarChar(1) NULL,
       NAME               NVarChar(40) NULL,
       ACCT_NO            NVarChar(16) NULL,
       CURR               NVarChar(4) NULL,
       REMARK             NVarChar(40) NULL,
       P_RATE             NUMERIC(16, 2) NULL,
       A_SAVE             NUMERIC(16, 2) NULL,
       A_INT              NUMERIC(16, 2) NULL,
       A_TAX              NUMERIC(16, 2) NULL,
       A_LOAN             NUMERIC(16, 2) NULL,
       A_USED             NUMERIC(16, 2) NULL,
       A_BAL              NUMERIC(16, 2) NULL,
       D_BEG              NVarChar(10) NULL,
       D_END              NVarChar(10) NULL,
       D_CLOSE            NVarChar(10) NULL,
       D_EXPIRED          NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(BNK_ID));

CREATE TABLE CND (
       CNM_ID             NVarChar(12) NOT NULL,
       ITEM               SMALLINT NOT NULL,
       PART_NO            NVarChar(10) NULL,
       PART_SP            NVarChar(10) NULL,
       Q_ONHAND           NUMERIC(16, 2) NULL,
       Q_CNT              NUMERIC(16, 2) NULL,
       DESC_C             NVarChar(40) NULL,
       DESC_E             NVarChar(40) NULL,
       UM                 NVarChar(6) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(CNM_ID, ITEM));

CREATE TABLE CNM (
       CNM_ID             NVarChar(12) NOT NULL,
       STR_ID             NVarChar(4) NULL,
       D_TRAN             NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(CNM_ID));

CREATE TABLE COR (
       COR_ID             VARCHAR(10) NOT NULL,
       ID                 VARCHAR(10) NULL,
       NAME               VARCHAR(50) NULL,
       NAME_E             VARCHAR(50) NULL,
       PRN                VARCHAR(10) NULL,
       SERIES             VARCHAR(10) NULL,
       D_ADD              nVarChar(20) NULL,       
       D_CHG              nVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(COR_ID));

CREATE TABLE CPD (
       CPD_ID             NVarChar(10) NOT NULL,
       RCM_ID             NVarChar(12) NULL,
       DLR_VND            NVarChar(10) NULL,
       YY                 SMALLINT NULL,
       MM                 SMALLINT NULL,
       MC                 NVarChar(1) NULL,
       NAME               NVarChar(40) NULL,
       EMP_ID             NVarChar(10) NULL,
       DOC_NO             NVarChar(16) NULL,
       A_CASH             NUMERIC(16, 2) NULL,
       A_CHECK            NUMERIC(16, 2) NULL,
       A_DISC_INT         NUMERIC(16, 2) NULL,
       A_DISC_BAL         NUMERIC(16, 2) NULL,
       A_DISC_ITEM        NUMERIC(16, 2) NULL,
       A_DISC_OTHER       NUMERIC(16, 2) NULL,
       A_INV              NUMERIC(16, 2) NULL,
       STATUS             NVarChar(1) NULL,
       POST               NVarChar(1) NULL,
       FLAG               NVarChar(1) NULL,
       REMARK             NVarChar(40) NULL,
       D_PAY              NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(CPD_ID));

CREATE TABLE CRD (
       CRD_ID             NVarChar(10) NOT NULL,
       SHM_ID             NVarChar(12) NULL,
       DLR_VND            NVarChar(10) NULL,
       YY                 SMALLINT NULL,
       MM                 SMALLINT NULL,
       MC                 NVarChar(1) NULL,
       DVM_SEQ            INT NULL,
       NAME               NVarChar(40) NULL,
       EMP_ID             NVarChar(10) NULL,
       DOC_NO             NVarChar(16) NULL,
       PRINT_CNT          SMALLINT NULL,
       A_CASH             NUMERIC(16, 2) NULL,
       A_CHECK            NUMERIC(16, 2) NULL,
       A_DISC_INT         NUMERIC(16, 2) NULL,
       A_DISC_BAL         NUMERIC(16, 2) NULL,
       A_DISC_ITEM        NUMERIC(16, 2) NULL,
       A_DISC_OTHER       NUMERIC(16, 2) NULL,
       A_INV              NUMERIC(16, 2) NULL,
       STATUS             NVarChar(1) NULL,
       POST               NVarChar(1) NULL,
       FLAG               NVarChar(1) NULL,
       REMARK             NVarChar(40) NULL,
       D_RCV              NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(CRD_ID));

CREATE TABLE DEP (
       DEP_ID             NVarChar(10) NOT NULL,
       NAME               NVarChar(20) NULL,
       REMARK             NVarChar(40) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(DEP_ID));

CREATE TABLE DVM (
       DLR_VND            NVarChar(10) NOT NULL,
       DVM_SEQ            INT NULL,
       ID_CODE            NVarChar(8) NULL,
       ID_2               NVarChar(8) NULL,
       NAME               NVarChar(40) NULL,
       NAME_TITLE         NVarChar(40) NULL,
       EMP_ID             NVarChar(10) NULL,
       TYPE               NVarChar(1) NULL,
       TAX                NVarChar(6) NULL,
       HOLD               NVarChar(1) NULL,
       CASH               NVarChar(1) NULL,
       RANK               NVarChar(1) NULL,
       ACCT_1             NVarChar(10) NULL,
       ACCT_2             NVarChar(10) NULL,
       ADDR_S             NVarChar(60) NULL,
       ADDR_I             NVarChar(60) NULL,
       TEL_1              NVarChar(50) NULL,
       TEL_2              NVarChar(50) NULL,
       FAX                NVarChar(50) NULL,
       TPM_ID             NVarChar(18) NULL,
       PRESIDENT          NVarChar(20) NULL,
       CONTECT            NVarChar(20) NULL,
       POSITION           NVarChar(20) NULL,
       TER_ID             NVarChar(4) NULL,
       CLASS              NVarChar(10) NULL,
       OLD_DLR_VND        NVarChar(10) NULL,
       ZIP                NVarChar(6) NULL,
       ZIP_2              NVarChar(6) NULL,
       CURR               NVarChar(4) NULL,
       FIX_PCT            NUMERIC(16, 2) NULL,
       REMARK             NVarChar(60) NULL,
       A_QUOT             NUMERIC(16, 2) NULL,
       A_ORD              NUMERIC(16, 2) NULL,
       D_QUOT             NVarChar(10) NULL,
       D_ORD              NVarChar(10) NULL,
       D_EXPIRE           NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(DLR_VND));

CREATE TABLE EMP (
       EMP_ID             NVarChar(10) NOT NULL,
       NAME               NVarChar(10) NULL,
       ID_CODE            NVarChar(10) NULL,
       SEX                NVarChar(1) NULL,
       QUIT               NVarChar(1) NULL,
       REPORT             NVarChar(1) NULL,
       DEP_ID             NVarChar(4) NULL,
       TEL_1              NVarChar(18) NULL,
       TEL_2              NVarChar(18) NULL,
       TITLE              NVarChar(20) NULL,
       ADDR               NVarChar(60) NULL,
       ADDR_I             NVarChar(60) NULL,
       EDUCATION          NVarChar(40) NULL,
       A_BASE             INT NULL,
       D_BIRTH            NVarChar(10) NULL,
       D_HIRE             NVarChar(10) NULL,
       D_QUIT             NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(EMP_ID));

CREATE TABLE ICM (
       PART_NO            NVarChar(10) NOT NULL,
       DESC_C             NVarChar(40) NULL,
       UM                 NVarChar(6) NULL,
       ICM_SP             INT NULL,
       REMARK             NVarChar(40) NULL,
       OLD_PART_NO        NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(PART_NO));

CREATE TABLE ITH (
       PART_NO            NVarChar(10) NOT NULL,
       PART_SP            NVarChar(10) NOT NULL,
       D_TRAN             NVarChar(10) NOT NULL,
       P_STD              NUMERIC(16, 2) NULL,
       P_CUR              NUMERIC(16, 2) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(PART_NO, PART_SP, D_TRAN));

CREATE TABLE ITM (
       PART_NO            NVarChar(10) NOT NULL,
       PART_SP            NVarChar(10) NOT NULL,
       SEQ                INT NULL,
       DESC_C             NVarChar(40) NULL,
       DESC_E             NVarChar(40) NULL,
       BRAND              NVarChar(20) NULL,
       UM                 NVarChar(6) NULL,
       HOLD               NVarChar(1) NULL,
       ONSALE             NVarChar(1) NULL,
       TYPE               NVarChar(1) NULL,
       STATUS             NVarChar(1) NULL,
       ICM_SP             INT NULL,
       IVS_PART           NVarChar(20) NULL,
       OLD_PART_NO        NVarChar(10) NULL,
       OLD_PART_SP        INT NULL,
       CURR               NVarChar(4) NULL,
       REMARK             NVarChar(20) NULL,
       P_CUR              NUMERIC(16, 2) NULL,
       P_NEW              NUMERIC(16, 2) NULL,
       P_STD              NUMERIC(16, 2) NULL,
       P_A                NUMERIC(16, 2) NULL,
       P_B                NUMERIC(16, 2) NULL,
       P_C                NUMERIC(16, 2) NULL,
       P_D                NUMERIC(16, 2) NULL,
       P_E                NUMERIC(16, 2) NULL,
       P_AVG              NUMERIC(16, 2) NULL,
       P_RCV              NUMERIC(16, 2) NULL,
       P_FOB              NUMERIC(16, 2) NULL,
       P_PROM             NUMERIC(16, 2) NULL,
       P_ONSALE           NUMERIC(16, 2) NULL,
       Q_SAFETY           INT NULL,
       D_EFF              NVarChar(10) NULL,
       D_HOLD             NVarChar(10) NULL,
       D_BEG              NVarChar(10) NULL,
       D_END              NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(PART_NO, PART_SP));

CREATE TABLE NCM (
       NCM_ID             NVarChar(1) NOT NULL,
       CAPITAL            NVarChar(2) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(NCM_ID));

CREATE TABLE NPD (
       NPD_ID             NVarChar(12) NOT NULL,
       D_CHECK            NVarChar(10) NULL,
       A_CHECK            NUMERIC(16, 2) NULL,
       BNK_ID             NVarChar(12) NULL,
       ACCT_NO            NVarChar(16) NULL,
       CPD_ID             NVarChar(10) NULL,
       VND_ID             NVarChar(10) NULL,
       YY                 INT NULL,
       MM                 INT NULL,
       NAME               NVarChar(40) NULL,
       DLR_FROM           NVarChar(10) NULL,
       SERIAL_NO          NVarChar(10) NULL,
       DOC_NO             NVarChar(10) NULL,
       MC                 NVarChar(1) NULL,
       SC                 NVarChar(1) NULL,
       STATUS             NVarChar(1) NULL,
       POST               NVarChar(1) NULL,
       RCM_ID             NVarChar(12) NULL,
       D_OPEN             NVarChar(10) NULL,
       D_PAY              NVarChar(10) NULL,
       D_CASH             NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(NPD_ID));

CREATE TABLE NRD (
       NRD_ID             NVarChar(12) NOT NULL,
       D_CHECK            NVarChar(10) NULL,
       A_CHECK            NUMERIC(16, 2) NULL,
       CHECK_BANK         NVarChar(20) NULL,
       BANK_NAME          NVarChar(20) NULL,
       CHECK_ACCT         NVarChar(16) NULL,
       DLR_ID             NVarChar(10) NULL,
       YY                 INT NULL,
       MM                 INT NULL,
       CRD_ID             NVarChar(10) NULL,
       NAME               NVarChar(40) NULL,
       BNK_ID             NVarChar(12) NULL,
       SEQ                INT NULL,
       VND_TO             NVarChar(10) NULL,
       SERIAL_NO          NVarChar(10) NULL,
       DEPOSIT_NO         NVarChar(10) NULL,
       DOC_NO             NVarChar(10) NULL,
       TO_NAME            NVarChar(40) NULL,
       MC                 NVarChar(1) NULL,
       SC                 NVarChar(1) NULL,
       STATUS             NVarChar(1) NULL,
       TERR               NVarChar(1) NULL,
       SHM_ID             NVarChar(12) NULL,
       D_OPEN             NVarChar(10) NULL,
       D_RCV              NVarChar(10) NULL,
       D_DEPOSIT          NVarChar(10) NULL,
       D_SAVE             NVarChar(10) NULL,
       D_CASH             NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(NRD_ID));

CREATE TABLE PGM (
       PGM_ID             NVarChar(6) NOT NULL,
       NAME               NVarChar(40) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
PRIMARY KEY(PGM_ID));

CREATE TABLE POD (
       POM_ID             NVarChar(16) NOT NULL,
       ITEM               SMALLINT NOT NULL,
       PART_NO            NVarChar(10) NULL,
       PART_SP            NVarChar(10) NULL,
       DESC_C             NVarChar(40) NULL,
       DESC_E             NVarChar(40) NULL,
       UM                 NVarChar(4) NULL,
       PRN                NVarChar(1) NULL,
       STR_ID             NVarChar(4) NULL,
       REMARK             NVarChar(20) NULL,
       P_ORD              NUMERIC(16, 2) NULL,
       P_NEW              NUMERIC(16, 2) NULL,
       Q_ORD              NUMERIC(16, 2) NULL,
       Q_RCV              NUMERIC(16, 2) NULL,
       A_ORD              NUMERIC(16, 2) NULL,
       A_NT               NUMERIC(16, 2) NULL,
       D_DLV              NVarChar(10) NULL,
       D_RCV              NVarChar(10) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(POM_ID, ITEM));

CREATE TABLE POM (
       POM_ID             NVarChar(16) NOT NULL,
       EMP_ID             NVarChar(10) NULL,
       DLR_VND            NVarChar(10) NULL,
       NAME               NVarChar(40) NULL,
       REMARK             NVarChar(60) NULL,
       MC                 NVarChar(1) NULL,
       POST               NVarChar(1) NULL,
       FLAG               NVarChar(1) NULL,
       TAX                NVarChar(6) NULL,
       STR_ID             NVarChar(4) NULL,
       CURR               NVarChar(4) NULL,
       PRINT_CNT          SMALLINT NULL,
       R_EXCH             NUMERIC(16, 2) NULL,
       A_ORD              NUMERIC(16, 2) NULL,
       D_ORD              NVarChar(10) NULL,
       D_DLV              NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(POM_ID));

CREATE TABLE QID (
       QIM_ID             NVarChar(10) NOT NULL,
       ITEM               SMALLINT NOT NULL,
       PART_NO            NVarChar(10) NULL,
       PART_SP            NVarChar(10) NULL,
       DESC_C             NVarChar(40) NULL,
       DESC_E             NVarChar(40) NULL,
       P_QUOT             NUMERIC(16, 2) NULL,
       Q_QUOT             NUMERIC(16, 2) NULL,
       A_QUOT             NUMERIC(16, 2) NULL,
       UM                 NVarChar(4) NULL,
       D_DLV              NVarChar(10) NULL,
       REMARK             NVarChar(10) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(QIM_ID, ITEM));

CREATE TABLE QIM (
       QIM_ID             NVarChar(10) NOT NULL,
       DLR_VND            NVarChar(10) NULL,
       NAME               NVarChar(40) NULL,
       EMP_ID             NVarChar(10) NULL,
       TAX                NVarChar(6) NULL,
       CURR               NVarChar(4) NULL,
       A_QUOT             NUMERIC(16, 2) NULL,
       A_COST             NUMERIC(16, 2) NULL,
       D_QUOT             NVarChar(10) NULL,
       D_EXPIRED          NVarChar(10) NULL,
       TERMS              NVarChar(40) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(QIM_ID));

CREATE TABLE QOD (
       QOM_ID             NVarChar(10) NOT NULL,
       ITEM               SMALLINT NOT NULL,
       PART_NO            NVarChar(10) NULL,
       PART_SP            NVarChar(10) NULL,
       DESC_C             NVarChar(40) NULL,
       DESC_E             NVarChar(40) NULL,
       P_QUOT             NUMERIC(16, 2) NULL,
       Q_QUOT             NUMERIC(16, 2) NULL,
       A_QUOT             NUMERIC(16, 2) NULL,
       P_COST             NUMERIC(16, 2) NULL,
       UM                 NVarChar(4) NULL,
       REMARK             NVarChar(40) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(QOM_ID, ITEM));

CREATE TABLE QOM (
       QOM_ID             NVarChar(10) NOT NULL,
       EMP_ID             NVarChar(10) NULL,
       DLR_VND            NVarChar(10) NULL,
       NAME               NVarChar(40) NULL,
       TAX                NVarChar(6) NULL,
       RANK               NVarChar(1) NULL,
       A_QUOT             NUMERIC(16, 2) NULL,
       D_QUOT             NVarChar(10) NULL,
       D_EXPIRED          NVarChar(10) NULL,
       TERMS              NVarChar(40) NULL,
       MEMO               NVarChar(238) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
PRIMARY KEY(QOM_ID));

CREATE TABLE RCD (
       RCM_ID             NVarChar(12) NOT NULL,
       ITEM               SMALLINT NOT NULL,
       PART_NO            NVarChar(10) NULL,
       PART_SP            NVarChar(10) NULL,
       DESC_C             NVarChar(40) NULL,
       DESC_E             NVarChar(40) NULL,
       UM                 NVarChar(4) NULL,
       ICM_SP             INT NULL,
       TYPE               NVarChar(1) NULL,
       FREE               NVarChar(1) NULL,
       POST               NVarChar(1) NULL,
       STK                NVarChar(1) NULL,
       INV_NO             NVarChar(12) NULL,
       STR_ID             NVarChar(4) NULL,
       Q_FIRM             NUMERIC(16, 2) NULL,
       Q_RCV              NUMERIC(16, 2) NULL,
       Q_STK              NUMERIC(16, 2) NULL,
       P_ORD              NUMERIC(16, 2) NULL,
       P_COST             NUMERIC(16, 2) NULL,
       A_RCV              NUMERIC(16, 2) NULL,
       A_NT               NUMERIC(16, 2) NULL,
       A_DISCOUNT         NUMERIC(16, 2) NULL,
       D_DLV              NVarChar(10) NULL,
       D_RCV              NVarChar(10) NULL,
       D_DISCOUNT         NVarChar(10) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(RCM_ID, ITEM));

CREATE TABLE RCDDBK (
       RCM_ID             NVarChar(12) NOT NULL,
       ITEM               SMALLINT NOT NULL,
       PART_NO            NVarChar(10) NULL,
       PART_SP            NVarChar(10) NULL,
       DESC_C             NVarChar(40) NULL,
       DESC_E             NVarChar(40) NULL,
       UM                 NVarChar(4) NULL,
       ICM_SP             INT NULL,
       TYPE               NVarChar(1) NULL,
       FREE               NVarChar(1) NULL,
       POST               NVarChar(1) NULL,
       STK                NVarChar(1) NULL,
       INV_NO             NVarChar(12) NULL,
       STR_ID             NVarChar(4) NULL,
       Q_FIRM             NUMERIC(16, 2) NULL,
       Q_RCV              NUMERIC(16, 2) NULL,
       Q_STK              NUMERIC(16, 2) NULL,
       P_ORD              NUMERIC(16, 2) NULL,
       P_COST             NUMERIC(16, 2) NULL,
       A_RCV              NUMERIC(16, 2) NULL,
       A_NT               NUMERIC(16, 2) NULL,
       A_DISCOUNT         NUMERIC(16, 2) NULL,
       D_DLV              NVarChar(10) NULL,
       D_RCV              NVarChar(10) NULL,
       D_DISCOUNT         NVarChar(10) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(RCM_ID, ITEM));

CREATE TABLE RCM (
       RCM_ID             NVarChar(12) NOT NULL,
       INV_NO             NVarChar(10) NULL,
       POM_ID             NVarChar(16) NULL,
       SHIPPER            NVarChar(10) NULL,
       EMP_ID             NVarChar(10) NULL,
       DLR_VND            NVarChar(10) NULL,
       DVM_SEQ            INT NULL,
       YY                 SMALLINT NULL,
       MM                 SMALLINT NULL,
       TYPE               NVarChar(1) NULL,
       MC                 NVarChar(1) NULL,
       NAME               NVarChar(40) NULL,
       ADDR               NVarChar(60) NULL,
       TEL                NVarChar(18) NULL,
       REMARK             NVarChar(40) NULL,
       STK                NVarChar(1) NULL,
       RANK               NVarChar(1) NULL,
       POST               NVarChar(1) NULL,
       SHIP_VIA           NVarChar(1) NULL,
       TAX                NVarChar(1) NULL,
       PAY                NVarChar(1) NULL,
       STR_ID             NVarChar(4) NULL,
       PRINT_CNT          SMALLINT NULL,
       A_RCV              NUMERIC(16, 2) NULL,
       A_CASH             NUMERIC(16, 2) NULL,
       A_CHECK            NUMERIC(16, 2) NULL,
       A_DISC_INT         NUMERIC(16, 2) NULL,
       A_DISC_BAL         NUMERIC(16, 2) NULL,
       A_DISC_ITEM        NUMERIC(16, 2) NULL,
       A_DISC_OTHER       NUMERIC(16, 2) NULL,
       A_INV              NUMERIC(16, 2) NULL,
       D_ORD              NVarChar(10) NULL,
       D_DLV              NVarChar(10) NULL,
       D_RCV              NVarChar(10) NULL,
       D_INV              NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(RCM_ID));

CREATE TABLE RCMDBK (
       RCM_ID             NVarChar(12) NOT NULL,
       INV_NO             NVarChar(10) NULL,
       POM_ID             NVarChar(16) NULL,
       SHIPPER            NVarChar(10) NULL,
       EMP_ID             NVarChar(10) NULL,
       DLR_VND            NVarChar(10) NULL,
       DVM_SEQ            INT NULL,
       YY                 SMALLINT NULL,
       MM                 SMALLINT NULL,
       TYPE               NVarChar(1) NULL,
       MC                 NVarChar(1) NULL,
       NAME               NVarChar(40) NULL,
       ADDR               NVarChar(60) NULL,
       TEL                NVarChar(18) NULL,
       REMARK             NVarChar(40) NULL,
       STK                NVarChar(1) NULL,
       RANK               NVarChar(1) NULL,
       POST               NVarChar(1) NULL,
       SHIP_VIA           NVarChar(1) NULL,
       TAX                NVarChar(1) NULL,
       PAY                NVarChar(1) NULL,
       STR_ID             NVarChar(4) NULL,
       PRINT_CNT          SMALLINT NULL,
       A_RCV              NUMERIC(16, 2) NULL,
       A_CASH             NUMERIC(16, 2) NULL,
       A_CHECK            NUMERIC(16, 2) NULL,
       A_DISC_INT         NUMERIC(16, 2) NULL,
       A_DISC_BAL         NUMERIC(16, 2) NULL,
       A_DISC_ITEM        NUMERIC(16, 2) NULL,
       A_DISC_OTHER       NUMERIC(16, 2) NULL,
       A_INV              NUMERIC(16, 2) NULL,
       D_ORD              NVarChar(10) NULL,
       D_DLV              NVarChar(10) NULL,
       D_RCV              NVarChar(10) NULL,
       D_INV              NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(RCM_ID));

CREATE TABLE SEM (
       PART_NO            NVarChar(10) NOT NULL,
       PART_SP            NVarChar(10) NOT NULL,
       STR_ID             NVarChar(4) NOT NULL,
       YY                 SMALLINT NOT NULL,
       MM                 SMALLINT NOT NULL,
       A_FORECAST         NUMERIC(16, 2) NULL,
       Q_BEG              NUMERIC(16, 2) NULL,
       A_BEG              NUMERIC(16, 2) NULL,
       Q_RCV              NUMERIC(16, 2) NULL,
       A_RCV              NUMERIC(16, 2) NULL,
       Q_RTV              NUMERIC(16, 2) NULL,
       A_RTV              NUMERIC(16, 2) NULL,
       Q_SHIP             NUMERIC(16, 2) NULL,
       A_SHIP             NUMERIC(16, 2) NULL,
       Q_RFD              NUMERIC(16, 2) NULL,
       A_RFD              NUMERIC(16, 2) NULL,
       Q_ADJ              NUMERIC(16, 2) NULL,
       Q_CNT              NUMERIC(16, 2) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(PART_NO, PART_SP, STR_ID, YY, MM));

CREATE TABLE SHD (
       SHM_ID             NVarChar(12) NOT NULL,
       ITEM               SMALLINT NOT NULL,
       SOM_ID             NVarChar(10) NULL,
       SOD_ITEM           SMALLINT NULL,
       PART_NO            NVarChar(10) NULL,
       PART_SP            NVarChar(10) NULL,
       DESC_C             NVarChar(40) NULL,
       DESC_E             NVarChar(40) NULL,
       UM                 NVarChar(4) NULL,
       ICM_SP             INT NULL,
       TYPE               NVarChar(1) NULL,
       FREE               NVarChar(1) NULL,
       POST               NVarChar(1) NULL,
       STK                NVarChar(1) NULL,
       Q_FIRM             NUMERIC(16, 2) NULL,
       Q_SHIP             NUMERIC(16, 2) NULL,
       Q_STK              NUMERIC(16, 2) NULL,
       P_ORD              NUMERIC(16, 2) NULL,
       P_COST             NUMERIC(16, 2) NULL,
       A_SHIP             NUMERIC(16, 2) NULL,
       A_DISCOUNT         NUMERIC(16, 2) NULL,
       D_DLV              NVarChar(10) NULL,
       D_SHIP             NVarChar(10) NULL,
       D_DISCOUNT         NVarChar(10) NULL,
       REMARK             NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(SHM_ID, ITEM));

CREATE TABLE SHDDBK (
       SHM_ID             NVarChar(12) NOT NULL,
       ITEM               SMALLINT NOT NULL,
       SOM_ID             NVarChar(10) NULL,
       SOD_ITEM           SMALLINT NULL,
       PART_NO            NVarChar(10) NULL,
       PART_SP            NVarChar(10) NULL,
       DESC_C             NVarChar(40) NULL,
       DESC_E             NVarChar(40) NULL,
       UM                 NVarChar(4) NULL,
       ICM_SP             INT NULL,
       TYPE               NVarChar(1) NULL,
       FREE               NVarChar(1) NULL,
       POST               NVarChar(1) NULL,
       STK                NVarChar(1) NULL,
       Q_FIRM             NUMERIC(16, 2) NULL,
       Q_SHIP             NUMERIC(16, 2) NULL,
       Q_STK              NUMERIC(16, 2) NULL,
       P_ORD              NUMERIC(16, 2) NULL,
       P_COST             NUMERIC(16, 2) NULL,
       A_SHIP             NUMERIC(16, 2) NULL,
       A_DISCOUNT         NUMERIC(16, 2) NULL,
       D_DLV              NVarChar(10) NULL,
       D_SHIP             NVarChar(10) NULL,
       D_DISCOUNT         NVarChar(10) NULL,
       REMARK             NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(SHM_ID, ITEM));

CREATE TABLE SHM (
       SHM_ID             NVarChar(12) NOT NULL,
       D_SHIP             NVarChar(10) NULL,
       INV_NO             NVarChar(10) NULL,
       SOM_ID             NVarChar(10) NULL,
       SHIPPER            NVarChar(10) NULL,
       EMP_ID             NVarChar(10) NULL,
       DLR_VND            NVarChar(10) NULL,
       DVM_SEQ            INT NULL,
       YY                 SMALLINT NULL,
       MM                 SMALLINT NULL,
       TYPE               NVarChar(1) NULL,
       MC                 NVarChar(1) NULL,
       NAME               NVarChar(40) NULL,
       ADDR               NVarChar(60) NULL,
       TEL                NVarChar(18) NULL,
       REMARK             NVarChar(40) NULL,
       STK                NVarChar(1) NULL,
       RANK               NVarChar(1) NULL,
       POST               NVarChar(1) NULL,
       SHIP_VIA           NVarChar(1) NULL,
       TAX                NVarChar(1) NULL,
       RCV                NVarChar(1) NULL,
       STR_ID             NVarChar(4) NULL,
       PRINT_CNT          SMALLINT NULL,
       A_SHIP             NUMERIC(16, 2) NULL,
       A_CASH             NUMERIC(16, 2) NULL,
       A_CHECK            NUMERIC(16, 2) NULL,
       A_DISC_INT         NUMERIC(16, 2) NULL,
       A_DISC_BAL         NUMERIC(16, 2) NULL,
       A_DISC_ITEM        NUMERIC(16, 2) NULL,
       A_DISC_OTHER       NUMERIC(16, 2) NULL,
       A_TEMP             NUMERIC(16, 2) NULL,
       A_INV              NUMERIC(16, 2) NULL,
       D_ORD              NVarChar(10) NULL,
       D_DLV              NVarChar(10) NULL,
       D_INV              NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(SHM_ID));

CREATE TABLE SHMDBK (
       SHM_ID             NVarChar(12) NOT NULL,
       D_SHIP             NVarChar(10) NULL,
       INV_NO             NVarChar(10) NULL,
       SOM_ID             NVarChar(10) NULL,
       SHIPPER            NVarChar(10) NULL,
       EMP_ID             NVarChar(10) NULL,
       DLR_VND            NVarChar(10) NULL,
       DVM_SEQ            INT NULL,
       YY                 SMALLINT NULL,
       MM                 SMALLINT NULL,
       TYPE               NVarChar(1) NULL,
       MC                 NVarChar(1) NULL,
       NAME               NVarChar(40) NULL,
       ADDR               NVarChar(60) NULL,
       TEL                NVarChar(18) NULL,
       REMARK             NVarChar(40) NULL,
       STK                NVarChar(1) NULL,
       RANK               NVarChar(1) NULL,
       POST               NVarChar(1) NULL,
       SHIP_VIA           NVarChar(1) NULL,
       TAX                NVarChar(1) NULL,
       RCV                NVarChar(1) NULL,
       STR_ID             NVarChar(4) NULL,
       PRINT_CNT          SMALLINT NULL,
       A_SHIP             NUMERIC(16, 2) NULL,
       A_CASH             NUMERIC(16, 2) NULL,
       A_CHECK            NUMERIC(16, 2) NULL,
       A_DISC_INT         NUMERIC(16, 2) NULL,
       A_DISC_BAL         NUMERIC(16, 2) NULL,
       A_DISC_ITEM        NUMERIC(16, 2) NULL,
       A_DISC_OTHER       NUMERIC(16, 2) NULL,
       A_TEMP             NUMERIC(16, 2) NULL,
       A_INV              NUMERIC(16, 2) NULL,
       D_ORD              NVarChar(10) NULL,
       D_DLV              NVarChar(10) NULL,
       D_INV              NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(SHM_ID));

CREATE TABLE SID (
       PART_NO            NVarChar(10) NOT NULL,
       PART_SP            NVarChar(10) NOT NULL,
       STR_ID             NVarChar(4) NOT NULL,
       LOCATION           NVarChar(10) NULL,
       DESC_C             NVarChar(40) NULL,
       DESC_E             NVarChar(40) NULL,
       UM                 NVarChar(6) NULL,
       Q_ONHAND           NUMERIC(16, 2) NULL,
       P_AVG              NUMERIC(16, 2) NULL,
       Q_BOY              NUMERIC(16, 2) NULL,
       A_BOY              NUMERIC(16, 2) NULL,
       Q_HOLD             NUMERIC(16, 2) NULL,
       Q_CNT              NUMERIC(16, 2) NULL,
       Q_POST             NUMERIC(16, 2) NULL,
       D_RCV              NVarChar(10) NULL,
       D_SHIP             NVarChar(10) NULL,
       D_CNT              NVarChar(10) NULL,
       D_TSF              NVarChar(10) NULL,
       D_ADJ              NVarChar(10) NULL,
       D_HOLD             NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(PART_NO, PART_SP, STR_ID));

CREATE TABLE SNM (
       SNM_ID             NVarChar(10) NOT NULL,
       SERIAL             INT NULL,
       LENGTH             SMALLINT NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(SNM_ID));

CREATE TABLE SOD (
       SOM_ID             NVarChar(10) NOT NULL,
       ITEM               SMALLINT NOT NULL,
       PART_NO            NVarChar(10) NULL,
       PART_SP            NVarChar(10) NULL,
       DESC_C             NVarChar(40) NULL,
       UM                 NVarChar(4) NULL,
       TYPE               NVarChar(1) NULL,
       TRAVEL             NVarChar(1) NULL,
       STR_ID             NVarChar(4) NULL,
       REMARK             NVarChar(20) NULL,
       CURR               NVarChar(4) NULL,
       Q_ORD              INT NULL,
       Q_SHIP             INT NULL,
       P_ORD              NUMERIC(16, 2) NULL,
       A_ORD              NUMERIC(16, 2) NULL,
       D_ORD              NVarChar(10) NULL,
       D_SHIP             NVarChar(10) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(SOM_ID, ITEM));

CREATE TABLE SOM (
       SOM_ID             NVarChar(10) NOT NULL,
       EMP_ID             NVarChar(10) NULL,
       DLR_VND            NVarChar(10) NULL,
       NAME               NVarChar(40) NULL,
       ADDR               NVarChar(60) NULL,
       TEL                NVarChar(18) NULL,
       REMARK             NVarChar(40) NULL,
       MC                 NVarChar(1) NULL,
       TAX                NVarChar(1) NULL,
       STR_ID             NVarChar(4) NULL,
       PRINT_CNT          SMALLINT NULL,
       A_ORD              NUMERIC(16, 2) NULL,
       D_ORD              NVarChar(10) NULL,
       D_DLV              NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(SOM_ID));

CREATE TABLE STR (
       STR_ID             NVarChar(4) NOT NULL,
       NAME               NVarChar(20) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(STR_ID));

CREATE TABLE SYS (
       SYS_ID             NVarChar(10) NOT NULL,
       VALUE              NUMERIC(16, 2) NULL,
       DATE               NVarChar(10) NULL,
       TYPE               NVarChar(10) NULL,
       DATA               NVarChar(20) NULL,
       REMARK             NVarChar(80) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(SYS_ID));

CREATE TABLE TER (
       TER_ID             NVarChar(4) NOT NULL,
       NAME               NVarChar(40) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
       USR_CHG            NVarChar(10) NULL,
       IP_CHG             NVarChar(20) NULL,
PRIMARY KEY(TER_ID));

CREATE TABLE UPM (
       USR_ID             NVarChar(10) NOT NULL,
       MODULE             NVarChar(4) NOT NULL,
       ITEM               SMALLINT NOT NULL,
       PGM_ID             NVarChar(6) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
PRIMARY KEY(USR_ID, MODULE, ITEM));

CREATE TABLE USR (
       USR_ID             NVarChar(10) NOT NULL,
       PASSWD             NVarChar(10) NULL,
       D_ADD              NVarChar(20) NULL,
       D_CHG              NVarChar(20) NULL,
PRIMARY KEY(USR_ID));

--> 然後按執行建立資料表 (這個 SQL Script 與 MySQL 所用的相同)。

◎ Windows 轉檔程式：

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

C#新增專案

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

◎ 設計畫面：

轉檔程式畫面設計

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

◎ 專案加入參考：

MySQL Connector Net 6.8.3 v4.0

◎撰寫程式：

Form1 上 buttonMy2MS，buttonBACKUP，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;
using System.Diagnostics;

namespace MySQL2MSWinAP
{
    public partial class MAINForm : Form
    {
        public int MaxWidth = 1024;
        public int MaxHeight = 768;

public string ConnectionStringMSSQL = @"server=localhost\SQLEXPRESS;database=KT;uid=PAM;pwd=12345678";
        public string ConnectionStringMySql = @"server=localhost;database=KT;uid=root;pwd=12345678;charset=utf8;PORT=3306;";

public MAINForm()
        {
            InitializeComponent();

textBoxBackDir.Text = @"C:\KT\BACKSQL";

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

DateTime t_beg = System.DateTime.Now;

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.PrimaryKey = new DataColumn[] { dt.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 * from " + TableName;
                        MySqlDataAdapter DA_MyTable = new MySqlDataAdapter(Txt, SC_MySql);
                        DataTable DT_MyTable = ds.Tables.Add("DT_MyTable" + i.ToString());
                        DA_MyTable.Fill(ds, "DT_MyTable" + i.ToString());
                        int iMy = DT_MyTable.Rows.Count;
                        int iMs = Post1(TableName, DT_MyTable);

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);
            }
            catch (MySqlException ex)
            {
                MessageBox.Show("MySQL 錯誤 : " + Txt + " " + ex.Number + " " + ex.Message);
            }
            catch (Exception ex)
            {
                MessageBox.Show("MySQL 錯誤 : " + Txt + " " + ex.Message);
            }
            finally
            { }
            DateTime t_end = System.DateTime.Now;
            TimeSpan diff = t_end - t_beg;
            MessageBox.Show("轉檔完成，耗時 : " + String.Format("{0} 時 {1} 分 {2} 秒", diff.Hours, diff.Minutes, diff.Seconds));

Cursor.Current = Cursors.Default;
        }

private int Post1(string TableName, DataTable dtMySql)
        {
            int iCount = 0;
            SqlConnection SC_MsSql = new SqlConnection(ConnectionStringMSSQL);
            SC_MsSql.Open();
            string Txt = "";

try
            {
                Txt = "Truncate Table " + TableName;
                SqlCommand sqlCommand = new SqlCommand(Txt, SC_MsSql);
                sqlCommand.ExecuteNonQuery();

using (SqlBulkCopy SBC = new SqlBulkCopy(SC_MsSql))
                {
                    SBC.DestinationTableName = TableName;
                    SBC.BatchSize = 10000;
                    decimal dTO = dtMySql.Rows.Count / 10000;
                    int iTO = (int)Math.Truncate(dTO);
                    if (iTO < 120)
                    { iTO = 120; }
                    SBC.BulkCopyTimeout = iTO;
                    SqlCommand SC_PGM = new SqlCommand(Txt, SC_MsSql);
                    SBC.WriteToServer(dtMySql);
                    iCount = dtMySql.Rows.Count;
                }
            }
            catch (Exception ex)
            { MessageBox.Show("MSSQL 錯誤 : " + ex.Message); }
            finally
            { }
            SC_MsSql.Close();
            SC_MsSql.Dispose();
            return iCount;
        }

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

int iMySql = 0;
            int iMsSql = 0;
            if (textBoxMySql.Text.Length > 0)
            { iMySql = int.Parse(textBoxMySql.Text.Replace(",", "")); }
            if (textBoxMsSql.Text.Length > 0)
            { iMsSql = int.Parse(textBoxMsSql.Text.Replace(",", "")); }
            if (iMySql == 0 || iMySql != iMsSql)
            {
                MessageBox.Show("請先轉檔，再備份");
                return;
            }
            if (!System.IO.Directory.Exists(textBoxBackDir.Text))
            {
                MessageBox.Show("備份目錄  : " + textBoxBackDir.Text + " 不存在，請 Check");
                return;
            }

Process proc = null;
            try
            {
                proc = new Process();
                proc.StartInfo.WorkingDirectory = textBoxBackDir.Text;
                proc.StartInfo.FileName = "BACKKT.bat";
                proc.StartInfo.Arguments = string.Format("10");  
                proc.StartInfo.CreateNoWindow = false;
                proc.StartInfo.WindowStyle = ProcessWindowStyle.Hidden; 
                proc.Start();
                proc.WaitForExit();
            }
            catch (Exception ex)
            {
               MessageBox.Show("Exception Occurred : " + ex.Message + " " + ex.StackTrace.ToString());
            }
            Cursor.Current = Cursors.Default;

MessageBox.Show("備份到 : " + textBoxBackDir.Text + " 完成，請將備份檔案 Copy 到隨身碟。");
        }

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

}
}

--> 然後按執行

◎程式解析：

○專案參考命名空間：

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

○資料庫備份目錄：
textBoxBackDir.Text = @"C:\KT\BACKSQL";

○連線字串：
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;";

○buttonMy2MS_Click：

建立 dt --> 連結 MySQL 資料庫 --> 用 Show Tables 讀出 KT 資料庫所有 Tables --> 用 SELECT * from Table 逐一讀取 MySQL 資料表 --> 先用 Truncate Table 清除 MS-SQL 資料表之資料 --> 再用 SqlBulkCopy 將資料存入 MS-SQL --> 返回存入資料筆數。
最後將 dataGridView1 之 DataSource 綁訂為 dt，為 dataGridView1 做細部設定 --> 然後顯示抓到之總筆數。

○buttonBACKUP_Click：

先 Check MySql 筆數必須大於0，且 MySql 筆數等於MsSql 筆數 --> 再 Check 資料庫備份目錄必須存在 --> 在程式中執行 BACKKT.bat --> 會產生 KT + 星期.bak 的備份檔 --> 所以會有 7 個備份檔。。

顯示備份完成，並提示將備份檔案 Copy 到隨身碟。

○buttonEXIT_Click：
結束備份程式

◎執行備份程式：

偵錯 --> 開始偵錯 --> 按 My --> MS

從 MySQL 將 299 萬筆資料 Copy 到 MsSQL 只需 1 分 18 秒

接著按 Backup

將 MsSql 資料庫備份到 KT+星期.bak 會產生 7 個備份檔

◎查看備份結果：

$程式產生的備分檔 C:\KT\BACKSQL\KT6.bak$

程式產生的備分檔 C:\KT\BACKSQL\KT6.bak

備份程式會產生 7 個備份檔，週日為 1 ，週六為 7 。可以避免最近的備份檔有問題而無法復原的窘境。

◎自動化備份：

將 Windows 程式改成主控台程式，就可以上 Windows 排程每天自動備份。但是還是要靠人工將備份檔 Copy 到隨身碟。

2018年7月4日星期三

省錢大作戰從MS-SQL跳槽到MySQL：第四步將 Delphi 的 Paradox 資料庫轉到 MySQL資料庫

我在 1997~2004 年期間使用 Delphi ，併用 MS-SQL 與 Paradox 兩種資料庫。到目前為止，尚有一小部份在使用 Paradox 資料庫，這些客戶中還是有在使用Windows XP 系統。以前曾經將 Paradox 轉到 MS-SQL，現在要轉到 MySQL

◎ 建立 MySQL 資料庫：

啟動 MySQL Workbench --> 連上資料庫主機 --> 在 Query 視窗輸入 CREATE DATABASE KT CHARACTER SET utf8 COLLATE utf8_unicode_ci; --> 然後按執行 --> 在 Query 視窗輸入 USE KT; --> 然後再按執行 --> 在 Query 視窗輸入：

--> 然後按執行

◎ 安裝 BDE：

執行 BDE32.EXE --> Next --> Finish --> 安裝成功後可於控制台看到

BDE Administrator

◎ Windows 轉檔程式：

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

C#新增專案

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

◎ 設計畫面：

轉檔程式畫面設計

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

◎ 專案加入參考：

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

◎ 確定專案平台為 x86：

右擊方案 MySQLFromParadoxWinAP --> 選擇屬性

方案屬性

--> 點擊組態管理員 --> 使用中的方案平台，點擊 Any CPU --> 選擇 <新增...> --> 輸入或選擇新平台：x86 --> 確定 --> 關閉 --> 確定。

組態管理員選擇平台：x86

右擊專案 MySQLFromParadoxWinAP --> 選擇屬性

專案屬性

--> 點擊建置 --> 確定專案平台為 x86。

專案平台為 x86

◎撰寫程式：

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 MySql.Data.MySqlClient;
using System.Data.OleDb;
using System.IO;

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

public string sDIR = @"C:\KT\DATA";
        public string ConnectionStringMySql = @"server=192.168.0.250;database=KT;uid=root;pwd=12345678;charset=utf8;PORT=3306;";

public Form1()
        {
            InitializeComponent();

private void buttonSEARCH_Click(object sender, EventArgs e)
        {
            System.Windows.Forms.Cursor.Current = Cursors.WaitCursor;
            DateTime t_beg = System.DateTime.Now;
            int iParadox = 0;
            int iMySql = 0;

DataTable dt1 = new DataTable();
            dt1.Columns.Add("Table", typeof(String));
            dt1.Columns.Add("Paradox", typeof(int));
            dt1.Columns.Add("MySql", typeof(int));
            dt1.Columns.Add("Sel", typeof(String));
            dt1.PrimaryKey = new DataColumn[] { dt1.Columns[0] };

string[] fileEntries = Directory.GetFiles(sDIR);
            foreach (string fileName in fileEntries)
            {
                int iDB = fileName.ToLower().IndexOf(".db");
                string fileFullName = fileName;
                string fileExt = Path.GetExtension(fileFullName);
                if (iDB >= 0 && fileExt.Length == 3)
                {
                    DataRow dr1 = dt1.NewRow();
                    dr1["Table"] = fileName;
                    dt1.Rows.Add(dr1);
                }
            }

string Txt = "";
            string sStep = "Paradox";
             
            try
            {
                string ConnectionStringParadox = "Provider=Microsoft.Jet.OLEDB.4.0; Data Source=" + sDIR + ";Extended Properties=Paradox 5.x";
                OleDbConnection SC_Ole = new OleDbConnection(ConnectionStringParadox);
                SC_Ole.Open();

for (int i = 0; i < dt1.Rows.Count; i++)
                {
                    if (dt1.Rows[i].ItemArray[0] != null && dt1.Rows[i].ItemArray[0].ToString().Length > 0)
                    {
                        string tableName = dt1.Rows[i].ItemArray[0].ToString();
                        DataRow result1 = dt1.Rows.Find(tableName);
                        OleDbCommand oledbcommand = new OleDbCommand();
                        Txt = "Select COUNT(*) from " + tableName;
                        oledbcommand.CommandText = Txt;
                        oledbcommand.Connection = SC_Ole;
                        int iParadox1 = Convert.ToInt32(oledbcommand.ExecuteScalar());
                        if (result1 != null)
                        {
                            result1["Paradox"] = iParadox1;
                            iParadox += iParadox1;
                        }
                        //MessageBox.Show(sStep + " "  + tableName + " " + iParadox.ToString());
                    }
                }
                //MessageBox.Show("Paradox Completed");

sStep = "MySql";

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

MySqlConnection SC_MySql = new MySqlConnection(ConnectionStringMySql);
                SC_MySql.Open();
                DataSet ds = new DataSet();
                Txt = "Show tables";
                MySqlDataAdapter DA_Table = new MySqlDataAdapter(Txt, SC_MySql);
                DataTable DT_Table = ds.Tables.Add("DT_Table");
                DA_Table.Fill(ds, "DT_Table");

for (int i = 0; i < DT_Table.Rows.Count; i++)
                {
                    if (DT_Table.Rows[i].ItemArray[0] != null && DT_Table.Rows[i].ItemArray[0].ToString().Length > 0)
                    {
                        string table = DT_Table.Rows[i].ItemArray[0].ToString();
                        DataRow result = dtTable.Rows.Find(table);
                        if (result == null)
                        {
                            DataRow dr1 = dtTable.NewRow();
                            dr1["Table"] = table;
                            dtTable.Rows.Add(dr1);
                        }
                    }
                }

for (int i = 0; i < dt1.Rows.Count; i++)
                {
                    if (dt1.Rows[i].ItemArray[0] != null && dt1.Rows[i].ItemArray[0].ToString().Length > 0)
                    {
                        string tableName = dt1.Rows[i].ItemArray[0].ToString();
                        string table = tableName.Replace(sDIR + "\\", "").Replace(".DB", "");
                        DataRow result = dtTable.Rows.Find(table);
                        if (result != null)
                        {
                            DataRow result1 = dt1.Rows.Find(tableName);
                            Txt = "SELECT COUNT(*) FROM " + table;
                            MySqlCommand cmdMySql = new MySqlCommand();
                            cmdMySql.CommandText = Txt;
                            cmdMySql.Connection = SC_MySql;
                            int iMySql1 = Convert.ToInt32(cmdMySql.ExecuteScalar());
                            if (result1 != null)
                            {
                                int iParadox1 = 0;
                                if (result1["Paradox"] != null && result1["Paradox"].ToString().Length > 0)
                                { iParadox1 = int.Parse(result1["Paradox"].ToString()); }
                                result1["MySql"] = iMySql1;
                                if (iParadox1 > 0 && iParadox1 != iMySql1)
                                { result1["Sel"] = "V"; }
                                iMySql += iMySql1;
                            }
                            //MessageBox.Show(sStep + " " + table + " " + iMySql.ToString());
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                string ERROR = sStep + " " + ex.Message;
                MessageBox.Show(ERROR);
            }
            finally
            { }

dataGridView1.DataSource = dt1;
            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);
            }
            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);
            textBoxParadox.Text = String.Format("{0,12:n0}", iParadox);
            textBoxMySql.Text = String.Format("{0,12:n0}", iMySql);

System.Windows.Forms.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;
                MessageBox.Show("轉檔完成，共 " + iPosted.ToString() + " 筆");
            }
        }

private int Post1(string TableName)
        {
            int iPost = 0;

//MessageBox.Show(TableName);

string table = TableName.Replace(sDIR + "\\", "").Replace(".DB", "");
            if (table.Length == 6)
            {
                string table1 = table.Substring(0, 4);
                string table2 = table.Substring(4, 2);
                if (string.Compare(table2, "D2", false) == 0 || string.Compare(table2, "DD", false) == 0)
                { table = table1 + "BK"; }
            }
            string ConnectionStringParadox = "Provider=Microsoft.Jet.OLEDB.4.0; Data Source=" + sDIR + ";Extended Properties=Paradox 5.x";
            OleDbConnection SC_Ole = new OleDbConnection(ConnectionStringParadox);
            OleDbCommand oledbcommand = new OleDbCommand();
            string Txt = "Select * from " + TableName;
            oledbcommand.CommandText = Txt;
            oledbcommand.Connection = SC_Ole;
            DataSet dsOle = new DataSet();
            OleDbDataAdapter da = new OleDbDataAdapter();
            da.SelectCommand = oledbcommand;
            da.Fill(dsOle);

MySqlConnection SC_MySql = new MySqlConnection(ConnectionStringMySql);
            SC_MySql.Open();

DataSet ds = new DataSet();

Txt = "Show Columns from " + table;
            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");
                //MessageBox.Show(FIELD + " " + NULL + " " + iNULL.ToString());
                if (iNULL >= 0)
                { iKeyCount++; }
            }
            //MessageBox.Show(table + " " + iKeyCount.ToString());
            Txt = "Select * from " + table;
            MySqlDataAdapter DA_MySqlTable = new MySqlDataAdapter(Txt, SC_MySql);
            DataTable DT_MySqlTable = ds.Tables.Add("DT_MySqlTable");
            DA_MySqlTable.Fill(ds, "DT_MySqlTable");

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

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

for (int i = 0; i < dsOle.Tables[0].Rows.Count; i++)
            {
                SORT_ID = "";
                for (int j = 0; j < iKeyCount; j++)
                {
                    if (dsOle.Tables[0].Rows[i].ItemArray[j] != System.DBNull.Value)
                    { SORT_ID += dsOle.Tables[0].Rows[i].ItemArray[j].ToString() + "|"; }
                }
                DataRow result2 = dtMySql.Rows.Find(SORT_ID);
                if (result2 == null)
                {
                    try
                    {
                        Txt = "Insert into " + table + " (";
                        for (int j = 0; j < dsOle.Tables[0].Columns.Count; j++)
                        {
                            string FIELD = dsOle.Tables[0].Columns[j].ColumnName.ToString();
                            if (string.Compare(FIELD, "DESC", false) == 0)
                            { FIELD += "_C"; }
                            if (string.Compare(FIELD, "PGM", false) == 0 || string.Compare(FIELD, "USR", false) == 0)
                            { FIELD += "_ID"; }
                            if (string.Compare(FIELD, "PRINT", false) == 0)
                            { FIELD = "PRN"; }
                            Txt += FIELD;
                            if (j < dsOle.Tables[0].Columns.Count - 1)
                            { Txt += ","; }
                            else
                            { Txt += ")"; }
                        }
                        Txt += "values (";
                        for (int j = 0; j < dsOle.Tables[0].Columns.Count; j++)
                        {
                            string FIELD = dsOle.Tables[0].Columns[j].ColumnName.ToString();
                            if (string.Compare(FIELD, "DESC", false) == 0)
                            { FIELD += "_C"; }
                            if (string.Compare(FIELD, "PGM", false) == 0 || string.Compare(FIELD, "USR", false) == 0)
                            { FIELD += "_ID"; }
                            if (string.Compare(FIELD, "PRINT", false) == 0)
                            { FIELD = "PRN"; }
                            Txt += "@" + FIELD;
                            if (j < dsOle.Tables[0].Columns.Count - 1)
                            { Txt += ","; }
                            else
                            { Txt += ")"; }
                        }
                        MySqlCommand comm = new MySqlCommand(Txt, SC_MySql);

for (int j = 0; j < DT_MyFields.Rows.Count - 2; j++)
                        {
                            string FIELD = DT_MyFields.Rows[j].ItemArray[0].ToString();
                            if (string.Compare(FIELD, "DESC", false) == 0)
                            { FIELD += "_C"; }
                            if (string.Compare(FIELD, "PGM", false) == 0 || string.Compare(FIELD, "USR", false) == 0)
                            { FIELD += "_ID"; }
                            if (string.Compare(FIELD, "PRINT", false) == 0)
                            { FIELD = "PRN"; }
                            string TYPE = DT_MyFields.Rows[j].ItemArray[1].ToString();
                            int iChar = TYPE.IndexOf("char");
                            int iInt = TYPE.IndexOf("int");
                            int iDecimal = TYPE.IndexOf("decimal");
                            string fieldName = "@" + FIELD;
                            if (iChar >= 0)
                            {
                                MySqlParameter sqlparameter = new MySqlParameter(fieldName, MySqlDbType.VarChar);
                                sqlparameter.Value = dsOle.Tables[0].Rows[i].ItemArray[j];
                                comm.Parameters.Add(sqlparameter);
                            }
                            if (iInt >= 0)
                            {
                                MySqlParameter sqlparameter = new MySqlParameter(fieldName, MySqlDbType.Int32);
                                sqlparameter.Value = dsOle.Tables[0].Rows[i].ItemArray[j];
                                comm.Parameters.Add(sqlparameter);
                            }
                            if (iDecimal >= 0)
                            {
                                MySqlParameter sqlparameter = new MySqlParameter(fieldName, MySqlDbType.Decimal);
                                sqlparameter.Value = dsOle.Tables[0].Rows[i].ItemArray[j];
                                comm.Parameters.Add(sqlparameter);
                            }
                        }
                        for (int j = 0; j < dsOle.Tables[0].Columns.Count; j++)
                        {
                            string FIELD = dsOle.Tables[0].Columns[j].ColumnName.ToString();
                            if (string.Compare(FIELD, "DESC", false) == 0)
                            { FIELD += "_C"; }
                            if (string.Compare(FIELD, "PGM", false) == 0 || string.Compare(FIELD, "USR", false) == 0)
                            { FIELD += "_ID"; }
                            if (string.Compare(FIELD, "PRINT", false) == 0)
                            { FIELD = "PRN"; }
                            string TYPE = DT_MyFields.Rows[j].ItemArray[1].ToString();
                            int iChar = TYPE.IndexOf("char");
                            int iInt = TYPE.IndexOf("int");
                            int iDecimal = TYPE.IndexOf("decimal");
                            comm.Parameters["@" + FIELD].Value = dsOle.Tables[0].Rows[i].ItemArray[j];
                            if (j < iKeyCount && (dsOle.Tables[0].Rows[i].ItemArray[j] == System.DBNull.Value || dsOle.Tables[0].Rows[i].ItemArray[j].ToString().Length <= 0))
                            {
                                if (iChar >= 0)
                                { comm.Parameters["@" + FIELD].Value = ""; }
                                else
                                { comm.Parameters["@" + FIELD].Value = 0; }
                            }
                        }

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

DT_MyFields.Clear();
            DT_MyFields.Dispose();
            dsOle.Tables[0].Clear();
            dsOle.Tables[0].Dispose();
            ds.Dispose();

SC_Ole.Close();
            SC_Ole.Dispose();

SC_MySql.Close();
            SC_MySql.Dispose();

return iPost;
        }

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

--> 然後按執行

◎程式解析：

○專案參考命名空間：

using MySql.Data.MySqlClient;
using System.Data.OleDb;
using System.IO;

○Paradox 資料庫所在目錄：
public string sDIR = @"C:\KT\DATA";

○連線字串：

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

○buttonSEARCH_Click：

建立 dtTable --> 用 Directory.GetFiles 抓取資料庫所在目錄的所有檔案 --> 過濾抓到的檔案尾端有 .db 寫入 dtTable
Paradox 連線字串： string ConnectionStringParadox = "Provider=Microsoft.Jet.OLEDB.4.0; Data Source=" + sDIR + ";Extended Properties=Paradox 5.x"; --> 用 OleDb 連結 Paradox 資料庫 OleDbConnection SC_Ole = new OleDbConnection(ConnectionStringParadox); --> 用 SELECT COUNT(*) 指令讀取每個 TParadox 資料表的筆數放進 dtTable 之 Paradox 欄位。
連結 MySQL 資料庫 --> 用 Show Tables 讀出 KT 資料庫所有 Tables --> 用 SELECT COUNT(*) 指令讀取每個 Table 的筆數放進 dtTable 之 MySQL 欄位。
若 Paradox 之筆數大於 0 且 Paradox 之筆數不等於 MySQL 之筆數，Sel 欄位自動標示為 V。
最後將 dataGridView1 之 DataSource 綁訂為 dtTable，為 dataGridView1 做細部設定 --> 然後顯示抓到之總筆數與耗用時間。

○buttonPOST_Click：

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

Post1 --> 先抓取 Paradox 資料表 --> 從 Paradox 資料表名稱切出 MySQL 資料表名稱 --> 用 Show Columns from Table 讀出 MySQL 資料庫中該資料表所有的 Column --> 再抓取 MySQL 資料表 --> 剔除 MySQL 現有的資料，只將 Paradox 多的資料存入 MySQL 資料表中。最後返回轉檔的筆數。
Paradox 資料表的結構與 MySQL 略有不同。除了有些欄位名稱需要調整外，Paradox 資料表名稱字尾有 DDD 或 DD2 者會全部轉到字尾為 DBK 之 MySQL 資料表。此外有少許資料因兩種系統結構不同，不用轉檔。

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

○buttonEXIT_Click：
結束轉檔程式

◎執行轉檔程式：

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

讀取 Paradox 資料庫 299 萬筆資料耗時 8 分 46 秒。

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

Paradox --> MySQL 轉檔完成，299 萬筆資料耗時59分38秒。

◎測試轉檔結果 ：

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

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

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

訂閱：文章 (Atom)

標籤

2018年7月6日 星期五

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

◎ 從備份檔還原 MS-SQL ：

◎ 設計畫面：

◎ 專案加入參考：

◎撰寫程式：

◎程式解析 ：

◎執行還原程式 ：

省錢大作戰從MS-SQL跳槽到MySQL：第五步透過 MsSQL 備份 MySQL 資料庫

◎ 安裝 MS-SQL Express：

◎ 建立資料庫：

◎ Windows 轉檔程式：

◎ 設計畫面：

◎ 專案加入參考：

◎撰寫程式：

◎程式解析 ：

◎執行備份程式 ：

2018年7月4日 星期三

省錢大作戰從MS-SQL跳槽到MySQL：第四步將 Delphi 的 Paradox 資料庫轉到 MySQL資料庫

◎ 建立 MySQL 資料庫：

◎ 安裝 BDE：

◎ Windows 轉檔程式：

◎ 設計畫面：

◎ 確定專案為 .Net Framework 4.0：

◎ 專案加入參考：

◎ 確定專案平台為 x86：

◎撰寫程式：

◎程式解析 ：

◎執行轉檔程式 ：

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

2018年7月6日星期五

◎程式解析：

◎執行還原程式：

◎程式解析：

◎執行備份程式：

2018年7月4日星期三

◎程式解析：

◎執行轉檔程式：