工事管理システム製品化対応

using System;

using System.Collections.Generic;

using System.Collections;

using System.Data;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using MySql.Data.MySqlClient;

using log4net;

using log4net.Appender;

using log4net.Repository.Hierarchy;

using ProcessManagement.MySQLDB.Core;

namespace ProcessManagement.MySQLDB.MySql

{

    /// <summary>

    /// MySql使用共通ラッパークラス

    /// </summary>

    public class MySqlProcess : ABaseDBProcessForMySQL

    {

        #region コンストラクタ

        /// <summary>

        /// コンストラクタ。

        /// </summary>

        /// <param name="connectionString">接続文字列</param>

        public MySqlProcess(String connectionString)

            : base(connectionString)

        {

        }

        #endregion

        #region メソッド

        /// <summary>

        /// Connectionを取得。

        /// </summary>

        /// <param name="connectionString"></param>

        /// <returns>Connection</returns>

        public override IDbConnection getConnection(String connectionString)

        {

            return new MySqlConnection(connectionString);

        }

        #endregion 

    }

}

using System;

using System.Collections.Generic;

using System.Data;

using System.Linq;

using System.Text;

namespace ProcessManagement.MySQLDB.Core

{

    /// <summary>

    /// データベース共通インターフェースクラス

    /// </summary>

    public interface IBaseDBForMySQL

    {

        /// <summary>

        /// コネクト処理。

        /// </summary>

        void connect();

        /// <summary>

        /// クローズ処理。

        /// </summary>

        bool close();

        /// <summary>

        /// トランザクション開始。

        /// </summary>

        bool beginTran();

        /// <summary>

        /// コミット。

        /// </summary>

        bool commit();

        /// <summary>

        /// ロールバック。

        /// </summary>

        bool rollback();

    }

}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using log4net;

using ProcessManagement.Common;

namespace ProcessManagement.MySQLDB.Core

{

    /// <summary>

    /// データベース共通接続クラス

    /// </summary>

    public class DBCommonForMySQL

    {

        #region 定義部

        /// <summary>

        /// データベース接続共通クラスインスタンスハンドル

        /// </summary>

        private static DBCommonForMySQL m_instance = new DBCommonForMySQL();

        /// <summary>

        /// log4netログを使用する

        /// </summary>

        private static readonly ILog logger = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);

        #endregion

        #region 変数

        /// <summary>

        /// DB接続情報

        /// </summary>

        private string m_dbconnectString = string.Empty;

        #endregion

        #region コンストラクタ

        /// <summary>

        /// 何もしない

        /// </summary>

        #endregion

        #region プロパティ

        /// <summary>

        ///インスタンス

        /// </summary>

        public static DBCommonForMySQL Instance

        {

            get { return m_instance; }

        }

        /// <summary>

        /// 接続文字列取得

        /// </summary>

        public string DBConnectString

        {

            get { return m_dbconnectString; }

        }

        #endregion

        #region メソッド

        /// <summary>

        /// 初期化メソッド

        /// </summary>

        public void Initialize()

        {

            // DB接続情報作成

            m_dbconnectString = string.Format("Server={0};", CommonMySQLDef.DBServer);

            m_dbconnectString += string.Format("Uid={0};", CommonMySQLDef.DBUser);

            m_dbconnectString += string.Format("Pwd={0};", CommonMySQLDef.Password);

            m_dbconnectString += string.Format("Database={0};", CommonMySQLDef.Database);

        }

        #endregion

    }

}

using System;

using System.Collections.Generic;

using System.Data;

using System.Linq;

using System.Text;

using System.Collections;

using MySql.Data.MySqlClient; 

using log4net;

using log4net.Appender;

using log4net.Repository.Hierarchy;

using ProcessManagement.Common;

namespace ProcessManagement.MySQLDB.Core

{

    /// <summary>

    /// データベース共通抽象クラス

    /// </summary>

    public abstract class ABaseDBProcessForMySQL : IBaseDBForMySQL

    {

        #region ログ定義

        /// <summary>

        /// log4netログを使用する

        /// </summary>

        private static readonly ILog logger = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);

        #endregion

        #region メンバ変数

        /// <summary>

        /// DB接続

        /// </summary>

        protected IDbConnection m_connection = null;

        /// <summary>

        /// 接続有無(true:接続中)

        /// </summary>

        protected bool m_isConnect = false;

        /// <summary>

        /// トランザクション

        /// </summary>

        protected IDbTransaction m_transaction = null;

        /// <summary>

        /// 接続文字列

        /// </summary>

        protected String m_connectionString = null;

        #endregion

        #region コンストラクタ

        /// <summary>

        /// コンストラクタ

        /// </summary>

        /// <param name="connectionString">接続文字列</param>

        public ABaseDBProcessForMySQL(String connectionString)

        {

            //接続文字列セット

            this.m_connectionString = connectionString;

        }

        #endregion

        #region プロパティ

        /// <summary>

        /// DCコネクション

        /// </summary>

        public IDbConnection DBConnection

        {

            get { return m_connection; }

            set { m_connection = value; }

        }

        #endregion

        #region プライベートメソッド

        /// <summary>

        /// 接続の確立判断。

        /// </summary>

        /// <returns>true：接続確立 false：接続無</returns>

        private bool isConnect()

        {

            //接続されていない場合

            if (this.m_connection == null || !this.m_isConnect) return false;

            return true;

        }

        /// <summary>

        /// パラメータの値を取得する

        /// </summary>

        /// <param name="value">値</param>

        /// <returns>パラメータの値</returns>

        protected object getParamValue(object value)

        {

            if (value != null) return value;

            return DBNull.Value;

        }

        #endregion

        #region コネクション接続

        /// <summary>

        /// Connectionを取得。

        /// </summary>

        /// <param name="connectionString"></param>

        /// <returns>Connectionのオブジェクト</returns>

        public virtual IDbConnection getConnection(String connectionString)

        {

            return new MySqlConnection(connectionString);

        }

        #endregion

        #region connect

        /// <summary>

        /// コネクト処理。

        /// </summary>

        public void connect()

        {

            try

            {

                //接続有無＝無に設定

                this.m_isConnect = false;

                //接続済みの場合

                if (this.m_connection != null)

                {

                    //接続をClose

                    this.m_connection.Close();

                    //初期化

                    this.m_connection = null;

                }

                //Connectionを取得

                this.m_connection = getConnection(m_connectionString);

                //Open

                this.m_connection.Open();

                //接続有無＝ありに設定

                this.m_isConnect = true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, m_connectionString);

            }

        }

        #endregion

        #region close

        /// <summary>

        /// クローズ処理。

        /// </summary>

        /// <returns>true：切断成功 false：接続無</returns>

        public bool close()

        {

            try

            {

                //接続が確立されていない場合は処理なし

                if (!isConnect()) return false;

                //トランザクションを破棄する

                if (this.m_transaction != null)

                {

                    this.m_transaction.Dispose();

                    this.m_transaction = null;

                }

                //接続をClose＆破棄する

                if (this.m_connection != null)

                {

                    this.m_connection.Close();

                    this.m_connection.Dispose();

                    this.m_connection = null;

                }

                //接続有無なしに設定

                this.m_isConnect = false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, m_connectionString);

                return false;

            }

        }

        #endregion

        #region begintran

        /// <summary>

        /// トランザクション開始。

        /// </summary>

        /// <returns>true：開始成功 false：接続無</returns>

        public bool beginTran()

        {

            try

            {

                //接続が確立されていない場合、処理なし

                if (!isConnect()) return false;

                //トランザクション開始

                this.m_transaction = m_connection.BeginTransaction();

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, m_connectionString);

                return false;

            }

        }

        #endregion

        #region commit

        /// <summary>

        /// コミット。

        /// </summary>

        /// <returns>true：Commit成功 false：トランザクション無・接続無</returns>

        public bool commit()

        {

            try

            {

                //接続が確立されていない場合は処理なし

                if (!isConnect()) return false;

                //トランザクションが開始されていない場合、処理なし

                if (this.m_transaction == null) return false;

                //コミット

                m_transaction.Commit();

                return true;

            }

            catch (Exception ex)

            {

                //ログ出力

                logger.ErrorFormat("{0}：{1}", CommonMotions.GetMethodName(2), ex.Message);

                return false;

            }

            finally

            {

                //トランザクションを破棄する

                if (this.m_transaction != null)

                {

                    this.m_transaction.Dispose();

                    this.m_transaction = null;

                }

            }

        }

        #endregion

        #region rollback

        /// <summary>

        /// ロールバック。

        /// </summary>

        /// <returns>true：Rollback成功 false：トランザクション無・接続無</returns>

        public bool rollback()

        {

            try

            {

                //接続が確立されていない場合は処理なし

                if (!isConnect()) return false;

                //トランザクションが開始されていない場合は処理なし

                if (this.m_transaction == null) return false;

                //ロールバック

                this.m_transaction.Rollback();

                return true;

            }

            catch (Exception ex)

            {

                //ログ出力

                logger.ErrorFormat("{0}：{1}", CommonMotions.GetMethodName(2), ex.Message);

                return false;

            }

            finally

            {

                //トランザクションを破棄する

                if (this.m_transaction != null)

                {

                    this.m_transaction.Dispose();

                    this.m_transaction = null;

                }

            }

        }

        #endregion

        #region ExecuteReader

        /// <summary>

        /// MySQLリーダー

        /// </summary>

        /// <param name="strSql">検索SQL</param>

        /// <param name="arData">取得データ</param>

        /// <returns>成功時:true 失敗時:false</returns>

        public bool ExecuteReader(string strSql, ref ArrayList arData, bool bconnect = true)

        {

            //MySQL インターフェース

            MySqlCommand mycmd = new MySqlCommand();

            MySqlDataReader myreader = null;

            try

            {

                //接続

                if (bconnect) this.connect();

                //MySqlCommand・MySqlDataReader作成

                mycmd.Connection = (MySqlConnection)m_connection;

                //SQLセット

                mycmd.CommandText = strSql;

                myreader = mycmd.ExecuteReader();

                int iFeildcnt = myreader.FieldCount;

                //読込

                while (myreader.Read())

                {

                    object[] objwrk = new object[iFeildcnt];

                    myreader.GetValues(objwrk);

                    //null抑制

                    int i = 0;

                    foreach (object www in objwrk)

                    {

                        objwrk[i++] = www.ToString().Equals("null") ? "" : www;

                    }

                    arData.Add(objwrk);

                }

                return true;

            }

            catch (MySqlException myex)

            {

                logger.ErrorFormat("ＭｙＳＱＬエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), myex.Message, strSql);

                return false;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strSql);

                return false;

            }

            finally

            {

                if (myreader != null)

                {

                    myreader.Close();

                    myreader.Dispose();

                    myreader = null;

                }

                mycmd.Dispose();

                mycmd = null;

                //切断

                if (bconnect) this.close();

            }

        }

        #endregion

        #region ExecuteNonQuery

        /// <summary>

        /// MySQL ExecuteNonQuery

        /// </summary>

        /// <param name="strSql">実行SQL</param>

        /// <returns>成功時:true 失敗時:false</returns>

        public bool ExecuteNonQuery(string strSql, bool bconnect = true)

        {

            //MySQL インターフェース

            MySqlCommand mycmd = new MySqlCommand();

            try

            {

                //接続

                if (bconnect) this.connect();

                //ネクションセット

                mycmd.Connection = (MySqlConnection)m_connection;

                //トランザクション

                if (bconnect)

                {

                    if (!this.beginTran()) return false;

                }

                //SQLセット

                mycmd.CommandText = strSql;

                //実行

                if (mycmd.ExecuteNonQuery() == 0)

                {

                    //エラー時rollbackして処理終了

                    if (bconnect) this.rollback();

                    return false;

                }

                //成功時Commit

                if (bconnect)

                {

                    if (!this.commit()) return false;

                }

                return true;

            }

            catch (MySqlException myex)

            {

                logger.ErrorFormat("ＭｙＳＱＬエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), myex.Message, strSql);

                return false;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strSql);

                return false;

            }

            finally

            {

                //切断

                if (bconnect) this.close();

                mycmd.Dispose();

                mycmd = null;

            }

        }

        #endregion

        #region SetLockWaitime

        /// <summary>

        /// MySQL innodb_lock_wait_timeoutを設定

        /// </summary>

        /// <param name="seconds">秒</param>

        /// <returns></returns>

        public  bool SetLockWaitime(int seconds)

        {

            MySqlCommand mycmd = new MySqlCommand();

            string strSql = "";

            try

            {

                //ネクションセット

                mycmd.Connection = (MySqlConnection)m_connection;

                //SQLセット

                strSql = "set innodb_lock_wait_timeout=1";

                mycmd.CommandText = strSql;

                //実行

                mycmd.ExecuteNonQuery();

                return true;

            }

            catch (MySqlException myex)

            {

                logger.ErrorFormat("ＭｙＳＱＬエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), myex.Message, strSql);

                return false;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strSql);

                return false;

            }

            finally

            {

                mycmd.Dispose();

                mycmd = null;

            }

        }

    }

    #endregion

}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Data;

using System.Collections;

using log4net;

using MySql.Data.MySqlClient;           // Data Provider for MySql

using ProcessManagement.MySQLDB.MySql;

using ProcessManagement.MySQLDB.Core;

using ProcessManagement.DataModel;

using ProcessManagement.Common;

namespace ProcessManagement.MySQLDB.IOAccess

{

    /// <summary>

    /// 工事増減情報ＤＢアクセス

    /// </summary>

    public class IOConstructionLink : MySqlProcess

    {

        #region 定義部

        /// <summary>

        /// log4netログを使用する

        /// </summary>

        private static readonly ILog logger = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);

        #endregion

        #region 定数

        /// <summary>

        /// 工事増減情報フィールド並び

        /// </summary>

        public enum TableColumn

        {

            ConstructionCode = 0,

            FluctuationCode,

            LinkType,

            EntryDate,

            UpdateDate,

        }

        #endregion

        #region プロパティ

        #endregion

        #region コンストラクタ

        /// <summary>

        /// コンストラクタ

        /// </summary>

        /// <param name="ConnectionString"></param>

        public IOConstructionLink()

            : base(DBCommonForMySQL.Instance.DBConnectString)

        {

        }

        #endregion

        #region SELECT　SQL作成

        /// <summary>

        /// SQL作成

        /// </summary>

        private string CreateSelectSQL()

        {

            // SQL作成（DateTime型が変換できないのでCharに変換しておく）

            string strcmd = "SELECT";

            strcmd += "  ConstructionCode, FluctuationCode, LinkType";

            strcmd += ", DATE_FORMAT(EntryDate, '%Y/%m/%d %H:%i:%s')";

            strcmd += ", DATE_FORMAT(UpdateDate, '%Y/%m/%d %H:%i:%s')";

            strcmd += " FROM ConstructionLink";

            return strcmd;

        }

        #endregion

        #region 読込み処理（1件読込み）

        /// <summary>

        /// 工事増減情報検索（1件読込み）

        /// </summary>

        /// <param name="AddSQLString">検索条件SQL文字列</param>

        /// <param name="data">工事増減情報データ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool SelectAction(string AddSQLString, ref ConstructionLink data, bool bConnect = true)

        {

            // インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            try

            {

                strcmd = CreateSelectSQL() + AddSQLString;

                // SQL実行

                if (!ExecuteReader(strcmd, ref arData, bConnect)) return false;

                if (arData.Count == 0) return false;

                // データセット

                foreach (object[] objwrk in arData)

                {

                    ConstructionLink work = new ConstructionLink();

                    Reader2Struct(objwrk, ref data);

                    break;

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 読込み処理（複数件読込み）

        /// <summary>

        /// 工事増減情報検索（複数件読込み）

        /// </summary>

        /// <param name="AddSQLString">検索条件SQL文字列</param>

        /// <param name="data">工事増減情報データ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool SelectAction(string AddSQLString, ref List<ConstructionLink> data, bool bConnect = true)

        {

            // インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            try

            {

                strcmd = CreateSelectSQL() + AddSQLString;

                // SQL実行

                if (!ExecuteReader(strcmd, ref arData, bConnect)) return false;

                // データセット

                foreach (object[] objwrk in arData)

                {

                    ConstructionLink work = new ConstructionLink();

                    Reader2Struct(objwrk, ref work);

                    data.Add(work);

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 追加処理（1件追加）

        /// <summary>

        /// 工事増減情報追加（1件追加）

        /// </summary>

        /// <param name="data">工事増減情報データ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool InsertAction(ConstructionLink data, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                strcmd = "INSERT INTO ConstructionLink";

                strcmd += " (ConstructionCode,";

                strcmd += " FluctuationCode,";

                strcmd += " LinkType,";

                strcmd += " EntryDate,";

                strcmd += " UpdateDate)";

                strcmd += " VALUES (";

                strcmd += string.Format("  {0}", data.ConstructionCode);

                strcmd += string.Format(", {0}", data.FluctuationCode);

                strcmd += string.Format(", {0}", data.LinkType);

                strcmd += ", STR_TO_DATE(DATE_FORMAT(NOW(),'%Y/%m/%d %H:%i:%s'),'%Y/%m/%d %H:%i:%s')";

                strcmd += ", STR_TO_DATE(DATE_FORMAT(NOW(),'%Y/%m/%d %H:%i:%s'),'%Y/%m/%d %H:%i:%s')";

                strcmd = strcmd + ")";

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 追加処理（複数件追加）

        /// <summary>

        /// 工事増減情報追加（複数件追加）

        /// </summary>

        /// <param name="data">工事増減情報データ</param>

        /// <returns>true：成功 false：失敗</returns>

        /// <summary>

        /// 工事増減情報追加

        /// </summary>

        /// <param name="data">工事増減情報データ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool InsertAction(List<ConstructionLink> data, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                foreach (ConstructionLink work in data)

                {

                    if (!InsertAction(work, bConnect)) return false;

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 更新処理

        /// <summary>

        /// 工事増減情報更新

        /// </summary>

        /// <param name="AddSQLString">更新条件SQL文字列</param>

        /// <param name="data">工事増減情報データ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool UpdateAction(string AddSQLString, ConstructionLink data, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                strcmd = "UPDATE ConstructionLink";

                strcmd += " SET";

                strcmd += string.Format("  ConstructionCode = {0}", data.ConstructionCode);

                strcmd += string.Format(", DetailNo = {0}", data.FluctuationCode);

                strcmd += string.Format(", LinkType = {0}", data.LinkType);

                strcmd += ", UpdateDate = STR_TO_DATE(DATE_FORMAT(NOW(),'%Y/%m/%d %H:%i:%s'),'%Y/%m/%d %H:%i:%s')";

                strcmd += AddSQLString;

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 削除処理

        /// <summary>

        /// 工事増減情報削除

        /// </summary>

        /// <param name="AddSQLString">削除条件SQL文字列</param>

        /// <param name="data">工事増減情報データ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool DeleteAction(string AddSQLString, bool bConnect = true)

        {

            // インターフェース

            string strcmd = "";

            try

            {

                strcmd = string.Format("{0}{1}", "DELETE FROM ConstructionLink", AddSQLString);

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region データセット処理

        /// <summary>

        /// OracleDataReaderより構造体へセットする

        /// </summary>

        /// <param name="reader">OracleDataReader</param>

        /// <param name="wrk">構造体</param>

        public void Reader2Struct(object[] objwrk, ref ConstructionLink wrk)

        {

            try

            {

                // データ取得

                wrk.ConstructionCode = int.Parse(objwrk[(int)TableColumn.ConstructionCode].ToString());

                wrk.FluctuationCode = int.Parse(objwrk[(int)TableColumn.FluctuationCode].ToString());

                wrk.LinkType = int.Parse(objwrk[(int)TableColumn.LinkType].ToString());

                wrk.EntryDate = DateTime.Parse(objwrk[(int)TableColumn.EntryDate].ToString());

                wrk.UpdateDate = DateTime.Parse(objwrk[(int)TableColumn.UpdateDate].ToString());

            }

            catch (MySqlException myex)

            {

                logger.ErrorFormat("ＭｙＳＱＬエラー：{0}：{1}", CommonMotions.GetMethodName(2), myex.Message);

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}", CommonMotions.GetMethodName(2), ex.Message);

            }

        }

        #endregion

        #region 1項目更新処理（親コードでの更新）

        /// <summary>

        /// 1項目の更新を行う（親コードでの更新）

        /// </summary>

        /// <returns></returns>

        public bool UpdateFeild(int ConstructionCode, int FeildNo, object value, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                strcmd = "UPDATE ConstructionLink";

                strcmd += " SET";

                switch (FeildNo)

                {

                    case (int)TableColumn.ConstructionCode:

                        strcmd += string.Format(" ConstructionCode = {0}", ((int)value).ToString());

                        break;

                    case (int)TableColumn.FluctuationCode:

                        strcmd += string.Format(" FluctuationCode = {0}", ((int)value).ToString());

                        break;

                }

                strcmd += ", UpdateDate = STR_TO_DATE(DATE_FORMAT(NOW(),'%Y/%m/%d %H:%i:%s'),'%Y/%m/%d %H:%i:%s')";

                strcmd += CreatePrimarykeyString(ConstructionCode);

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 1項目更新処理（子コードでの更新）

        /// <summary>

        /// 1項目の更新を行う（子コードでの更新）

        /// </summary>

        /// <returns></returns>

        public bool UpdateFeild2(int FluctuationCode, int FeildNo, object value, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                strcmd = "UPDATE ConstructionLink";

                strcmd += " SET";

                switch (FeildNo)

                {

                    case (int)TableColumn.ConstructionCode:

                        strcmd += string.Format(" ConstructionCode = {0}", ((int)value).ToString());

                        break;

                    case (int)TableColumn.FluctuationCode:

                        strcmd += string.Format(" FluctuationCode = {0}", ((int)value).ToString());

                        break;

                }

                strcmd += ", UpdateDate = STR_TO_DATE(DATE_FORMAT(NOW(),'%Y/%m/%d %H:%i:%s'),'%Y/%m/%d %H:%i:%s')";

                strcmd += string.Format(" WHERE FluctuationCode = {0}", FluctuationCode);

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 検索の文字列を返す

        /// <summary>

        /// 主キー検索の文字列を返す

        /// </summary>

        /// <param name="ComponentCode"></param>

        /// <param name="DetailNo"></param>

        /// <returns></returns>

        public string CreatePrimarykeyString(int ConstructionCode, int FluctuationCode = 0)

        {

            string strWork = "";

            try

            {

                strWork = string.Format(" Where ConstructionCode = {0}", ConstructionCode);

                if (FluctuationCode != 0)

                    strWork += string.Format(" And FluctuationCode = {0}", FluctuationCode);

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strWork);

            }

            return strWork;

        }

        #endregion

    }

}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Collections;

using log4net;

using MySql.Data.MySqlClient;

using ProcessManagement.MySQLDB.MySql;

using ProcessManagement.MySQLDB.Core;

using ProcessManagement.DataModel;

using ProcessManagement.Common;

namespace ProcessManagement.MySQLDB.IOAccess

{

    /// <summary>

    /// 業者請求データアクセスクラス

    /// </summary>

    public class IOBillingData : MySqlProcess

    {

        #region 定義部

        /// <summary>

        /// log4netログを使用する

        /// </summary>

        private static readonly ILog logger = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);

        #endregion

        #region 定数

        /// <summary>

        /// フィールド並び

        /// </summary>

        public enum NameColumn

        {

            CompanyCode = 0,

            TargetDate,

            SeqNo,

            BillPrice,

            EntryDate,

            UpdateDate,

        }

        #endregion

        #region コンストラクタ

        /// <summary>

        /// コンストラクタ

        /// </summary>

        /// <param name="ConnectionString"></param>

        public IOBillingData()

            : base(DBCommonForMySQL.Instance.DBConnectString)

        {

        }

        #endregion

        #region パブリックメソッド

        /// <summary>

        /// データ検索

        /// </summary>

        /// <param name="AddSQLString"></param>

        /// <param name="data"></param>

        /// <param name="bConnect"></param>

        /// <returns></returns>

        public bool SelectAction(string AddSQLString, ref List<BillingData> data, bool bConnect = true)

        {

            // インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            try

            {

                // SQL作成（DateTime型が変換できないのでCharに変換しておく）

                strcmd = "SELECT";

                strcmd += " CompanyCode,TargetDate,SeqNo,BillPrice";

                strcmd += " ,DATE_FORMAT(EntryDate, '%Y/%m/%d %H:%i:%s')";

                strcmd += " ,DATE_FORMAT(UpdateDate, '%Y/%m/%d %H:%i:%s')";

                strcmd += " FROM BillingData";

                strcmd += AddSQLString;

                // SQL実行

                if (!ExecuteReader(strcmd, ref arData, bConnect)) return false;

                // データセット

                foreach (object[] objwrk in arData)

                {

                    BillingData work = new BillingData();

                    Reader2Struct(objwrk, ref work);

                    data.Add(work);

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        /// <summary>

        /// 新規登録

        /// </summary>

        /// <param name="data"></param>

        /// <param name="bConnect"></param>

        /// <returns></returns>

        public bool InsertAction(List<BillingData> data, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                foreach (BillingData work in data)

                {

                    strcmd = "INSERT INTO BillingData";

                    strcmd += " VALUES (";

                    strcmd += string.Format("  {0}", work.CompanyCode.ToString());

                    strcmd += string.Format(", {0}", work.TargetDate.ToString());

                    strcmd += string.Format(", {0}", work.SeqNo.ToString());

                    strcmd += string.Format(", {0}", work.BillPrice.ToString());

                    strcmd += ", DATE_FORMAT(DATE_FORMAT(NOW(),'%Y/%m/%d %H:%i:%s'),'%Y/%m/%d %H:%i:%s')";

                    strcmd += ", DATE_FORMAT(DATE_FORMAT(NOW(),'%Y/%m/%d %H:%i:%s'),'%Y/%m/%d %H:%i:%s')";

                    strcmd = strcmd + ")";

                    if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        /// <summary>

        /// 更新登録

        /// </summary>

        /// <param name="AddSQLString"></param>

        /// <param name="data"></param>

        /// <param name="bConnect"></param>

        /// <returns></returns>

        public bool UpdateAction(string AddSQLString, BillingData data, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                strcmd = "UPDATE BillingData";

                strcmd += " SET";

                strcmd += string.Format(" BillPrice = {0}", data.BillPrice.ToString());

                strcmd += ", UpdateDate = DATE_FORMAT(DATE_FORMAT(NOW(),'%Y/%m/%d %H:%i:%s'),'%Y/%m/%d %H:%i:%s')";

                strcmd += AddSQLString;

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        /// <summary>

        /// 削除

        /// </summary>

        /// <param name="AddSQLString"></param>

        /// <param name="bConnect"></param>

        /// <returns></returns>

        public bool DeleteAction(string AddSQLString, bool bConnect = true)

        {

            // インターフェース

            string strcmd = "";

            try

            {

                strcmd = string.Format("{0}{1}", "DELETE FROM BillingData", AddSQLString);

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        /// <summary>

        /// 構造体へセット

        /// </summary>

        /// <param name="objwrk"></param>

        /// <param name="wrk"></param>

        public void Reader2Struct(object[] objwrk, ref BillingData wrk)

        {

            try

            {

                // データ取得

                wrk.CompanyCode = int.Parse(objwrk[(int)NameColumn.CompanyCode].ToString());

                wrk.TargetDate = int.Parse(objwrk[(int)NameColumn.TargetDate].ToString());

                wrk.SeqNo = int.Parse(objwrk[(int)NameColumn.SeqNo].ToString());

                wrk.BillPrice = long.Parse(objwrk[(int)NameColumn.BillPrice].ToString());

                wrk.EntryDate = DateTime.Parse(objwrk[(int)NameColumn.EntryDate].ToString());

                wrk.UpdateDate = DateTime.Parse(objwrk[(int)NameColumn.UpdateDate].ToString());

            }

            catch (MySqlException oraex)

            {

                logger.ErrorFormat("ＭｙＳＱＬエラー：{0}：{1}", CommonMotions.GetMethodName(), oraex.Message);

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：：{0}：{1}：{2}", CommonMotions.GetMethodName(), ex.Message);

            }

        }

        #endregion

        #region パブリックメソッド（特殊処理）

        /// <summary>

        /// 主キー検索の文字列を返す

        /// </summary>

        /// <param name="BusinessTypeCode"></param>

        /// <returns>Where文字列</returns>

        public string CreatePrimarykeyString(int CompanyCode, int TargetDate, int SeqNo)

        {

            string strWork = string.Empty;

            try

            {

                strWork = string.Format(" Where CompanyCode = {0} and TargetDate = {1} and SeqNo = {2}", CompanyCode, TargetDate, SeqNo);

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strWork);

            }

            return strWork;

        }

        /// <summary>

        /// 行ロック

        /// </summary>

        /// <param name="MaterialItemCode"></param>

        /// <param name="bConnect"></param>

        /// <returns></returns>

        public bool RowLock(int CompanyCode, int TargetDate, int SeqNo, bool bConnect = true)

        {

            //インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            try

            {

                strcmd = string.Format("select * from BillingData where CompanyCode = {0} and TargetDate = {1} and SeqNo = {2} for update;",

                                        CompanyCode, TargetDate, SeqNo);

                // SQL実行

                if (!ExecuteReader(strcmd, ref arData, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

    }

}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Data;

using System.Collections;

using log4net;

using MySql.Data.MySqlClient;           // Data Provider for MySql

using ProcessManagement.MySQLDB.MySql;

using ProcessManagement.MySQLDB.Core;

using ProcessManagement.DataModel;

using ProcessManagement.Common;

namespace ProcessManagement.MySQLDB.IOAccess

{

    /// <summary>

    /// 受注金額データＤＢアクセス

    /// </summary>

    public class IOOrdersPriceData : MySqlProcess

    {

        #region 定義部

        /// <summary>

        /// log4netログを使用する

        /// </summary>

        private static readonly ILog logger = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);

        #endregion

        #region 定数

        /// <summary>

        /// 担当者毎経費データフィールド並び

        /// </summary>

        public enum TableColumn

        {

            ConstructionCode = 0,       // 工事コード

            ChangeNo,	                // 変更番号

            ChangeDate,	                // 変更日

            ChangePersonCode,           // 変更者コード

            ChangePersonName,           // 変更者名

            BeforeValue,                // 変更前税抜受注金額

            BeforeValueInTax,           // 　〃　税込受注金額

            AfterValue,                 // 変更後税抜受注金額

            AfterValueInTax,            // 　〃　税込受注金額

            ChangeComment,              // 変更理由

            EntryDate,

            UpdateDate,

        }

        #endregion

        #region コンストラクタ

        /// <summary>

        /// コンストラクタ

        /// </summary>

        /// <param name="ConnectionString"></param>

        public IOOrdersPriceData()

            : base(DBCommonForMySQL.Instance.DBConnectString)

        {

        }

        #endregion

        #region SQL作成

        /// <summary>

        /// SQL作成

        /// </summary>

        private string CreateSelectSQL()

        {

            // SQL作成

            string strcmd = "SELECT";

            strcmd += "  ConstructionCode";             // 工事コード

            strcmd += " ,ChangeNo";	                    // 変更番号

            strcmd += " ,DATE_FORMAT(ChangeDate, '%Y/%m/%d')";	// 変更日

            strcmd += " ,ChangePersonCode";             // 変更者コード

            strcmd += " ,ChangePersonName";             // 変更者名

            strcmd += " ,BeforeValue";                  // 変更前税抜受注金額

            strcmd += " ,BeforeValueInTax";             // 　〃　税込受注金額

            strcmd += " ,AfterValue";                   // 変更後税抜受注金額

            strcmd += " ,AfterValueInTax";              // 　〃　税込受注金額

            strcmd += " ,ChangeComment";                // 変更理由

            strcmd += ", DATE_FORMAT(EntryDate, '%Y/%m/%d %H:%i:%s')";

            strcmd += ", DATE_FORMAT(UpdateDate, '%Y/%m/%d %H:%i:%s')";

            strcmd += " FROM OrdersPriceData";

            return strcmd;

        }

        #endregion

        #region 複数読込み処理

        public bool SelectAction(string AddSQLString, ref List<OrdersPriceData> data, bool bConnect = true)

        {

            // インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            try

            {

                // SQL作成

                strcmd = CreateSelectSQL() + AddSQLString;

                // SQL実行

                if (!ExecuteReader(strcmd, ref arData, bConnect)) return false;

                // データセット

                foreach (object[] objwrk in arData)

                {

                    OrdersPriceData work = new OrdersPriceData();

                    Reader2Struct(objwrk, ref work);

                    data.Add(work);

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 1件読込み処理

        public bool SelectAction(string AddSQLString, ref OrdersPriceData data, bool bConnect = true)