using SqlSugar;
using System;
using System.Collections.Generic;
using System.Data;
using Uninpho.DBOperation.Model;
namespace Uninpho.DBOperation.Operation
{
public class SqlQueryable_QX
{
static SqlSugarClient db = Config.GetPgClient();
///
/// 获取曲线信息管理数据
///
public static List Search_QX()
{
List listqx = db.SqlQueryable("select * from \"t_quxian_account\"").ToList();
return listqx;
}
///
/// 获取道岔信息管理数据
///
public static List Search_DC()
{
List listdc = db.SqlQueryable("select * from \"t_daocha_account\"").ToList();
return listdc;
}
///
/// 获取管界信息管理数据
///
public static List Search_GJ()
{
List listgj = db.SqlQueryable("select * from \"t_guanjie_account\" ").ToList();
return listgj;
}
///
/// 获取功率信息管理数据
///
public static List Search_GLData()
{
List listgl = db.SqlQueryable("select * from \"t_gonglv_account\" ").ToList();
return listgl;
}
///
/// 获取缺口信息管理数据
///
public static List Search_QKData()
{
List listqk = db.SqlQueryable("select * from \"t_quekou_account\" ").ToList();
return listqk;
}
///
/// 插入功率信息数据表
///
///
public static void Insertdata_GL(List listgj)
{
db.Insertable(listgj).ExecuteCommand();//get change row count
}
///
/// 插入曲线信息数据表
///
///
public static void Insertdata_QX(List listqx)
{
db.Insertable(listqx).ExecuteCommand();//get change row count
}
///
/// 插入道岔信息数据表
///
///
public static void Insertdata_DC(List listdc)
{
db.Insertable(listdc).ExecuteCommand();//get change row count
}
///
/// 插入管界信息数据表
///
///
public static void Insertdata_GJ(List listgj)
{
db.Insertable(listgj).ExecuteCommand();//get change row count
}
///
/// 获取曲线数据局名信息
///
///
public static void SelectJMInform(ref List qxjminform, ref List dcjminform, ref List qxgjjminform)
{
List qxjminformList = db.SqlQueryable("SELECT t1.juming FROM (SELECT t_quxian_account.juming,COUNT(*) AS cn FROM t_quxian_account GROUP BY t_quxian_account.juming)t1 WHERE t1.cn>0").ToList();
List dcjminformList = db.SqlQueryable("SELECT t1.juming FROM (SELECT t_daocha_account.juming,COUNT(*) AS cn FROM t_daocha_account GROUP BY t_daocha_account.juming)t1 WHERE t1.cn>0").ToList();
List gjjminformList = db.SqlQueryable("SELECT t1.juming FROM (SELECT t_guanjie_account.juming,COUNT(*) AS cn FROM t_guanjie_account GROUP BY t_guanjie_account.juming)t1 WHERE t1.cn>0").ToList();
foreach (var item in qxjminformList)
{
qxjminform.Add(item.Juming);
}
foreach (var item in dcjminformList)
{
dcjminform.Add(item.Juming);
}
foreach (var item in gjjminformList)
{
qxgjjminform.Add(item.Juming);
}
}
//道岔删除行
public static void DCDeleteRows(List deletelist)
{
foreach (var item in deletelist)
{
db.Deleteable().Where(it => it.Id == item.Id).ExecuteCommand();
}
}
//管界删除行
public static void GJDeleteRows(List deletelist)
{
foreach (var item in deletelist)
{
db.Deleteable().Where(it => it.Id == item.Id).ExecuteCommand();
}
}
//道岔删除行
public static void QXDeleteRows(List deletelist)
{
foreach (var item in deletelist)
{
db.Deleteable().Where(it => it.Id == item.Id).ExecuteCommand();
}
}
//功率删除行
public static void GLDeleteRows(List deletelist)
{
foreach (var item in deletelist)
{
db.Deleteable().Where(it => it.Id == item.Id).ExecuteCommand();
}
}
//缺口删除行
public static void QKDeleteRows(List deletelist)
{
foreach (var item in deletelist)
{
db.Deleteable().Where(it => it.Id == item.Id).ExecuteCommand();
}
}
//曲线更新数据
public static void QXUpdataRowData(T_quxian_account rowdata)
{
var qxrest = db.Updateable(rowdata).ExecuteCommand();
}
//道岔更新数据
public static void DCUpdataRowData(T_daocha_account rowdata)
{
var qxrest = db.Updateable(rowdata).ExecuteCommand();
}
//管界更新数据
public static void GJUpdataRowData(T_guanjie_account rowdata)
{
var qxrest = db.Updateable(rowdata).ExecuteCommand();
}
//
//var list = db.SqlQueryable("select * from \"user\"").ToPageList(1, 2, ref total);
////by expression
//var list2 = db.SqlQueryable("select * from \"user\"").Where(it => it.Id == 1).ToPageList(1, 2);
////by sql
//var list3 = db.SqlQueryable("select * from \"user\"").Where("id=@id", new { id = 1 }).ToPageList(1, 2);
}
}