using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

//Using Mysql Namespace
using MySql.Data.MySqlClient;
using MySql.Data.Types;
using System.Data;

namespace WindowsFormsApplication2
{
    public class MySqlConn
    {
        #region ===== MySQL Connection =====
        MySqlConnection _conn = new MySqlConnection();
        string _connString = "Server=127.0.0.1;Database=DB명;Uid=계정명;pwd=비밀번호";

        /// 

        /// MySQL 연결
        /// 
        public void MySQLConnection()
        {
            try
            {
                _conn.ConnectionString = _connString;
                _conn.Open();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
        }

        /// 

        /// MySQL 연결 해제
        /// 
        public void MySQLDisConnect()
        {
            if (_conn != null)
                _conn.Close();
        }
        #endregion

        public DataSet GetMemberList()
        {
            MySQLConnection();
            string strQuery = "SELECT * FROM Member";
            //_conn.ConnectionString = _connString;

            MySqlCommand cmd = new MySqlCommand();
            cmd.Connection = _conn;

            DataSet ds = new DataSet();
            MySqlDataAdapter da = new MySqlDataAdapter(strQuery, _conn);
            da.Fill(ds, "Member");

            MySQLDisConnect();

            return ds;
        }

        public int SetMemberList(string[] arrParam)
        {
            MySQLConnection();

            string strQuery = "Insert Into Member(EMAIL, KOR_NM, PASSWORD) VALUES(@Email, @KOR_NM, @PWD)";
            //_conn.ConnectionString = _connString;
            
            MySqlCommand InsertCommand = new MySqlCommand();
            
            InsertCommand.Connection = _conn;
            InsertCommand.CommandText = strQuery;

            InsertCommand.Parameters.Add("@Email", MySqlDbType.VarChar, 200);
            InsertCommand.Parameters.Add("@KOR_NM", MySqlDbType.VarChar, 100);
            InsertCommand.Parameters.Add("@PWD", MySqlDbType.VarChar, 100);

            InsertCommand.Parameters[0].Value = arrParam[0];
            InsertCommand.Parameters[1].Value = arrParam[1];
            InsertCommand.Parameters[2].Value = arrParam[2];

            int intResult = InsertCommand.ExecuteNonQuery();

            MySQLDisConnect();

            return intResult;
        }

        public DataSet GetIDCheck(string userID)
        {
            DataSet ds = null;
            string strQuery = "SELECT EMail from Member Where Email='" + userID + "'";
            MySQLConnection();

            MySqlCommand cmd = new MySqlCommand();
            cmd.Connection = _conn;

            ds = new DataSet();
            MySqlDataAdapter da = new MySqlDataAdapter(strQuery, _conn);
            da.Fill(ds, "Memeber");


            MySQLDisConnect();

            return ds;
        }
    }
}

using System;
using System.Windows;
using System.IO.Ports;
using System.Windows.Threading;
using System.Windows.Interop;
using System.Runtime.InteropServices;

namespace Wpf_Serial
{
    /// 

    /// MainWindow.xaml에 대한 상호 작용 논리
    /// 
    public partial class MainWindow : Window
    {
        decimal LineNumber = 1;

        SerialPort SP = new SerialPort();

        public MainWindow()
        {
            InitializeComponent();
        }

        IntPtr WndProc(IntPtr hWnd, int nMsg, IntPtr wParam, IntPtr lParam, ref bool handled)
        {
            UInt32 WM_DEVICECHANGE = 0x0219;
            UInt32 DBT_DEVTUP_VOLUME = 0x02;
            UInt32 DBT_DEVICEARRIVAL = 0x8000;
            UInt32 DBT_DEVICEREMOVECOMPLETE = 0x8004;

            //디바이스 연결시
            if ((nMsg == WM_DEVICECHANGE) && (wParam.ToInt32() == DBT_DEVICEARRIVAL))
            {
                int devType = Marshal.ReadInt32(lParam, 4);

                if (devType == DBT_DEVTUP_VOLUME)
                {
                    GetSerialPort();
                }
            }

            //디바이스 연결 해제시...
            if((nMsg == WM_DEVICECHANGE) && (wParam.ToInt32() == DBT_DEVICEREMOVECOMPLETE))
            {
                int devType = Marshal.ReadInt32(lParam,4);
                if(devType == DBT_DEVTUP_VOLUME)
                {
                    GetSerialPort();
                }
            }

            return IntPtr.Zero;
        }

        private void Window_Loaded(object sender, RoutedEventArgs e)
        {
            WindowInteropHelper helper = new WindowInteropHelper(this);
            HwndSource source = HwndSource.FromHwnd(helper.Handle);
            source.AddHook(new HwndSourceHook(this.WndProc));

            SP.DataReceived += new SerialDataReceivedEventHandler(SP_DataReceived);
        }

        private void SP_DataReceived(object sender, SerialDataReceivedEventArgs e)
        {
            Dispatcher.Invoke(DispatcherPriority.Normal, new Action(delegate
            {
                string str = SP.ReadLine();
                textBox1.AppendText("[" + LineNumber++.ToString() + "] : " + str);
                textBox1.ScrollToEnd();
            }));
        }

        private void btnPortSearch_Click(object sender, RoutedEventArgs e)
        {
            GetSerialPort();
        }

        private void GetSerialPort()
        {
            lst_ComPort.Items.Clear();
            foreach (string comport in SerialPort.GetPortNames())
            {
                lst_ComPort.Items.Add(comport);
            }

            if (lst_ComPort.Items.Count <= 0)
            {
                lst_ComPort.Items.Add("찾을 수 없음");
            }
        }

        private void btnPortOpen_Click(object sender, RoutedEventArgs e)
        {
            if (SP.IsOpen)
            {

            }
            else
            {
                SP.Open();
            }
        }

        private void lst_ComPort_SelectionChanged(object sender, System.Windows.Controls.SelectionChangedEventArgs e)
        {
            SP.PortName = lst_ComPort.SelectedItem.ToString();
        }

        private void btnPortClose_Click(object sender, RoutedEventArgs e)
        {
            if (SP.IsOpen)
            {
                SP.Close();
            }
        }
    }
}