From b2c7669408b295f50cb02e2e9d6661d6b7674a99 Mon Sep 17 00:00:00 2001 From: kyh <1329522@naver.com> Date: Mon, 10 Apr 2023 16:08:58 +0900 Subject: [PATCH] =?UTF-8?q?1.=20=EC=98=A4=ED=83=80=20=EC=88=98=EC=A0=95=20?= =?UTF-8?q?2.=20SavedResultData=20=EC=82=AD=EC=A0=9C=20=ED=95=A8=EC=88=98?= =?UTF-8?q?=20=EC=B6=94=EA=B0=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- DataSaver/MainForm.cs | 12 +- Million Buyer/MainForm.cs | 6 +- Million Buyer/SubForm/IndicatorLoad.cs | 4 +- Million Hunter/HunterMainForm.cs | 8 +- .../LoadAnalysisResultDataForm.cs | 2 +- .../HunterSubForm/LoadResultViewerForm.cs | 6 +- .../HunterSubForm/ResultViewerForm.cs | 2 +- Million Prototype/Form1.cs | 6 +- Million/DbMangement/DBConnection.cs | 116 +++++++++++++++--- Million/DbMangement/DBServiceFunctions.cs | 12 +- Million/Manager/InitManager.cs | 14 +-- Million/Manager/RealtimeDataSettingManager.cs | 2 +- 12 files changed, 136 insertions(+), 54 deletions(-) diff --git a/DataSaver/MainForm.cs b/DataSaver/MainForm.cs index 5b045e5..fc54b15 100644 --- a/DataSaver/MainForm.cs +++ b/DataSaver/MainForm.cs @@ -163,7 +163,7 @@ namespace DataSaver sqlQuery += Million.DbManagement.DbServiceFunctions.CreateMarketTable_ToDB(item); if (!string.IsNullOrWhiteSpace(sqlQuery)) - Million.DbManagement.DBConnection.QueryUpdateExcuter(CommonProperty.DbConnectionStr + placeName, sqlQuery); + Million.DbManagement.DBConnection.QueryUpdateExecuter(CommonProperty.DbConnectionStr + placeName, sqlQuery); } @@ -202,12 +202,12 @@ namespace DataSaver count++; if (count % 50 == 0) { - Million.DbManagement.DBConnection.QueryUpdateExcuter(CommonProperty.DbConnectionStr + placeName, sqlQuery); + Million.DbManagement.DBConnection.QueryUpdateExecuter(CommonProperty.DbConnectionStr + placeName, sqlQuery); sqlQuery = ""; } } - if (!string.IsNullOrWhiteSpace(sqlQuery)) Million.DbManagement.DBConnection.QueryUpdateExcuter(CommonProperty.DbConnectionStr + placeName, sqlQuery); + if (!string.IsNullOrWhiteSpace(sqlQuery)) Million.DbManagement.DBConnection.QueryUpdateExecuter(CommonProperty.DbConnectionStr + placeName, sqlQuery); MessageBox.Show("기간 삭제 완료"); @@ -244,7 +244,7 @@ namespace DataSaver DbServiceFunctions.GetMarketTable_FromDB("Upbit", "KRW"); // Result Data DB에 생성 - Million.DbManagement.DBConnection.QueryUpdateExcuter + Million.DbManagement.DBConnection.QueryUpdateExecuter (CommonProperty.DbConnectionResultData, DbServiceFunctions.CreateVerifyTickerDataTableQuery()); //market List @@ -285,7 +285,7 @@ namespace DataSaver recentlyDate = recentlyDate.AddMilliseconds(-1 * date.Millisecond); var dicList = list.Where(t => ((DateTime)t["DateTime"]) >= beforeDate && ((DateTime)t["DateTime"]) < recentlyDate).ToList(); - DBConnection.QueryInsertExcuter_VerifyTickerData(dicList, beforeDate); + DBConnection.QueryInsertExecuter_VerifyTickerData(dicList, beforeDate); foreach(var item in dicList) { @@ -305,7 +305,7 @@ namespace DataSaver // //insertDateTime = insertDateTime.AddSeconds(-1 * insertDateTime.Second); // //insertDateTime = insertDateTime.AddMilliseconds(-1 * insertDateTime.Millisecond); // //var dicList = list.Where(t => ((DateTime)t["DateTime"]).Hour == hour).ToList(); - // //DBConnection.QueryInsertExcuter_VerifyTickerData(dicList, insertDateTime); + // //DBConnection.QueryInsertExecuter_VerifyTickerData(dicList, insertDateTime); // ////clear 작업 // //list = list.OrderBy(t => t["DateTime"]).ToList(); // //var index = list.FindLastIndex(t => ((DateTime)t["DateTime"]).Hour == hour); diff --git a/Million Buyer/MainForm.cs b/Million Buyer/MainForm.cs index deeaf63..385b988 100644 --- a/Million Buyer/MainForm.cs +++ b/Million Buyer/MainForm.cs @@ -657,7 +657,7 @@ namespace Million_Buyer try { //result data insert - DBConnection.QueryInsertExcuter_SavedBuyerResultData(cb_UserList.Text, Enum.GetName(typeof(BuyerMode), programMode), time, result); + DBConnection.QueryInsertExecuter_SavedBuyerResultData(cb_UserList.Text, Enum.GetName(typeof(BuyerMode), programMode), time, result); //Grid 처리 TreeListNode buyNode = null; @@ -790,7 +790,7 @@ namespace Million_Buyer _saveResultData.SearchResultList = resultDataList; - DBConnection.QueryInsertExcuter_SavedResultData(_saveResultData); + DBConnection.QueryInsertExecuter_SavedResultData(_saveResultData); _saveResultData.StartDateTime = DateTime.Now; resultDataList.Clear(); @@ -821,7 +821,7 @@ namespace Million_Buyer lb_log.Items.Clear(); } lb_log.Items.Insert(0, log); - DBConnection.QueryInsertExcuter_MainLog(DateTime.Now, cb_UserList.Text, log); + DBConnection.QueryInsertExecuter_MainLog(DateTime.Now, cb_UserList.Text, log); })); return true; diff --git a/Million Buyer/SubForm/IndicatorLoad.cs b/Million Buyer/SubForm/IndicatorLoad.cs index f9efa19..7c8c675 100644 --- a/Million Buyer/SubForm/IndicatorLoad.cs +++ b/Million Buyer/SubForm/IndicatorLoad.cs @@ -28,7 +28,7 @@ namespace Million_Buyer.SubForm { tl_Indicator.ClearNodes(); - datas = DBConnection.QueryGetExcuter_RealTimeIndicator(); + datas = DBConnection.QueryGetExecuter_RealTimeIndicator(); if (datas.Count > 0) { @@ -86,7 +86,7 @@ namespace Million_Buyer.SubForm private void bt_Delete_Click(object sender, EventArgs e) { var strId = tl_Indicator.Selection.First()["Id"].ToString(); - DBConnection.QueryUpdateExcuter(CommonProperty.DbConnectionResultData, + DBConnection.QueryUpdateExecuter(CommonProperty.DbConnectionResultData, "DELETE FROM [ResultData].[dbo].[RealTimeIndicator] WHERE Id = " + strId); Init(); } diff --git a/Million Hunter/HunterMainForm.cs b/Million Hunter/HunterMainForm.cs index 63cd620..ea78976 100644 --- a/Million Hunter/HunterMainForm.cs +++ b/Million Hunter/HunterMainForm.cs @@ -278,7 +278,7 @@ namespace Million CalculateDatas(_saveResultData, cb_UpperMainIndi.Checked, cb_IncludeClearIndicator.Checked, cb_DownBeforeValueFlag.Checked, rd_Hunter.Checked); // 3. 자동으로 저장하기 - if (DBConnection.QueryInsertExcuter_SavedResultData(_saveResultData)) + if (DBConnection.QueryInsertExecuter_SavedResultData(_saveResultData)) { MessageBox.Show("데이터 저장 성공"); } @@ -960,7 +960,7 @@ namespace Million _saveResultData.BuyRegularExpression = textEdit_BuyRegularExpression.Text; _saveResultData.SellRegularExpression = textEdit_SellRegularExpression.Text; _saveResultData.SellExceptionRegularExpression = textEdit_SellExceptionRegularExpression.Text; - if (DBConnection.QueryInsertExcuter_SavedResultData(_saveResultData)) + if (DBConnection.QueryInsertExecuter_SavedResultData(_saveResultData)) MessageBox.Show("데이터 저장 성공"); else MessageBox.Show("데이터 저장 실패"); @@ -982,7 +982,7 @@ namespace Million _saveResultData.BuyRegularExpression = textEdit_BuyRegularExpression.Text; _saveResultData.SellRegularExpression = textEdit_SellRegularExpression.Text; _saveResultData.SellExceptionRegularExpression = textEdit_SellExceptionRegularExpression.Text; - if (DBConnection.QueryInsertExcuter_RealTimeIndicator(_saveResultData, name)) + if (DBConnection.QueryInsertExecuter_RealTimeIndicator(_saveResultData, name)) MessageBox.Show("데이터 저장 성공"); else MessageBox.Show("데이터 저장 실패"); @@ -1006,7 +1006,7 @@ namespace Million LogManager.WriteLog("헌터 리스트 계산 완료. Name : " + item.SavedResultData.Name, "Hunter List 계산"); // 3. 자동으로 저장하기 - if (DBConnection.QueryInsertExcuter_SavedResultData(item.SavedResultData)) + if (DBConnection.QueryInsertExecuter_SavedResultData(item.SavedResultData)) { LogManager.WriteLog("데이터 저장 성공. Name : " + item.SavedResultData.Name, "Hunter List 계산"); } diff --git a/Million Hunter/HunterSubForm/LoadAnalysisResultDataForm.cs b/Million Hunter/HunterSubForm/LoadAnalysisResultDataForm.cs index f0c8521..4487abf 100644 --- a/Million Hunter/HunterSubForm/LoadAnalysisResultDataForm.cs +++ b/Million Hunter/HunterSubForm/LoadAnalysisResultDataForm.cs @@ -36,7 +36,7 @@ namespace Million.HunterSubForm var list = new List(); list.Add(_resultViewerForm._savedResultData.Id); - treeList_ResultData.DataSource = DBConnection.QueryGetExcuter_SavedAnalysisData(list); + treeList_ResultData.DataSource = DBConnection.QueryGetExecuter_SavedAnalysisData(list); } private void treeList_ResultData_MouseDoubleClick(object sender, MouseEventArgs e) diff --git a/Million Hunter/HunterSubForm/LoadResultViewerForm.cs b/Million Hunter/HunterSubForm/LoadResultViewerForm.cs index 719ce1d..1c7f30a 100644 --- a/Million Hunter/HunterSubForm/LoadResultViewerForm.cs +++ b/Million Hunter/HunterSubForm/LoadResultViewerForm.cs @@ -51,7 +51,7 @@ namespace Million.HunterSubForm } // 결과 데이터 정보 가져오기 - savedResultDatas = DBConnection.QueryGetExcuter_SavedResultData(); + savedResultDatas = DBConnection.QueryGetExecuter_SavedResultData(); //foreach (var filePath in Directory.GetFiles(CommonProperty.SaveProgramDirecotryPath).ToList() @@ -109,7 +109,7 @@ namespace Million.HunterSubForm treeList_AnalysisResultData.DataSource = null; var data = new List(); data.Add(selectedResultData.Id); - treeList_AnalysisResultData.DataSource = DBConnection.QueryGetExcuter_SavedAnalysisData(data); + treeList_AnalysisResultData.DataSource = DBConnection.QueryGetExecuter_SavedAnalysisData(data); // 분석 데이터 정보 파일 항목 불러오기(.data) // 폴더 검사 @@ -145,7 +145,7 @@ namespace Million.HunterSubForm var selectedResultData = (SavedResultData)treeList.GetDataRecordByNode(hitInfo.Node); - selectedResultData = DBConnection.QueryGetExcuter_SearchResultData(selectedResultData); + selectedResultData = DBConnection.QueryGetExecuter_SearchResultData(selectedResultData); //Main 폼의 SaveResultData 초기화 _mainForm._saveResultData = null; diff --git a/Million Hunter/HunterSubForm/ResultViewerForm.cs b/Million Hunter/HunterSubForm/ResultViewerForm.cs index 6f20349..f250ba6 100644 --- a/Million Hunter/HunterSubForm/ResultViewerForm.cs +++ b/Million Hunter/HunterSubForm/ResultViewerForm.cs @@ -140,7 +140,7 @@ namespace Million.HunterSubForm // 저장 하기 - if (DBConnection.QueryInsertExcuter_SavedAnalysisData(savedAnalysisData, _savedResultData)) + if (DBConnection.QueryInsertExecuter_SavedAnalysisData(savedAnalysisData, _savedResultData)) { MessageBox.Show("데이터 저장 성공"); textEdit_Description.Text = ""; diff --git a/Million Prototype/Form1.cs b/Million Prototype/Form1.cs index fceacc8..d0de0e1 100644 --- a/Million Prototype/Form1.cs +++ b/Million Prototype/Form1.cs @@ -153,7 +153,7 @@ namespace Million_Prototype int firstFlag = 0; - var savedResultDatas = DBConnection.QueryGetExcuter_SavedResultData(); + var savedResultDatas = DBConnection.QueryGetExecuter_SavedResultData(); var savedResultData = savedResultDatas.FirstOrDefault(t=>t.Name == "IndicatorTemplate"); var sellIndicator = savedResultData.SellSetupList.OfType().ToList(); @@ -276,7 +276,7 @@ namespace Million_Prototype savedResultData.ExchangePlace = "Upbit"; savedResultData.ParentId = null; - DBConnection.QueryInsertExcuter_SavedResultData(savedResultData); + DBConnection.QueryInsertExecuter_SavedResultData(savedResultData); savedResultData.StartDateTime = DateTime.Now; resultDataList.Clear(); @@ -400,7 +400,7 @@ namespace Million_Prototype private void button11_Click(object sender, EventArgs e) { //select 관련 처리 - var list = DBConnection.QueryGetExcuter_SavedResultData(); + var list = DBConnection.QueryGetExecuter_SavedResultData(); } private void button4_Click(object sender, EventArgs e) diff --git a/Million/DbMangement/DBConnection.cs b/Million/DbMangement/DBConnection.cs index 32b1735..5401943 100644 --- a/Million/DbMangement/DBConnection.cs +++ b/Million/DbMangement/DBConnection.cs @@ -23,7 +23,7 @@ namespace Million.DbManagement return CommonProperty.DbConnectionStr + databaseName; } - public static List QueryGetExcuter_Market(string strDBCon, string sqlQuery) + public static List QueryGetExecuter_Market(string strDBCon, string sqlQuery) { if (string.IsNullOrWhiteSpace(sqlQuery)) return null; @@ -84,7 +84,7 @@ namespace Million.DbManagement /// /// /// - public static List QueryGetExcuter_Candle(string strDBCon, string sqlQuery) + public static List QueryGetExecuter_Candle(string strDBCon, string sqlQuery) { var returnData = new List(); @@ -155,7 +155,7 @@ namespace Million.DbManagement /// /// /// - public static List> QueryGetExcuter_MainLog(string strDBCon, string userName, DateTime startDate, DateTime endDate) + public static List> QueryGetExecuter_MainLog(string strDBCon, string userName, DateTime startDate, DateTime endDate) { var returnData = new List>(); @@ -207,7 +207,7 @@ namespace Million.DbManagement /// /// /// - public static List QueryGetExcuterTest_Candle(string strDBCon, string sqlQuery) + public static List QueryGetExecuterTest_Candle(string strDBCon, string sqlQuery) { var returnData = new List(); @@ -238,7 +238,7 @@ namespace Million.DbManagement /// /// conn /// create table sql - public static void QueryUpdateExcuter(string strDBCon, string sqlQuery) + public static void QueryUpdateExecuter(string strDBCon, string sqlQuery) { SqlConnection conn = null; SqlDataReader rdr = null; @@ -277,7 +277,7 @@ namespace Million.DbManagement /// /// /// - public static bool QueryInsertExcuter_SavedBuyerResultData(string userName, string mode, DateTime savedDateTime, SearchResult data) + public static bool QueryInsertExecuter_SavedBuyerResultData(string userName, string mode, DateTime savedDateTime, SearchResult data) { var binaryFormatter = new BinaryFormatter(); @@ -321,11 +321,93 @@ namespace Million.DbManagement } } + /// + /// SavedResultData List 삭제 + /// + /// + /// + public static bool QueryDeleteExecuter_SavedResultData(List ids) + { + var sqlQuery = @"DELETE FROM [ResultData].[dbo].[SavedResultData] WHERE Id in(" + string.Join(",", ids) + ")"; + var strDBCon = CommonProperty.DbConnectionResultData; + + SqlConnection conn = null; + SqlDataReader rdr = null; + + try + { + using (conn = new SqlConnection(strDBCon)) + { + using (var cmd = new SqlCommand(sqlQuery, conn)) + { + conn.Open(); + using (rdr = cmd.ExecuteReader()) + { + } + } + + conn.Close(); + } + return true; + } + catch (Exception e) + { + Console.WriteLine(" ============= exception ==============="); + Console.WriteLine(e.Message); + if (rdr != null) + rdr.Close(); + if (conn != null) + conn.Close(); + return false; + } + } + + /// + /// SavedResultData 삭제 + /// + /// + /// + public static bool QueryDeleteExecuter_SavedResultData(int id) + { + var sqlQuery = @"DELETE FROM [ResultData].[dbo].[SavedResultData] WHERE Id =" + id; + var strDBCon = CommonProperty.DbConnectionResultData; + + SqlConnection conn = null; + SqlDataReader rdr = null; + + try + { + using (conn = new SqlConnection(strDBCon)) + { + using (var cmd = new SqlCommand(sqlQuery, conn)) + { + conn.Open(); + using (rdr = cmd.ExecuteReader()) + { + } + } + + conn.Close(); + } + return true; + } + catch (Exception e) + { + Console.WriteLine(" ============= exception ==============="); + Console.WriteLine(e.Message); + if (rdr != null) + rdr.Close(); + if (conn != null) + conn.Close(); + return false; + } + } + /// /// Insert SavedResultData /// /// - public static bool QueryInsertExcuter_SavedResultData(SavedResultData item) + public static bool QueryInsertExecuter_SavedResultData(SavedResultData item) { var baBinaryFormatter = new BinaryFormatter(); @@ -384,7 +466,7 @@ namespace Million.DbManagement /// /// /// - public static bool QueryInsertExcuter_MainLog(DateTime savedData, string user, string data) + public static bool QueryInsertExecuter_MainLog(DateTime savedData, string user, string data) { var sqlQuery = string.Format(@"INSERT INTO [ResultData].[dbo].[MainLog] VALUES('{0}', '{1}', '{2}');", @@ -430,7 +512,7 @@ namespace Million.DbManagement /// /// /// - public static bool QueryInsertExcuter_RealTimeIndicator(SavedResultData item, string name) + public static bool QueryInsertExecuter_RealTimeIndicator(SavedResultData item, string name) { var baBinaryFormatter = new BinaryFormatter(); @@ -484,7 +566,7 @@ namespace Million.DbManagement /// /// /// - public static bool QueryInsertExcuter_VerifyTickerData(List> data, DateTime savedDateTime) + public static bool QueryInsertExecuter_VerifyTickerData(List> data, DateTime savedDateTime) { var baBinaryFormatter = new BinaryFormatter(); @@ -536,7 +618,7 @@ namespace Million.DbManagement /// /// /// - public static bool QueryInsertExcuter_SavedAnalysisData(SavedAnalysisData savedAnalysisData, SavedResultData savedResultData) + public static bool QueryInsertExecuter_SavedAnalysisData(SavedAnalysisData savedAnalysisData, SavedResultData savedResultData) { var baBinaryFormatter = new BinaryFormatter(); @@ -588,7 +670,7 @@ namespace Million.DbManagement /// /// /// - public static List QueryGetExcuter_SavedBuyerResultData(string userName, string mode, DateTime startDate, DateTime endDate) + public static List QueryGetExecuter_SavedBuyerResultData(string userName, string mode, DateTime startDate, DateTime endDate) { var returnData = new List(); var sqlQuery = string.Format(@"SELECT * FROM [ResultData].[dbo].[SavedBuyerResultData] WHERE [Mode] = '{0}' AND [UserName] = '{1}' @@ -635,7 +717,7 @@ namespace Million.DbManagement /// /// /// - public static List> QueryGetExcuter_VerifyTickerData(DateTime startDate, DateTime endDate) + public static List> QueryGetExecuter_VerifyTickerData(DateTime startDate, DateTime endDate) { var returnData = new List>(); var sqlQuery = string.Format(@"SELECT * FROM [ResultData].[dbo].[VerifyTickerData] WHERE [SavedDateTime] >= '{0}' AND [SavedDateTime] <= '{1}';", @@ -680,7 +762,7 @@ namespace Million.DbManagement /// /// /// - public static SavedResultData QueryGetExcuter_SearchResultData(SavedResultData data) + public static SavedResultData QueryGetExecuter_SearchResultData(SavedResultData data) { if (data != null && data.Id > 0) { @@ -724,7 +806,7 @@ namespace Million.DbManagement /// /// /// - public static List QueryGetExcuter_SavedResultData(List idList = null, bool includeFolder = true) + public static List QueryGetExecuter_SavedResultData(List idList = null, bool includeFolder = true) { var returnData = new List(); var sqlQuery = @"SELECT [Id] @@ -843,7 +925,7 @@ namespace Million.DbManagement /// /// /// - public static List QueryGetExcuter_SavedAnalysisData(List resultIdList) + public static List QueryGetExecuter_SavedAnalysisData(List resultIdList) { var returnData = new List(); var sqlQuery = "SELECT * FROM [ResultData].[dbo].[SavedAnalysisData] WHERE "; @@ -923,7 +1005,7 @@ namespace Million.DbManagement /// 실시간 Indicator 가져오는 함수 /// /// - public static List> QueryGetExcuter_RealTimeIndicator() + public static List> QueryGetExecuter_RealTimeIndicator() { var returnData = new List>(); var sqlQuery = "SELECT * FROM [ResultData].[dbo].[RealTimeIndicator]"; diff --git a/Million/DbMangement/DBServiceFunctions.cs b/Million/DbMangement/DBServiceFunctions.cs index 60d0551..9f64cbc 100644 --- a/Million/DbMangement/DBServiceFunctions.cs +++ b/Million/DbMangement/DBServiceFunctions.cs @@ -199,7 +199,7 @@ namespace Million.DbManagement // Query문 만들기 var sqlQuery = string.Format("select * from dbo.{0} where IsValid = 1 {1};", tableName, subSql); - return DBConnection.QueryGetExcuter_Market(strDbCon, sqlQuery); + return DBConnection.QueryGetExecuter_Market(strDbCon, sqlQuery); } /// @@ -237,7 +237,7 @@ namespace Million.DbManagement var sqlQuery = string.Format(@"SELECT [DateTime],[StartValue],[EndValue],[HighValue],[LowValue],[MoneyVolume],[CandleTimeType] FROM [{0}] WHERE [DateTime] >= '{1}' AND [DateTime] < '{2}' AND [CandleTimeType] = {3} ORDER BY [DateTime] ASC", marketData.CoinFullName, startDate.ToString("yyyy-MM-dd HH:mm:ss"), endDate.ToString("yyyy-MM-dd HH:mm:ss"), (int)candleTimeType); - var dataList = DBConnection.QueryGetExcuter_Candle(strDbCon, sqlQuery); + var dataList = DBConnection.QueryGetExecuter_Candle(strDbCon, sqlQuery); if (dataList == null) return returnData; @@ -282,7 +282,7 @@ namespace Million.DbManagement var sqlQuery = string.Format(@"SELECT TOP({0}) [DateTime],[StartValue],[EndValue],[HighValue],[LowValue],[MoneyVolume],[CandleTimeType] FROM [{1}] WHERE [DateTime] >= '{2}' AND [CandleTimeType] = {3} ORDER BY [DateTime] ASC", count, marketData.CoinFullName, startDate.ToString("yyyy-MM-dd HH:mm:ss"), ((int)candleTimeType).ToString()); - var dataList = DBConnection.QueryGetExcuter_Candle(strDbCon, sqlQuery); + var dataList = DBConnection.QueryGetExecuter_Candle(strDbCon, sqlQuery); if (dataList == null) return returnData; @@ -313,7 +313,7 @@ namespace Million.DbManagement data.ConGoodsData = item; var sqlQuery = string.Format(@"SELECT TOP(1) [DateTime],[StartValue],[EndValue],[HighValue],[LowValue],[MoneyVolume],[CandleTimeType] FROM [{0}] WHERE [CandleTimeType] = {1} ORDER BY [DateTime] DESC", item.CoinFullName, ((int) candleTimeType).ToString()); - var recentlyDataList = DBConnection.QueryGetExcuter_Candle(strDbCon, sqlQuery); + var recentlyDataList = DBConnection.QueryGetExecuter_Candle(strDbCon, sqlQuery); if (recentlyDataList.Count > 0) { @@ -336,7 +336,7 @@ namespace Million.DbManagement // 1개라도 있을 경우 var sqlQuery = string.Format("SELECT TOP(1) [DateTime],[StartValue],[EndValue],[HighValue],[LowValue],[MoneyVolume],[CandleTimeType] FROM [{0}] WHERE [CandleTimeType] = {1} ORDER BY [DateTime] ASC", item.ConGoodsData.CoinFullName, ((int)candleTimeType).ToString()); - var recentlyDataList = DBConnection.QueryGetExcuter_Candle(strDbCon, sqlQuery); + var recentlyDataList = DBConnection.QueryGetExecuter_Candle(strDbCon, sqlQuery); if (recentlyDataList.Count > 0) { recentlyDataList[0].CandleType = CandleType.Old; @@ -514,7 +514,7 @@ namespace Million.DbManagement break; //초당 8회 이상안됨 (0.125초) if (!string.IsNullOrWhiteSpace(insertQuery)) - DBConnection.QueryUpdateExcuter(DbConnectionStr + placeName, insertQuery); + DBConnection.QueryUpdateExecuter(DbConnectionStr + placeName, insertQuery); Thread.Sleep(60); insertQuery = ""; } diff --git a/Million/Manager/InitManager.cs b/Million/Manager/InitManager.cs index b12e6f4..12596ed 100644 --- a/Million/Manager/InitManager.cs +++ b/Million/Manager/InitManager.cs @@ -22,15 +22,15 @@ namespace Million.Manager DbServiceFunctions.GetMarketTable_FromDB(marketName, Enum.GetName(typeof(PaymentType), payment)); // Result Data DB에 생성 - Million.DbManagement.DBConnection.QueryUpdateExcuter + Million.DbManagement.DBConnection.QueryUpdateExecuter (CommonProperty.DbConnectionResultData, DbServiceFunctions.CreateSavedAnalysisDataTableQuery()); - Million.DbManagement.DBConnection.QueryUpdateExcuter + Million.DbManagement.DBConnection.QueryUpdateExecuter (CommonProperty.DbConnectionResultData, DbServiceFunctions.CreateSavedResultDataTableQuery()); - Million.DbManagement.DBConnection.QueryUpdateExcuter + Million.DbManagement.DBConnection.QueryUpdateExecuter (CommonProperty.DbConnectionResultData, DbServiceFunctions.CreateRealTimeIndicatorTableQuery()); - Million.DbManagement.DBConnection.QueryUpdateExcuter + Million.DbManagement.DBConnection.QueryUpdateExecuter (CommonProperty.DbConnectionResultData, DbServiceFunctions.CreateMainLogTableQuery()); - Million.DbManagement.DBConnection.QueryUpdateExcuter + Million.DbManagement.DBConnection.QueryUpdateExecuter (CommonProperty.DbConnectionResultData, DbServiceFunctions.CreateSavedBuyerResultDataTableQuery()); @@ -39,7 +39,7 @@ namespace Million.Manager foreach (var placeName in GetMarketList()) { var createTableSql = Million.DbManagement.DbServiceFunctions.CreateMarketTableQuery(placeName); - Million.DbManagement.DBConnection.QueryUpdateExcuter + Million.DbManagement.DBConnection.QueryUpdateExecuter (CommonProperty.DbConnectionMarket, createTableSql); } UpdateMarketTableOfPlace(placeType, payment); @@ -98,7 +98,7 @@ namespace Million.Manager data.CoinFullName); } if (!string.IsNullOrWhiteSpace(sqlQuery)) - Million.DbManagement.DBConnection.QueryUpdateExcuter(CommonProperty.DbConnectionMarket, sqlQuery); + Million.DbManagement.DBConnection.QueryUpdateExecuter(CommonProperty.DbConnectionMarket, sqlQuery); GetRecentlyMarketOfPlaceList(placeType); } diff --git a/Million/Manager/RealtimeDataSettingManager.cs b/Million/Manager/RealtimeDataSettingManager.cs index 810f4d0..419c4bc 100644 --- a/Million/Manager/RealtimeDataSettingManager.cs +++ b/Million/Manager/RealtimeDataSettingManager.cs @@ -168,7 +168,7 @@ namespace Million.Manager /// private void GetAllTickerDataList() { - var tickerDickList = DBConnection.QueryGetExcuter_VerifyTickerData(startDateTime, endDateTime); + var tickerDickList = DBConnection.QueryGetExecuter_VerifyTickerData(startDateTime, endDateTime); tickerDickList = tickerDickList.OrderBy(t => t["DateTime"]?.ToString()).ToList(); foreach (var item in tickerDickList) {