MES/MES-Toolkit
6
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

修改导出

Browse Source
This commit is contained in:
lindj
2022-01-18 11:25:50 +08:00
parent de141de3bd
commit d2697baf37
1 changed files with 18 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
src/Archiver/Commands/ExportTableCommand.cs
View File

@@ -1,18 +1,13 @@
using MySqlConnector; using Chenfeng.MES.Archiver.Core;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Dapper;
using CliFx;
using CliFx.Infrastructure;
using CliFx.Attributes;
using System.Data;
using System.Data.Common;
using Chenfeng.MES.Archiver.Core;
using Chenfeng.MES.Archiver.Data; using Chenfeng.MES.Archiver.Data;
using CliFx;
using CliFx.Attributes;
using CliFx.Infrastructure;
using Dapper;
using MySqlConnector;
using System.Data;
using System.Diagnostics; using System.Diagnostics;
using System.Text;
namespace Chenfeng.MES.Archiver.Commands namespace Chenfeng.MES.Archiver.Commands
{ {
@@ -89,7 +84,7 @@ namespace Chenfeng.MES.Archiver.Commands
{ {
Db?.Close(); Db?.Close();
} }
console.Output.WriteLine("执行耗时:" + (DateTime.Now - startTime).TotalMilliseconds+"ms"); console.Output.WriteLine("执行耗时:" + (DateTime.Now - startTime).TotalMilliseconds + "ms");
return default; return default;
} }
@@ -159,14 +154,14 @@ namespace Chenfeng.MES.Archiver.Commands
using (var reader = cmd.ExecuteReader()) using (var reader = cmd.ExecuteReader())
{ {
if (columnString.Length ==0) if (columnString.Length == 0)
{ {
for (int i = 0; i < reader.FieldCount; i++) for (int i = 0; i < reader.FieldCount; i++)
{ {
//columns.Add(reader.GetName(i)); //columns.Add(reader.GetName(i));
columnString.Append($"`reader.GetName(i)`,"); columnString.Append($"`{reader.GetName(i)}`,");
} }
columnString.Length--; columnString.Length--;
} }
while (reader.Read()) while (reader.Read())
@@ -175,13 +170,17 @@ namespace Chenfeng.MES.Archiver.Commands
for (int i = 0; i < reader.FieldCount; i++) for (int i = 0; i < reader.FieldCount; i++)
{ {
var val = reader.GetValue(i); var val = reader.GetValue(i);
switch (val) switch (val)
{ {
case bool b:
row.Add(b ? 1 : 0);
break;
case string s: case string s:
row.Add($"'{s}'"); row.Add($"'{s}'");
break; break;
case DateTime dt: case DateTime dt:
row.Add(dt.ToString("'yyyy-MM-dd HH:mm:ss'")); row.Add('\'' + dt.ToString("yyyy-MM-dd HH:mm:ss") + '\'');
break; break;
case byte[] byteList: case byte[] byteList:
row.Add("0x" + string.Concat(byteList.Select(i => i.ToString("X2")))); row.Add("0x" + string.Concat(byteList.Select(i => i.ToString("X2"))));
@@ -237,7 +236,7 @@ namespace Chenfeng.MES.Archiver.Commands
} }
watch.Stop(); watch.Stop();
Print("导出完成,耗时" + watch.ElapsedMilliseconds+"ms"); Print("导出完成,耗时" + watch.ElapsedMilliseconds + "ms");
} }
public void Step(Action<string> action, params string[] tables) public void Step(Action<string> action, params string[] tables)