linq2db增删改查

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using LinqToDB;
using System.IO;
using System.Data;
using System.Data.SqlClient;

namespace NICSISDAL
{
public class DBHelper
{
private static string SysPath = System.AppDomain.CurrentDomain.BaseDirectory; //获取程序的基目录
private static string DateType = System.Configuration.ConfigurationManager.AppSettings["DataType"];
///

/// 数据库文件路径
///

public static string DBPath = "";
///

/// 连接字符串配置
///

public static string ConnConfig = "NICSIS";
///

/// 获取连接字符串
///

public static string ConnectionString
{
get
{
string dataType;
dataType = string.Empty;
switch (DateType.ToLower())
{
case "sqltie":
dataType = "SQLiteConString";
break;
case "access":
dataType = "AccessConString";
break;
default:
dataType = "SQLiteConString";
break;
}

string connectionString = System.Configuration.ConfigurationManager.ConnectionStrings[dataType].ConnectionString;
return connectionString;
}
}
static DBHelper()
{
SQLNICSDB.AddConfiguration(ConnConfig, (ConnectionString.Replace("Data Source=", "Data Source=" + SysPath + "\\")).Replace("\\\\", "\\"), new LinqToDB.DataProvider.SQLite.SQLiteDataProvider());
DBPath = ConnectionString.Replace("Data Source=", SysPath + "\\").Replace("\\\\", "\\");
}
//初始化数据库
public static void InitDataBase()
{
string ss = SQLNICSDB.GetConnectionString(DBHelper.ConnConfig);
using (SQLNICSDB sQLNICSDB = new SQLNICSDB(SQLNICSDB.GetConnectionString(DBHelper.ConnConfig)))
{
sQLNICSDB.T_OPI.Delete();
sQLNICSDB.T_OPID.Delete();
sQLNICSDB.T_SERIES.Delete();
}
}
public static bool CheckConnect()
{
try
{
string ss = SQLNICSDB.GetConnectionString(DBHelper.ConnConfig);
using (SQLNICSDB sQLNICSDB = new SQLNICSDB(SQLNICSDB.GetConnectionString(DBHelper.ConnConfig)))
{
sQLNICSDB.T_OPI.FirstOrDefault();
}
return true;
}
catch
{
return false;
}
}

//添加数据
public static void InsertSeries(string

SERIES_NAME, DateTime SERIES_Data=default(DateTime))
{
string ss = SQLNICSDB.GetConnectionString(DBHelper.ConnConfig);
using (SQLNICSDB sQLNICSDB = new SQLNICSDB(SQLNICSDB.GetConnectionString(DBHelper.ConnConfig)))
{
T_SERIES series=new T_SERIES();
if (SERIES_Data == default(DateTime))
series.SERIES_Data = DateTime.Now;
else
series.SERIES_Data = SERIES_Data;
series.SERIES_NAME = SERIES_NAME;

sQLNICSDB.Insert(series);
}

}

//删除数据
public static bool DelSeries(string series_name)
{
bool result = false;
using (SQLNICSDB sQLNICSDB = new SQLNICSDB(SQLNICSDB.GetConnectionString(DBHelper.ConnConfig)))
{
var name = sQLNICSDB.T_SERIES.FirstOrDefault(x => x.SERIES_NAME == series_name);
if (name == null)
{
result = false;
}
else
{
//验证成功,删除
sQLNICSDB.Delete(name);
result = true;
}
}
return result;
}

//修改数据
public static void UpdateSERIES(string SERIES_NAME, DateTime SERIES_Data, int ID)
{

using (SQLNICSDB sQLNICSDB = new SQLNICSDB(SQLNICSDB.GetConnectionString(DBHelper.ConnConfig)))
{
T_SERIES t_Series = sQLNICSDB.T_SERIES.FirstOrDefault(x => x.ID == ID);
if (t_Series != null)
{
t_Series.SERIES_NAME = SERIES_NAME;
t_Series.SERIES_Data = SERIES_Data;
sQLNICSDB.Update(t_Series);
}
}
}

//查询所有的数据
public static List select()
{
using (SQLNICSDB sQLNICSDB = new SQLNICSDB(SQLNICSDB.GetConnectionString(DBHelper.ConnConfig)))
return sQLNICSDB.T_SERIES.ToList();//con.表名.ToList(); ToList()--查找所有
}

}
}