Archived
添加项目文件。
This commit is contained in:
sc committed
1 parent
ae61226cb0
commit
8f6f633278
9 files changed
+1201
No files matched your search
@@ -0,0 +1,25 @@
|
|||||||
|
|
||||||
|
Microsoft Visual Studio Solution File, Format Version 12.00
|
||||||
|
# Visual Studio Version 17
|
||||||
|
VisualStudioVersion = 17.14.36202.13 d17.14
|
||||||
|
MinimumVisualStudioVersion = 10.0.40219.1
|
||||||
|
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ProcessManage", "ProcessManage\ProcessManage.csproj", "{C23B5C86-638A-431E-939B-591CDF8CF6D3}"
|
||||||
|
EndProject
|
||||||
|
Global
|
||||||
|
GlobalSection(SolutionConfigurationPlatforms) = preSolution
|
||||||
|
Debug|Any CPU = Debug|Any CPU
|
||||||
|
Release|Any CPU = Release|Any CPU
|
||||||
|
EndGlobalSection
|
||||||
|
GlobalSection(ProjectConfigurationPlatforms) = postSolution
|
||||||
|
{C23B5C86-638A-431E-939B-591CDF8CF6D3}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||||
|
{C23B5C86-638A-431E-939B-591CDF8CF6D3}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||||
|
{C23B5C86-638A-431E-939B-591CDF8CF6D3}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||||
|
{C23B5C86-638A-431E-939B-591CDF8CF6D3}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||||
|
EndGlobalSection
|
||||||
|
GlobalSection(SolutionProperties) = preSolution
|
||||||
|
HideSolutionNode = FALSE
|
||||||
|
EndGlobalSection
|
||||||
|
GlobalSection(ExtensibilityGlobals) = postSolution
|
||||||
|
SolutionGuid = {27BEF72D-8965-44C7-A72E-C25F919388E2}
|
||||||
|
EndGlobalSection
|
||||||
|
EndGlobal
|
||||||
@@ -0,0 +1,6 @@
|
|||||||
|
<?xml version="1.0" encoding="utf-8" ?>
|
||||||
|
<configuration>
|
||||||
|
<startup>
|
||||||
|
<supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.7.2" />
|
||||||
|
</startup>
|
||||||
|
</configuration>
|
||||||
@@ -0,0 +1,138 @@
|
|||||||
|
using System;
|
||||||
|
using System.Collections.Generic;
|
||||||
|
using System.Linq;
|
||||||
|
using System.Text;
|
||||||
|
using System.Threading;
|
||||||
|
using System.Threading.Tasks;
|
||||||
|
|
||||||
|
namespace ProcessManage
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// 使用using代替lock操作的对象，可指定写入和读取锁定模式
|
||||||
|
/// </summary>
|
||||||
|
public sealed class ClsLock
|
||||||
|
{
|
||||||
|
#region 内部类
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 利用IDisposable的using语法糖方便的释放锁定操作内部类
|
||||||
|
/// </summary>
|
||||||
|
private struct Lock : IDisposable
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// 读写锁对象
|
||||||
|
/// </summary>
|
||||||
|
private readonly ReaderWriterLockSlim _Lock;
|
||||||
|
/// <summary>
|
||||||
|
/// 是否为写入模式
|
||||||
|
/// </summary>
|
||||||
|
private bool _IsWrite;
|
||||||
|
/// <summary>
|
||||||
|
/// 利用IDisposable的using语法糖方便的释放锁定操作构造函数
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="rwl">读写锁</param>
|
||||||
|
/// <param name="isWrite">写入模式为true，读取模式为false</param>
|
||||||
|
public Lock(ReaderWriterLockSlim rwl, bool isWrite)
|
||||||
|
{
|
||||||
|
_Lock = rwl;
|
||||||
|
_IsWrite = isWrite;
|
||||||
|
}
|
||||||
|
/// <summary>
|
||||||
|
/// 释放对象时退出指定锁定模式
|
||||||
|
/// </summary>
|
||||||
|
public void Dispose()
|
||||||
|
{
|
||||||
|
if (_IsWrite)
|
||||||
|
{
|
||||||
|
if (_Lock.IsWriteLockHeld)
|
||||||
|
{
|
||||||
|
_Lock.ExitWriteLock();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
if (_Lock.IsReadLockHeld)
|
||||||
|
{
|
||||||
|
_Lock.ExitReadLock();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 空的可释放对象，免去了调用时需要判断是否为null的问题内部类
|
||||||
|
/// </summary>
|
||||||
|
private class Disposable : IDisposable
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// 空的可释放对象
|
||||||
|
/// </summary>
|
||||||
|
public static readonly Disposable Empty = new Disposable();
|
||||||
|
/// <summary>
|
||||||
|
/// 空的释放方法
|
||||||
|
/// </summary>
|
||||||
|
public void Dispose() { }
|
||||||
|
}
|
||||||
|
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 读写锁
|
||||||
|
/// </summary>
|
||||||
|
private readonly ReaderWriterLockSlim _LockSlim = new ReaderWriterLockSlim();
|
||||||
|
/// <summary>
|
||||||
|
/// 使用using代替lock操作的对象，可指定写入和读取锁定模式构造函数
|
||||||
|
/// </summary>
|
||||||
|
public ClsLock()
|
||||||
|
{
|
||||||
|
Enabled = true;
|
||||||
|
}
|
||||||
|
/// <summary>
|
||||||
|
/// 是否启用，当该值为false时，Read()和Write()方法将返回 Disposable.Empty
|
||||||
|
/// </summary>
|
||||||
|
public bool Enabled { get; set; }
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 进入读取锁定模式，该模式下允许多个读操作同时进行，
|
||||||
|
/// 退出读锁请将返回对象释放，建议使用using语块,
|
||||||
|
/// Enabled为false时，返回Disposable.Empty，
|
||||||
|
/// 在读取或写入锁定模式下重复执行，返回Disposable.Empty;
|
||||||
|
/// </summary>
|
||||||
|
public IDisposable Read()
|
||||||
|
{
|
||||||
|
if (Enabled == false || _LockSlim.IsReadLockHeld || _LockSlim.IsWriteLockHeld)
|
||||||
|
{
|
||||||
|
return Disposable.Empty;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
_LockSlim.EnterReadLock();
|
||||||
|
return new Lock(_LockSlim, false);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 进入写入锁定模式,该模式下只允许同时执行一个读操作，
|
||||||
|
/// 退出读锁请将返回对象释放，建议使用using语块，
|
||||||
|
/// Enabled为false时，返回Disposable.Empty，
|
||||||
|
/// 在写入锁定模式下重复执行，返回Disposable.Empty
|
||||||
|
/// </summary>
|
||||||
|
/// <exception cref="NotImplementedException">读取模式下不能进入写入锁定状态</exception>
|
||||||
|
public IDisposable Write()
|
||||||
|
{
|
||||||
|
if (Enabled == false || _LockSlim.IsWriteLockHeld)
|
||||||
|
{
|
||||||
|
return Disposable.Empty;
|
||||||
|
}
|
||||||
|
else if (_LockSlim.IsReadLockHeld)
|
||||||
|
{
|
||||||
|
throw new NotImplementedException("读取模式下不能进入写入锁定状态");
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
_LockSlim.EnterWriteLock();
|
||||||
|
return new Lock(_LockSlim, true);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,52 @@
|
|||||||
|
using System.Runtime.InteropServices;
|
||||||
|
using System.Text;
|
||||||
|
|
||||||
|
namespace ProcessManage
|
||||||
|
{
|
||||||
|
internal class IniFile
|
||||||
|
{
|
||||||
|
public class IniFiles
|
||||||
|
{
|
||||||
|
public string path;
|
||||||
|
[DllImport("kernel32")] //返回0表示失败，非0为成功
|
||||||
|
private static extern long WritePrivateProfileString(string section, string key, string val, string filePath);
|
||||||
|
[DllImport("kernel32")] //返回取得字符串缓冲区的长度
|
||||||
|
private static extern int GetPrivateProfileString(string section, string key, string def, StringBuilder retVal, int size, string filePath);
|
||||||
|
/// <summary>
|
||||||
|
/// 保存ini文件的路径
|
||||||
|
/// 调用示例：var ini = IniFiles("C:\file.ini");
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="INIPath"></param>
|
||||||
|
public IniFiles(string iniPath)
|
||||||
|
{
|
||||||
|
this.path = iniPath;
|
||||||
|
}
|
||||||
|
/// <summary>
|
||||||
|
/// 写Ini文件
|
||||||
|
/// 调用示例：ini.IniWritevalue("Server","name","localhost");
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="Section">[缓冲区]</param>
|
||||||
|
/// <param name="Key">键</param>
|
||||||
|
/// <param name="value">值</param>
|
||||||
|
public void IniWritevalue(string Section, string Key, string value)
|
||||||
|
{
|
||||||
|
WritePrivateProfileString(Section, Key, value, this.path);
|
||||||
|
}
|
||||||
|
/// <summary>
|
||||||
|
/// 读Ini文件
|
||||||
|
/// 调用示例：ini.IniWritevalue("Server","name");
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="Section">[缓冲区]</param>
|
||||||
|
/// <param name="Key">键</param>
|
||||||
|
/// <returns>值</returns>
|
||||||
|
public string IniReadvalue(string Section, string Key)
|
||||||
|
{
|
||||||
|
StringBuilder temp = new StringBuilder(255);
|
||||||
|
|
||||||
|
int i = GetPrivateProfileString(Section, Key, "", temp, 255, this.path);
|
||||||
|
return temp.ToString();
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,118 @@
|
|||||||
|
using System;
|
||||||
|
using System.Collections.Generic;
|
||||||
|
using System.Data;
|
||||||
|
using System.IO;
|
||||||
|
|
||||||
|
namespace ProcessManage
|
||||||
|
{
|
||||||
|
public class LogGing
|
||||||
|
{
|
||||||
|
public static void LogGingDATA(string dat)
|
||||||
|
{
|
||||||
|
string logpath = System.Environment.CurrentDirectory + "\\Log";//日志文件目录
|
||||||
|
string logPath = "" + System.Environment.CurrentDirectory + "\\Log\\" + DateTime.Now.ToString("yyyy-MM-dd") + ".txt";//日志文件
|
||||||
|
string Log_time = "[" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "]：";
|
||||||
|
|
||||||
|
if (Directory.Exists(logpath))//检查日志路径
|
||||||
|
{
|
||||||
|
if (!File.Exists(logPath))//检查日志文件并写入启动日志
|
||||||
|
{
|
||||||
|
FileStream fs = new FileStream(logPath, FileMode.CreateNew, FileAccess.Write);//创建写入文件
|
||||||
|
StreamWriter wr = new StreamWriter(fs);//创建文件
|
||||||
|
wr.WriteLine(Log_time + dat);
|
||||||
|
wr.Close();
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
FileStream fs = new FileStream(logPath, FileMode.Append, FileAccess.Write);
|
||||||
|
StreamWriter wr = new StreamWriter(fs);//创建文件
|
||||||
|
wr.WriteLine(Log_time + dat);
|
||||||
|
wr.Close();
|
||||||
|
}
|
||||||
|
catch { }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
DirectoryInfo directoryInfo = new DirectoryInfo(logpath);
|
||||||
|
directoryInfo.Create();//创建日志路径
|
||||||
|
}
|
||||||
|
}
|
||||||
|
public static void ERRDATA(System.Exception dat)
|
||||||
|
{
|
||||||
|
string Log_time = DateTime.Now.ToString("yyyy-MM-dd");
|
||||||
|
string logpath = System.Environment.CurrentDirectory + "\\ERR";//日志文件目录
|
||||||
|
// string logPathtxt = "" + System.Environment.CurrentDirectory + "\\Log\\"+ Log_time + "Log.txt";//日志文件
|
||||||
|
// System.IO.DirectoryInfo log = new System.IO.DirectoryInfo();//生成日志文件目录
|
||||||
|
string log_path = logpath + "\\ERR" + Log_time + ".txt";
|
||||||
|
string Log_timehms = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
||||||
|
if (Directory.Exists(logpath))//检查日志路径
|
||||||
|
{
|
||||||
|
if (!File.Exists(log_path))//检查文件并写入
|
||||||
|
{
|
||||||
|
// FileStream fs = new FileStream(log_path, FileMode.CreateNew, FileAccess.Write);//创建文件
|
||||||
|
// StreamWriter wr = new StreamWriter(fs);//创建文件
|
||||||
|
// wr.Close();
|
||||||
|
FileStream fil = new FileStream(log_path, FileMode.CreateNew, FileAccess.Write);//创建写入文件
|
||||||
|
StreamWriter wfil = new StreamWriter(fil);//创建文件
|
||||||
|
wfil.WriteLine("[" + Log_timehms + "];[Error] ||" + Environment.NewLine.ToString());
|
||||||
|
wfil.WriteLine("[" + Log_timehms + "];[Error source] ||" + dat.Source.ToString() + Environment.NewLine.ToString());
|
||||||
|
wfil.WriteLine("[" + Log_timehms + "];[Error message] ||" + dat.Message.ToString() + Environment.NewLine.ToString());
|
||||||
|
wfil.WriteLine("[" + Log_timehms + "];[Error area] ||" + dat.StackTrace.ToString());
|
||||||
|
wfil.Close();
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
FileStream fs = new FileStream(log_path, FileMode.Append, FileAccess.Write);//创建写入文件
|
||||||
|
StreamWriter wr = new StreamWriter(fs);//创建文件
|
||||||
|
wr.WriteLine("[" + Log_timehms + "];[Error] ||" + Environment.NewLine.ToString());
|
||||||
|
wr.WriteLine("[" + Log_timehms + "];[Error source] ||" + dat.ToString() + Environment.NewLine.ToString());
|
||||||
|
wr.WriteLine("[" + Log_timehms + "];[Error message] ||" + dat.Message.ToString() + Environment.NewLine.ToString());
|
||||||
|
wr.WriteLine("[" + Log_timehms + "];[Error area] ||" + dat.ToString());
|
||||||
|
wr.Close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
DirectoryInfo directoryInfo = new DirectoryInfo(logpath);
|
||||||
|
directoryInfo.Create();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
public static void ExchangeDATA(string dat)
|
||||||
|
{
|
||||||
|
string Log_time = DateTime.Now.ToString("yyyy-MM-dd");
|
||||||
|
string logpath = System.Environment.CurrentDirectory + "\\Exchange";//日志文件目录
|
||||||
|
// string logPathtxt = "" + System.Environment.CurrentDirectory + "\\Log\\"+ Log_time + "Log.txt";//日志文件
|
||||||
|
// System.IO.DirectoryInfo log = new System.IO.DirectoryInfo();//生成日志文件目录
|
||||||
|
string log_path = logpath + "\\Exchange" + Log_time + ".txt";
|
||||||
|
string Log_timehms = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
||||||
|
if (Directory.Exists(logpath))//检查日志路径
|
||||||
|
{
|
||||||
|
if (!File.Exists(log_path))//检查文件并写入
|
||||||
|
{
|
||||||
|
// FileStream fs = new FileStream(log_path, FileMode.CreateNew, FileAccess.Write);//创建文件
|
||||||
|
// StreamWriter wr = new StreamWriter(fs);//创建文件
|
||||||
|
// wr.Close();
|
||||||
|
FileStream fil = new FileStream(log_path, FileMode.CreateNew, FileAccess.Write);//创建写入文件
|
||||||
|
StreamWriter wfil = new StreamWriter(fil);//创建文件
|
||||||
|
wfil.WriteLine("[" + Log_timehms + "];[Exchange] ||" + dat);
|
||||||
|
wfil.Close();
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
FileStream fs = new FileStream(log_path, FileMode.Append, FileAccess.Write);//创建写入文件
|
||||||
|
StreamWriter wr = new StreamWriter(fs);//创建文件
|
||||||
|
wr.WriteLine("[" + Log_timehms + "];[Exchange] ||" + dat);
|
||||||
|
wr.Close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
DirectoryInfo directoryInfo = new DirectoryInfo(logpath);
|
||||||
|
directoryInfo.Create();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,62 @@
|
|||||||
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
|
<Project ToolsVersion="15.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
|
||||||
|
<Import Project="$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props" Condition="Exists('$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props')" />
|
||||||
|
<PropertyGroup>
|
||||||
|
<Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
|
||||||
|
<Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
|
||||||
|
<ProjectGuid>{C23B5C86-638A-431E-939B-591CDF8CF6D3}</ProjectGuid>
|
||||||
|
<OutputType>Exe</OutputType>
|
||||||
|
<RootNamespace>ProcessManage</RootNamespace>
|
||||||
|
<AssemblyName>ProcessManage</AssemblyName>
|
||||||
|
<TargetFrameworkVersion>v4.7.2</TargetFrameworkVersion>
|
||||||
|
<FileAlignment>512</FileAlignment>
|
||||||
|
<AutoGenerateBindingRedirects>true</AutoGenerateBindingRedirects>
|
||||||
|
<Deterministic>true</Deterministic>
|
||||||
|
</PropertyGroup>
|
||||||
|
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
|
||||||
|
<PlatformTarget>AnyCPU</PlatformTarget>
|
||||||
|
<DebugSymbols>true</DebugSymbols>
|
||||||
|
<DebugType>full</DebugType>
|
||||||
|
<Optimize>false</Optimize>
|
||||||
|
<OutputPath>bin\Debug\</OutputPath>
|
||||||
|
<DefineConstants>DEBUG;TRACE</DefineConstants>
|
||||||
|
<ErrorReport>prompt</ErrorReport>
|
||||||
|
<WarningLevel>4</WarningLevel>
|
||||||
|
</PropertyGroup>
|
||||||
|
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
|
||||||
|
<PlatformTarget>AnyCPU</PlatformTarget>
|
||||||
|
<DebugType>pdbonly</DebugType>
|
||||||
|
<Optimize>true</Optimize>
|
||||||
|
<OutputPath>bin\Release\</OutputPath>
|
||||||
|
<DefineConstants>TRACE</DefineConstants>
|
||||||
|
<ErrorReport>prompt</ErrorReport>
|
||||||
|
<WarningLevel>4</WarningLevel>
|
||||||
|
</PropertyGroup>
|
||||||
|
<ItemGroup>
|
||||||
|
<Reference Include="System" />
|
||||||
|
<Reference Include="System.Core" />
|
||||||
|
<Reference Include="System.Xml.Linq" />
|
||||||
|
<Reference Include="System.Data.DataSetExtensions" />
|
||||||
|
<Reference Include="Microsoft.CSharp" />
|
||||||
|
<Reference Include="System.Data" />
|
||||||
|
<Reference Include="System.Net.Http" />
|
||||||
|
<Reference Include="System.Xml" />
|
||||||
|
</ItemGroup>
|
||||||
|
<ItemGroup>
|
||||||
|
<Compile Include="ClsLock.cs" />
|
||||||
|
<Compile Include="IniFile.cs" />
|
||||||
|
<Compile Include="LogGing.cs" />
|
||||||
|
<Compile Include="Program.cs" />
|
||||||
|
<Compile Include="Properties\AssemblyInfo.cs" />
|
||||||
|
<Compile Include="SqliteHelper.cs" />
|
||||||
|
</ItemGroup>
|
||||||
|
<ItemGroup>
|
||||||
|
<None Include="App.config" />
|
||||||
|
</ItemGroup>
|
||||||
|
<ItemGroup>
|
||||||
|
<PackageReference Include="System.Data.SQLite">
|
||||||
|
<Version>1.0.119</Version>
|
||||||
|
</PackageReference>
|
||||||
|
</ItemGroup>
|
||||||
|
<Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
|
||||||
|
</Project>
|
||||||
@@ -0,0 +1,83 @@
|
|||||||
|
using System;
|
||||||
|
using System.Collections.Generic;
|
||||||
|
using System.Data;
|
||||||
|
using System.Data.SqlClient;
|
||||||
|
using System.Linq;
|
||||||
|
using System.Security.Cryptography;
|
||||||
|
using System.Text;
|
||||||
|
using System.Threading;
|
||||||
|
using System.Threading.Tasks;
|
||||||
|
|
||||||
|
namespace ProcessManage
|
||||||
|
{
|
||||||
|
internal class Program
|
||||||
|
{
|
||||||
|
private static IniFile.IniFiles Configini = new IniFile.IniFiles(Convert.ToString(System.AppDomain.CurrentDomain.BaseDirectory) + "ProcessManageConfigini.ini");
|
||||||
|
private static string SQLIP = Configini.IniReadvalue("SQL_SERVER", "SQL1"); //读配置文件
|
||||||
|
private static string SQLNAME = Configini.IniReadvalue("SQL_SERVER", "SQL2");
|
||||||
|
private static string SQMOD = Configini.IniReadvalue("SQL_SERVER", "SQL3");
|
||||||
|
private static string SQLUSER = Configini.IniReadvalue("SQL_SERVER", "SQL4");
|
||||||
|
private static string SQLPASWORD = Configini.IniReadvalue("SQL_SERVER", "SQL5");
|
||||||
|
private static DataTable DyelotsBulkedRecipe = new DataTable();
|
||||||
|
private static Timer _timer;
|
||||||
|
private static int Count = 0;
|
||||||
|
private static readonly int _intervalMs = int.Parse( Configini.IniReadvalue("SQL_SERVER", "SQL6"));
|
||||||
|
static void Main(string[] args)
|
||||||
|
{
|
||||||
|
Console.WriteLine("Process选择功能启动");
|
||||||
|
_timer = new Timer(
|
||||||
|
callback: EXTask,
|
||||||
|
state: null,
|
||||||
|
dueTime: 100,
|
||||||
|
period: Timeout.Infinite);
|
||||||
|
|
||||||
|
Console.ReadKey();//等待退出
|
||||||
|
|
||||||
|
_timer?.Dispose();//清理
|
||||||
|
Console.WriteLine("程序退出");
|
||||||
|
}
|
||||||
|
|
||||||
|
private static void EXTask(object state)
|
||||||
|
{
|
||||||
|
string Connstr_SC;
|
||||||
|
string DyelotsBulkedRecipe_sql = "SELECT * FROM [dbo].[DyelotsBulkedRecipe] WHERE Created > '"
|
||||||
|
+ DateTime.Now.AddDays(-1).ToString("yyyy/MM/dd") + "' AND Process IS NULL";
|
||||||
|
try
|
||||||
|
{
|
||||||
|
DyelotsBulkedRecipe.Clear();
|
||||||
|
|
||||||
|
if (SQMOD == "Windows Authentication")
|
||||||
|
{
|
||||||
|
Connstr_SC = "server=" + SQLIP + ";database=" + SQLNAME + ";Trusted_Connection=SSPI";
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
Connstr_SC = "server=" + SQLIP + ";database=" + SQLNAME + ";User ID=" + SQLUSER + ";Password=" + SQLPASWORD;
|
||||||
|
}
|
||||||
|
SqlConnection conn_SC = new SqlConnection(Connstr_SC);
|
||||||
|
conn_SC.OpenAsync(); //连接数据库
|
||||||
|
SqlDataAdapter DyelotsBulkedRecipe_ = new SqlDataAdapter(DyelotsBulkedRecipe_sql, Connstr_SC);
|
||||||
|
conn_SC.Close();
|
||||||
|
DyelotsBulkedRecipe_.Fill(DyelotsBulkedRecipe);
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
Console.Write("\n"+DateTime.Now.ToString("yyyy/MM/dd-HH:mm:ss")+$"转换{Count}条");
|
||||||
|
Count = 0;
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{//错误处理
|
||||||
|
LogGing.ERRDATA(ex);
|
||||||
|
Console.Write(ex.ToString());
|
||||||
|
}
|
||||||
|
finally
|
||||||
|
{
|
||||||
|
_timer.Change(
|
||||||
|
dueTime: _intervalMs,
|
||||||
|
period: Timeout.Infinite);//设定下次触发
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,33 @@
|
|||||||
|
using System.Reflection;
|
||||||
|
using System.Runtime.CompilerServices;
|
||||||
|
using System.Runtime.InteropServices;
|
||||||
|
|
||||||
|
// 有关程序集的一般信息由以下
|
||||||
|
// 控制。更改这些特性值可修改
|
||||||
|
// 与程序集关联的信息。
|
||||||
|
[assembly: AssemblyTitle("ProcessManage")]
|
||||||
|
[assembly: AssemblyDescription("")]
|
||||||
|
[assembly: AssemblyConfiguration("")]
|
||||||
|
[assembly: AssemblyCompany("")]
|
||||||
|
[assembly: AssemblyProduct("ProcessManage")]
|
||||||
|
[assembly: AssemblyCopyright("Copyright © 2025")]
|
||||||
|
[assembly: AssemblyTrademark("")]
|
||||||
|
[assembly: AssemblyCulture("")]
|
||||||
|
|
||||||
|
// 将 ComVisible 设置为 false 会使此程序集中的类型
|
||||||
|
//对 COM 组件不可见。如果需要从 COM 访问此程序集中的类型
|
||||||
|
//请将此类型的 ComVisible 特性设置为 true。
|
||||||
|
[assembly: ComVisible(false)]
|
||||||
|
|
||||||
|
// 如果此项目向 COM 公开，则下列 GUID 用于类型库的 ID
|
||||||
|
[assembly: Guid("c23b5c86-638a-431e-939b-591cdf8cf6d3")]
|
||||||
|
|
||||||
|
// 程序集的版本信息由下列四个值组成:
|
||||||
|
//
|
||||||
|
// 主版本
|
||||||
|
// 次版本
|
||||||
|
// 生成号
|
||||||
|
// 修订号
|
||||||
|
//
|
||||||
|
[assembly: AssemblyVersion("1.0.0.0")]
|
||||||
|
[assembly: AssemblyFileVersion("1.0.0.0")]
|
||||||
@@ -0,0 +1,684 @@
|
|||||||
|
using System;
|
||||||
|
using System.Collections.Generic;
|
||||||
|
using System.Linq;
|
||||||
|
using System.Text;
|
||||||
|
using System.Threading.Tasks;
|
||||||
|
using System.Data;
|
||||||
|
using System.IO;
|
||||||
|
using System.Data.Common;
|
||||||
|
using System.Data.SQLite;
|
||||||
|
using System.Drawing;
|
||||||
|
|
||||||
|
|
||||||
|
namespace ProcessManage
|
||||||
|
{
|
||||||
|
public class SqliteHelper
|
||||||
|
{
|
||||||
|
|
||||||
|
public class SQLiteHelper
|
||||||
|
{
|
||||||
|
#region 字段
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 事务的基类
|
||||||
|
/// </summary>
|
||||||
|
private DbTransaction DBtrans;
|
||||||
|
/// <summary>
|
||||||
|
/// 使用静态变量字典解决多线程实例本类，实现一个数据库对应一个clslock
|
||||||
|
/// </summary>
|
||||||
|
private static readonly Dictionary<string, ClsLock> RWL = new Dictionary<string, ClsLock>();
|
||||||
|
/// <summary>
|
||||||
|
/// 数据库地址
|
||||||
|
/// </summary>
|
||||||
|
private readonly string mdataFile;
|
||||||
|
/// <summary>
|
||||||
|
/// 数据库密码
|
||||||
|
/// </summary>
|
||||||
|
private readonly string mPassWord;
|
||||||
|
private readonly string LockName = null;
|
||||||
|
/// <summary>
|
||||||
|
/// 数据库连接定义
|
||||||
|
/// </summary>
|
||||||
|
private SQLiteConnection mConn;
|
||||||
|
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
#region 构造函数
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 根据数据库地址初始化
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="dataFile">数据库地址</param>
|
||||||
|
public SQLiteHelper(string dataFile)
|
||||||
|
{
|
||||||
|
this.mdataFile = dataFile ?? throw new ArgumentNullException("dataFile=null");
|
||||||
|
//this.mdataFile = AppDomain.CurrentDomain.BaseDirectory + dataFile;
|
||||||
|
this.mdataFile = dataFile;
|
||||||
|
if (!RWL.ContainsKey(dataFile))
|
||||||
|
{
|
||||||
|
LockName = dataFile;
|
||||||
|
RWL.Add(dataFile, new ClsLock());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 使用密码打开数据库
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="dataFile">数据库地址</param>
|
||||||
|
/// <param name="PassWord">数据库密码</param>
|
||||||
|
public SQLiteHelper(string dataFile, string PassWord)
|
||||||
|
{
|
||||||
|
this.mdataFile = dataFile ?? throw new ArgumentNullException("dataFile is null");
|
||||||
|
this.mPassWord = PassWord ?? throw new ArgumentNullException("PassWord is null");
|
||||||
|
//this.mdataFile = AppDomain.CurrentDomain.BaseDirectory + dataFile;
|
||||||
|
this.mdataFile = dataFile;
|
||||||
|
if (!RWL.ContainsKey(dataFile))
|
||||||
|
{
|
||||||
|
LockName = dataFile;
|
||||||
|
RWL.Add(dataFile, new ClsLock());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
#region 打开/关闭 数据库
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 打开 SQLiteManager 使用的数据库连接
|
||||||
|
/// </summary>
|
||||||
|
public void Open()
|
||||||
|
{
|
||||||
|
if (string.IsNullOrWhiteSpace(mPassWord))
|
||||||
|
{
|
||||||
|
mConn = OpenConnection(this.mdataFile);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
mConn = OpenConnection(this.mdataFile, mPassWord);
|
||||||
|
}
|
||||||
|
Console.WriteLine("The database was opened successfully");
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 关闭连接
|
||||||
|
/// </summary>
|
||||||
|
public void Close()
|
||||||
|
{
|
||||||
|
if (this.mConn != null)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
this.mConn.Close();
|
||||||
|
if (RWL.ContainsKey(LockName))
|
||||||
|
{
|
||||||
|
RWL.Remove(LockName);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
catch
|
||||||
|
{
|
||||||
|
Console.WriteLine("Shutdown failed");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
Console.WriteLine("The database was shut down successfully");
|
||||||
|
}
|
||||||
|
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
#region 事务
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 开始事务
|
||||||
|
/// </summary>
|
||||||
|
public void BeginTrain()
|
||||||
|
{
|
||||||
|
EnsureConnection();
|
||||||
|
DBtrans = mConn.BeginTransaction();
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 提交事务
|
||||||
|
/// </summary>
|
||||||
|
public void DBCommit()
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
DBtrans.Commit();
|
||||||
|
}
|
||||||
|
catch (Exception)
|
||||||
|
{
|
||||||
|
DBtrans.Rollback();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
#region 工具
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 打开一个SQLite数据库文件，如果文件不存在，则创建（无密码）
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="dataFile"></param>
|
||||||
|
/// <returns>SQLiteConnection 类</returns>
|
||||||
|
private SQLiteConnection OpenConnection(string dataFile)
|
||||||
|
{
|
||||||
|
if (dataFile == null)
|
||||||
|
{
|
||||||
|
throw new ArgumentNullException("dataFiledataFile=null");
|
||||||
|
}
|
||||||
|
if (!File.Exists(dataFile))
|
||||||
|
{
|
||||||
|
SQLiteConnection.CreateFile(dataFile);
|
||||||
|
}
|
||||||
|
SQLiteConnection conn = new SQLiteConnection();
|
||||||
|
SQLiteConnectionStringBuilder conStr = new SQLiteConnectionStringBuilder
|
||||||
|
{
|
||||||
|
DataSource = dataFile
|
||||||
|
};
|
||||||
|
conn.ConnectionString = conStr.ToString();
|
||||||
|
conn.Open();
|
||||||
|
return conn;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 打开一个SQLite数据库文件，如果文件不存在，则创建（有密码）
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="dataFile"></param>
|
||||||
|
/// <param name="Password"></param>
|
||||||
|
/// <returns>SQLiteConnection 类</returns>
|
||||||
|
private SQLiteConnection OpenConnection(string dataFile, string Password)
|
||||||
|
{
|
||||||
|
if (dataFile == null)
|
||||||
|
{
|
||||||
|
throw new ArgumentNullException("dataFile=null");
|
||||||
|
}
|
||||||
|
if (!File.Exists(Convert.ToString(dataFile)))
|
||||||
|
{
|
||||||
|
SQLiteConnection.CreateFile(dataFile);
|
||||||
|
}
|
||||||
|
try
|
||||||
|
{
|
||||||
|
SQLiteConnection conn = new SQLiteConnection();
|
||||||
|
SQLiteConnectionStringBuilder conStr = new SQLiteConnectionStringBuilder
|
||||||
|
{
|
||||||
|
DataSource = dataFile,
|
||||||
|
Password = Password
|
||||||
|
};
|
||||||
|
conn.ConnectionString = conStr.ToString();
|
||||||
|
conn.Open();
|
||||||
|
return conn;
|
||||||
|
}
|
||||||
|
catch (Exception)
|
||||||
|
{
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 读取 或 设置 SQLiteManager 使用的数据库连接
|
||||||
|
/// </summary>
|
||||||
|
public SQLiteConnection Connection
|
||||||
|
{
|
||||||
|
get
|
||||||
|
{
|
||||||
|
return mConn;
|
||||||
|
}
|
||||||
|
private set
|
||||||
|
{
|
||||||
|
mConn = value ?? throw new ArgumentNullException();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 确保数据库是连接状态
|
||||||
|
/// </summary>
|
||||||
|
/// <exception cref="Exception"></exception>
|
||||||
|
protected void EnsureConnection()
|
||||||
|
{
|
||||||
|
if (this.mConn == null)
|
||||||
|
{
|
||||||
|
throw new Exception("SQLiteManager.Connection=null");
|
||||||
|
}
|
||||||
|
if (mConn.State != ConnectionState.Open)
|
||||||
|
{
|
||||||
|
mConn.Open();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 获取数据库文件的路径
|
||||||
|
/// </summary>
|
||||||
|
/// <returns></returns>
|
||||||
|
public string GetDataFile()
|
||||||
|
{
|
||||||
|
return this.mdataFile;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 判断表 table 是否存在
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="table"></param>
|
||||||
|
/// <returns>存在返回true，否则返回false</returns>
|
||||||
|
public bool TableExists(string table)
|
||||||
|
{
|
||||||
|
if (table == null)
|
||||||
|
{
|
||||||
|
throw new ArgumentNullException("table=null");
|
||||||
|
}
|
||||||
|
EnsureConnection();
|
||||||
|
SQLiteDataReader reader = ExecuteReader("SELECT count(*) as c FROM sqlite_master WHERE type='table' AND name=@tableName ", new SQLiteParameter[] { new SQLiteParameter("tableName", table) });
|
||||||
|
if (reader == null)
|
||||||
|
{
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
reader.Read();
|
||||||
|
int c = reader.GetInt32(0);
|
||||||
|
reader.Close();
|
||||||
|
reader.Dispose();
|
||||||
|
//return false;
|
||||||
|
return c == 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// VACUUM 命令（通过复制主数据库中的内容到一个临时数据库文件，然后清空主数据库，并从副本中重新载入原始的数据库文件）
|
||||||
|
/// </summary>
|
||||||
|
/// <returns></returns>
|
||||||
|
public bool Vacuum()
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
using (SQLiteCommand Command = new SQLiteCommand("VACUUM", Connection))
|
||||||
|
{
|
||||||
|
Command.ExecuteNonQuery();
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
catch (System.Data.SQLite.SQLiteException)
|
||||||
|
{
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
#region 执行SQL
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 执行SQL, 并返回 SQLiteDataReader 对象结果
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="sql"></param>
|
||||||
|
/// <param name="paramArr">null 表示无参数</param>
|
||||||
|
/// <returns></returns>
|
||||||
|
public SQLiteDataReader ExecuteReader(string sql, SQLiteParameter[] paramArr)
|
||||||
|
{
|
||||||
|
if (sql == null)
|
||||||
|
{
|
||||||
|
throw new ArgumentNullException("sql=null");
|
||||||
|
}
|
||||||
|
EnsureConnection();
|
||||||
|
using (RWL[LockName].Read())
|
||||||
|
{
|
||||||
|
using (SQLiteCommand cmd = new SQLiteCommand(sql, Connection))
|
||||||
|
{
|
||||||
|
if (paramArr != null)
|
||||||
|
{
|
||||||
|
cmd.Parameters.AddRange(paramArr);
|
||||||
|
}
|
||||||
|
try
|
||||||
|
{
|
||||||
|
SQLiteDataReader reader = cmd.ExecuteReader();
|
||||||
|
cmd.Parameters.Clear();
|
||||||
|
return reader;
|
||||||
|
}
|
||||||
|
catch (Exception)
|
||||||
|
{
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 执行查询，并返回dataset对象
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="sql">SQL查询语句</param>
|
||||||
|
/// <param name="paramArr">参数数组</param>
|
||||||
|
/// <returns></returns>
|
||||||
|
public DataSet ExecuteDataSet(string sql, SQLiteParameter[] paramArr)
|
||||||
|
{
|
||||||
|
if (sql == null)
|
||||||
|
{
|
||||||
|
throw new ArgumentNullException("sql=null");
|
||||||
|
}
|
||||||
|
this.EnsureConnection();
|
||||||
|
using (RWL[LockName].Read())
|
||||||
|
{
|
||||||
|
using (SQLiteCommand cmd = new SQLiteCommand(sql, this.Connection))
|
||||||
|
{
|
||||||
|
if (paramArr != null)
|
||||||
|
{
|
||||||
|
cmd.Parameters.AddRange(paramArr);
|
||||||
|
}
|
||||||
|
try
|
||||||
|
{
|
||||||
|
SQLiteDataAdapter da = new SQLiteDataAdapter();
|
||||||
|
DataSet ds = new DataSet();
|
||||||
|
da.SelectCommand = cmd;
|
||||||
|
da.Fill(ds);
|
||||||
|
cmd.Parameters.Clear();
|
||||||
|
da.Dispose();
|
||||||
|
return ds;
|
||||||
|
}
|
||||||
|
catch (Exception)
|
||||||
|
{
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 执行SQL查询，并返回dataset对象。
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="strTable">映射源表的名称</param>
|
||||||
|
/// <param name="sql">SQL语句</param>
|
||||||
|
/// <param name="paramArr">SQL参数数组</param>
|
||||||
|
/// <returns></returns>
|
||||||
|
public DataSet ExecuteDataSet(string strTable, string sql, SQLiteParameter[] paramArr)
|
||||||
|
{
|
||||||
|
if (sql == null)
|
||||||
|
{
|
||||||
|
throw new ArgumentNullException("sql=null");
|
||||||
|
}
|
||||||
|
this.EnsureConnection();
|
||||||
|
using (RWL[LockName].Read())
|
||||||
|
{
|
||||||
|
using (SQLiteCommand cmd = new SQLiteCommand(sql, this.Connection))
|
||||||
|
{
|
||||||
|
if (paramArr != null)
|
||||||
|
{
|
||||||
|
cmd.Parameters.AddRange(paramArr);
|
||||||
|
}
|
||||||
|
try
|
||||||
|
{
|
||||||
|
SQLiteDataAdapter da = new SQLiteDataAdapter();
|
||||||
|
DataSet ds = new DataSet();
|
||||||
|
da.SelectCommand = cmd;
|
||||||
|
da.Fill(ds, strTable);
|
||||||
|
cmd.Parameters.Clear();
|
||||||
|
da.Dispose();
|
||||||
|
return ds;
|
||||||
|
}
|
||||||
|
catch (Exception)
|
||||||
|
{
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 执行SQL，返回受影响的行数，可用于执行表创建语句，paramArr == null 表示无参数
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="sql"></param>
|
||||||
|
/// <returns></returns>
|
||||||
|
public int ExecuteNonQuery(string sql, SQLiteParameter[] paramArr)
|
||||||
|
{
|
||||||
|
if (sql == null)
|
||||||
|
{
|
||||||
|
throw new ArgumentNullException("sql=null");
|
||||||
|
}
|
||||||
|
this.EnsureConnection();
|
||||||
|
using (RWL[LockName].Read())
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
using (SQLiteCommand cmd = new SQLiteCommand(sql, Connection))
|
||||||
|
{
|
||||||
|
if (paramArr != null)
|
||||||
|
{
|
||||||
|
foreach (SQLiteParameter p in paramArr)
|
||||||
|
{
|
||||||
|
cmd.Parameters.Add(p);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
int c = cmd.ExecuteNonQuery();
|
||||||
|
cmd.Parameters.Clear();
|
||||||
|
return c;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
catch (SQLiteException)
|
||||||
|
{
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 执行SQL，返回结果集第一行，如果结果集为空，那么返回空 List(List.Count=0)，
|
||||||
|
/// rowWrapper = null 时，使用 WrapRowToDictionary
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="sql"></param>
|
||||||
|
/// <param name="paramArr"></param>
|
||||||
|
/// <returns></returns>
|
||||||
|
public object ExecuteScalar(string sql, SQLiteParameter[] paramArr)
|
||||||
|
{
|
||||||
|
if (sql == null)
|
||||||
|
{
|
||||||
|
throw new ArgumentNullException("sql=null");
|
||||||
|
}
|
||||||
|
this.EnsureConnection();
|
||||||
|
using (RWL[LockName].Read())
|
||||||
|
{
|
||||||
|
using (SQLiteCommand cmd = new SQLiteCommand(sql, Connection))
|
||||||
|
{
|
||||||
|
if (paramArr != null)
|
||||||
|
{
|
||||||
|
cmd.Parameters.AddRange(paramArr);
|
||||||
|
}
|
||||||
|
try
|
||||||
|
{
|
||||||
|
object reader = cmd.ExecuteScalar();
|
||||||
|
cmd.Parameters.Clear();
|
||||||
|
cmd.Dispose();
|
||||||
|
return reader;
|
||||||
|
}
|
||||||
|
catch (Exception)
|
||||||
|
{
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 查询一行记录，无结果时返回 null，conditionCol = null 时将忽略条件，直接执行 select * from table
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="table">表名</param>
|
||||||
|
/// <param name="conditionCol"></param>
|
||||||
|
/// <param name="conditionVal"></param>
|
||||||
|
/// <returns></returns>
|
||||||
|
public object QueryOne(string table, string conditionCol, object conditionVal)
|
||||||
|
{
|
||||||
|
if (table == null)
|
||||||
|
{
|
||||||
|
throw new ArgumentNullException("table=null");
|
||||||
|
}
|
||||||
|
this.EnsureConnection();
|
||||||
|
string sql = "select * from " + table;
|
||||||
|
if (conditionCol != null)
|
||||||
|
{
|
||||||
|
sql += " where " + conditionCol + "=@" + conditionCol;
|
||||||
|
}
|
||||||
|
object result = ExecuteScalar(sql, new SQLiteParameter[] { new SQLiteParameter(conditionCol, conditionVal) });
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
#region 增 删 改
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 执行 insert into 语句
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="table"></param>
|
||||||
|
/// <param name="entity"></param>
|
||||||
|
/// <returns></returns>
|
||||||
|
public int InsertData(string table, Dictionary<string, object> entity)
|
||||||
|
{
|
||||||
|
if (table == null)
|
||||||
|
{
|
||||||
|
throw new ArgumentNullException("table=null");
|
||||||
|
}
|
||||||
|
this.EnsureConnection();
|
||||||
|
string sql = BuildInsert(table, entity);
|
||||||
|
return this.ExecuteNonQuery(sql, BuildParamArray(entity));
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 执行 update 语句，注意：如果 where = null，那么 whereParams 也为 null，
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="table">表名</param>
|
||||||
|
/// <param name="entity">要修改的列名和列名的值</param>
|
||||||
|
/// <param name="where">查找符合条件的列</param>
|
||||||
|
/// <param name="whereParams">where条件中参数的值</param>
|
||||||
|
/// <returns></returns>
|
||||||
|
public int Update(string table, Dictionary<string, object> entity, string where, SQLiteParameter[] whereParams)
|
||||||
|
{
|
||||||
|
if (table == null)
|
||||||
|
{
|
||||||
|
throw new ArgumentNullException("table=null");
|
||||||
|
}
|
||||||
|
this.EnsureConnection();
|
||||||
|
string sql = BuildUpdate(table, entity);
|
||||||
|
SQLiteParameter[] parameter = BuildParamArray(entity);
|
||||||
|
if (where != null)
|
||||||
|
{
|
||||||
|
sql += " where " + where;
|
||||||
|
if (whereParams != null)
|
||||||
|
{
|
||||||
|
SQLiteParameter[] newArr = new SQLiteParameter[(parameter.Length + whereParams.Length)];
|
||||||
|
Array.Copy(parameter, newArr, parameter.Length);
|
||||||
|
Array.Copy(whereParams, 0, newArr, parameter.Length, whereParams.Length);
|
||||||
|
parameter = newArr;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return this.ExecuteNonQuery(sql, parameter);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 执行 delete from table 语句，where不必包含'where'关键字，where = null 时将忽略 whereParams
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="table"></param>
|
||||||
|
/// <param name="where"></param>
|
||||||
|
/// <param name="whereParams"></param>
|
||||||
|
/// <returns></returns>
|
||||||
|
public int Delete(string table, string where, SQLiteParameter[] whereParams)
|
||||||
|
{
|
||||||
|
if (table == null)
|
||||||
|
{
|
||||||
|
throw new ArgumentNullException("table=null");
|
||||||
|
}
|
||||||
|
this.EnsureConnection();
|
||||||
|
string sql = "delete from " + table + " ";
|
||||||
|
if (where != null)
|
||||||
|
{
|
||||||
|
sql += "where " + where;
|
||||||
|
}
|
||||||
|
return ExecuteNonQuery(sql, whereParams);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 将 Dictionary 类型数据 转换为 SQLiteParameter[] 类型
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="entity"></param>
|
||||||
|
/// <returns></returns>
|
||||||
|
private SQLiteParameter[] BuildParamArray(Dictionary<string, object> entity)
|
||||||
|
{
|
||||||
|
List<SQLiteParameter> list = new List<SQLiteParameter>();
|
||||||
|
foreach (string key in entity.Keys)
|
||||||
|
{
|
||||||
|
list.Add(new SQLiteParameter(key, entity[key]));
|
||||||
|
}
|
||||||
|
if (list.Count == 0)
|
||||||
|
{
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
return list.ToArray();
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 将 Dictionary 类型数据 转换为 插入数据 的 SQL语句
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="table">表名</param>
|
||||||
|
/// <param name="entity">字典</param>
|
||||||
|
/// <returns></returns>
|
||||||
|
private string BuildInsert(string table, Dictionary<string, object> entity)
|
||||||
|
{
|
||||||
|
StringBuilder buf = new StringBuilder();
|
||||||
|
buf.Append("insert into ").Append(table);
|
||||||
|
buf.Append(" (");
|
||||||
|
foreach (string key in entity.Keys)
|
||||||
|
{
|
||||||
|
buf.Append(key).Append(",");
|
||||||
|
}
|
||||||
|
buf.Remove(buf.Length - 1, 1); // 移除最后一个,
|
||||||
|
buf.Append(") ");
|
||||||
|
buf.Append("values(");
|
||||||
|
foreach (string key in entity.Keys)
|
||||||
|
{
|
||||||
|
buf.Append("@").Append(key).Append(","); // 创建一个参数
|
||||||
|
}
|
||||||
|
buf.Remove(buf.Length - 1, 1);
|
||||||
|
buf.Append(") ");
|
||||||
|
|
||||||
|
return buf.ToString();
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 将 Dictionary 类型数据 转换为 修改数据 的 SQL语句
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="table">表名</param>
|
||||||
|
/// <param name="entity">字典</param>
|
||||||
|
/// <returns></returns>
|
||||||
|
private string BuildUpdate(string table, Dictionary<string, object> entity)
|
||||||
|
{
|
||||||
|
StringBuilder buf = new StringBuilder();
|
||||||
|
buf.Append("update ").Append(table).Append(" set ");
|
||||||
|
foreach (string key in entity.Keys)
|
||||||
|
{
|
||||||
|
buf.Append(key).Append("=").Append("@").Append(key).Append(",");
|
||||||
|
}
|
||||||
|
buf.Remove(buf.Length - 1, 1);
|
||||||
|
buf.Append(" ");
|
||||||
|
return buf.ToString();
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 将 DataTable 转换为 Dictionary 类型数据
|
||||||
|
/// </summary>
|
||||||
|
public Dictionary<string, object> DataTableToDictionary(DataTable dataTable)
|
||||||
|
{
|
||||||
|
Dictionary<string, object> result = new Dictionary<string, object>();
|
||||||
|
if (dataTable != null)
|
||||||
|
{
|
||||||
|
foreach (DataRow dataRow in dataTable.Rows)
|
||||||
|
{
|
||||||
|
foreach (DataColumn dataColumn in dataTable.Columns)
|
||||||
|
{
|
||||||
|
result.Add(dataColumn.ColumnName, dataRow[dataColumn].ToString());
|
||||||
|
//result = Console.WriteLine(dataRow[dataColumn].ToString());
|
||||||
|
//result.Add(dataColumn.ColumnName, dataRow[dataColumn].ToString())(new RepeatDictionaryComparer());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
result = null;
|
||||||
|
}
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in new issue
Block a user