📄 sqldataprovider.cs
字号:
return rInt;
}
/// <summary>
/// 返回sys_RoleApplicationTable实体类的ArrayList对象
/// </summary>
/// <param name="qp">查询类</param>
/// <param name="RecordCount">返回记录总数</param>
/// <returns>sys_RoleApplicationTable实体类的ArrayList对象</returns>
public override ArrayList sys_RoleApplicationList(QueryParam qp, out int RecordCount)
{
PopulateDelegate mypd = new PopulateDelegate(base.Populatesys_RoleApplication);
return this.GetObjectList(mypd, qp, out RecordCount);
}
#endregion
#region "sys_UserRoles - SQLDataProvider"
/// <summary>
/// 新增/删除/修改 sys_UserRoles
/// </summary>
/// <param name="fam">sys_UserRolesTable实体类</param>
/// <returns>返回0操正常</returns>
public override int sys_UserRolesInsertUpdate(sys_UserRolesTable fam)
{
int rInt = 0;
using (SqlConnection Conn = GetSqlConnection())
{
SqlCommand cmd = new SqlCommand("sys_UserRolesInsertUpdateDelete", Conn);
cmd.CommandType = CommandType.StoredProcedure;
//设置参数
cmd.Parameters.Add("@DB_Option_Action_", SqlDbType.NVarChar).Value = fam.DB_Option_Action_; //操作方法 Insert:增加 Update:修改 Delete:删除 Disp:显示单笔记录
cmd.Parameters.Add("@R_UserID", SqlDbType.Int).Value = fam.R_UserID; //用户ID与sys_User表中UserID相关
cmd.Parameters.Add("@R_RoleID", SqlDbType.Int).Value = fam.R_RoleID; //用户所属角色ID与Sys_Roles关联
Conn.Open();
rInt = Convert.ToInt32(cmd.ExecuteScalar());
cmd.Dispose();
Conn.Dispose();
Conn.Close();
}
return rInt;
}
/// <summary>
/// 返回sys_UserRolesTable实体类的ArrayList对象
/// </summary>
/// <param name="qp">查询类</param>
/// <param name="RecordCount">返回记录总数</param>
/// <returns>sys_UserRolesTable实体类的ArrayList对象</returns>
public override ArrayList sys_UserRolesList(QueryParam qp, out int RecordCount)
{
PopulateDelegate mypd = new PopulateDelegate(base.Populatesys_UserRoles);
return this.GetObjectList(mypd, qp, out RecordCount);
}
#endregion
#region "sys_SystemInfo - SQLDataProvider"
/// <summary>
/// 新增/删除/修改 sys_SystemInfo
/// </summary>
/// <param name="fam">sys_SystemInfoTable实体类</param>
/// <returns>返回0操正常</returns>
public override int sys_SystemInfoInsertUpdate(sys_SystemInfoTable fam)
{
int rInt = 0;
using (SqlConnection Conn = GetSqlConnection())
{
SqlCommand cmd = new SqlCommand("sys_SystemInfoInsertUpdateDelete", Conn);
cmd.CommandType = CommandType.StoredProcedure;
//设置参数
cmd.Parameters.Add("@DB_Option_Action_", SqlDbType.NVarChar).Value = fam.DB_Option_Action_; //操作方法 Insert:增加 Update:修改 Delete:删除 Disp:显示单笔记录
cmd.Parameters.Add("@SystemID", SqlDbType.Int).Value = fam.SystemID; //自动ID
cmd.Parameters.Add("@S_Name", SqlDbType.NVarChar).Value = fam.S_Name; //系统名称
cmd.Parameters.Add("@S_Version", SqlDbType.NVarChar).Value = fam.S_Version; //版本号
cmd.Parameters.Add("@S_Licensed", SqlDbType.VarChar).Value = fam.S_Licensed; //序列号
cmd.Parameters.Add("@S_SystemConfigData", SqlDbType.Image).Value = FrameSystemInfo.Serializable_sys_ConfigDataTable(fam.S_SystemConfigData); //系统配置信息
Conn.Open();
rInt = Convert.ToInt32(cmd.ExecuteScalar());
cmd.Dispose();
Conn.Dispose();
Conn.Close();
}
return rInt;
}
/// <summary>
/// 返回sys_SystemInfoTable实体类的ArrayList对象
/// </summary>
/// <param name="qp">查询类</param>
/// <param name="RecordCount">返回记录总数</param>
/// <returns>sys_SystemInfoTable实体类的ArrayList对象</returns>
public override ArrayList sys_SystemInfoList(QueryParam qp, out int RecordCount)
{
PopulateDelegate mypd = new PopulateDelegate(base.Populatesys_SystemInfo);
return this.GetObjectList(mypd, qp, out RecordCount);
}
#endregion
#region "sys_Online - SQLDataProvider"
/// <summary>
/// 新增/删除/修改 sys_Online
/// </summary>
/// <param name="fam">sys_OnlineTable实体类</param>
/// <returns>返回0操正常</returns>
public override int sys_OnlineInsertUpdate(sys_OnlineTable fam)
{
int rInt = 0;
using (SqlConnection Conn = GetSqlConnection())
{
SqlCommand cmd = new SqlCommand("sys_OnlineInsertUpdateDelete", Conn);
cmd.CommandType = CommandType.StoredProcedure;
//设置参数
cmd.Parameters.Add("@DB_Option_Action_", SqlDbType.NVarChar).Value = fam.DB_Option_Action_; //操作方法 Insert:增加 Update:修改 Delete:删除 Disp:显示单笔记录
cmd.Parameters.Add("@OnlineID", SqlDbType.Int).Value = fam.OnlineID; //自动ID
cmd.Parameters.Add("@O_SessionID", SqlDbType.VarChar).Value = fam.O_SessionID; //用户SessionID
cmd.Parameters.Add("@O_UserName", SqlDbType.NVarChar).Value = fam.O_UserName; //用户名
cmd.Parameters.Add("@O_Ip", SqlDbType.VarChar).Value = fam.O_Ip; //用户IP地址
cmd.Parameters.Add("@O_LoginTime", SqlDbType.DateTime).Value = fam.O_LoginTime; //登陆时间
cmd.Parameters.Add("@O_LastTime", SqlDbType.DateTime).Value = fam.O_LastTime; //最后访问时间
cmd.Parameters.Add("@O_LastUrl", SqlDbType.NVarChar).Value = fam.O_LastUrl; //最后请求网站
Conn.Open();
rInt = Convert.ToInt32(cmd.ExecuteScalar());
cmd.Dispose();
Conn.Dispose();
Conn.Close();
}
return rInt;
}
/// <summary>
/// 返回sys_OnlineTable实体类的ArrayList对象
/// </summary>
/// <param name="qp">查询类</param>
/// <param name="RecordCount">返回记录总数</param>
/// <returns>sys_OnlineTable实体类的ArrayList对象</returns>
public override ArrayList sys_OnlineList(QueryParam qp, out int RecordCount)
{
PopulateDelegate mypd = new PopulateDelegate(base.Populatesys_Online);
return this.GetObjectList(mypd, qp, out RecordCount);
}
#endregion
#region "常用函数"
/// <summary>
/// 获取表中字段值
/// </summary>
/// <param name="table_name">表名</param>
/// <param name="table_fileds">字段</param>
/// <param name="where_fileds">查询条件字段</param>
/// <param name="where_value">查询值</param>
/// <returns></returns>
public override string get_table_fileds(string table_name, string table_fileds, string where_fileds, string where_value)
{
where_value = Common.inSQL(where_value);
string rStr = "";
using (SqlConnection Conn = GetSqlConnection())
{
string strSql = string.Format("select {0} from {1} where upper({2})='{3}'", table_fileds, table_name, where_fileds, where_value);
SqlCommand cmd = new SqlCommand(strSql, Conn);
cmd.CommandType = CommandType.Text;
Conn.Open();
SqlDataReader dr = cmd.ExecuteReader();
if (dr.Read())
{
rStr = dr[0].ToString();
}
dr.Close();
dr.Dispose();
cmd.Dispose();
Conn.Dispose();
Conn.Close();
}
return rStr;
}
#endregion
#region "更新表中字段值"
/// <summary>
/// 更新表中字段值
/// </summary>
/// <param name="Table">表名</param>
/// <param name="Table_FiledsValue">需要更新值(不用带Set)</param>
/// <param name="Wheres">更新条件(不用带Where)</param>
/// <returns></returns>
public override int Update_Table_Fileds(string Table, string Table_FiledsValue, string Wheres)
{
int rInt = 0;
using (SqlConnection Conn = GetSqlConnection())
{
string strSql = string.Format("Update {0} Set {1} Where {2}", Table,Table_FiledsValue,Wheres);
SqlCommand cmd = new SqlCommand(strSql, Conn);
cmd.CommandType = CommandType.Text;
Conn.Open();
rInt = Convert.ToInt32(cmd.ExecuteScalar());
cmd.Dispose();
Conn.Dispose();
Conn.Close();
}
return rInt;
}
#endregion
#region 公共查询数据函数Sql存储过程版
/// <summary>
/// 公共查询数据函数Sql存储过程版
/// </summary>
/// <param name="pd">委托对象</param>
/// <param name="pp">查询字符串</param>
/// <param name="RecordCount">返回记录总数</param>
/// <returns>返回记录集ArrayList</returns>
private ArrayList GetObjectList(PopulateDelegate pd, QueryParam pp, out int RecordCount)
{
ArrayList lst = new ArrayList();
RecordCount = 0;
using (SqlConnection conn = GetSqlConnection())
{
SqlCommand cmd = new SqlCommand("SupesoftPage", conn);
cmd.CommandType = CommandType.StoredProcedure;
// 设置参数
cmd.Parameters.Add("@TableName", SqlDbType.NVarChar, 500).Value = pp.TableName;
cmd.Parameters.Add("@ReturnFields", SqlDbType.NVarChar, 500).Value = pp.ReturnFields;
cmd.Parameters.Add("@Where", SqlDbType.NVarChar, 500).Value = pp.Where;
cmd.Parameters.Add("@PageIndex", SqlDbType.Int).Value = pp.PageIndex;
cmd.Parameters.Add("@PageSize", SqlDbType.Int).Value = pp.PageSize;
cmd.Parameters.Add("@Orderfld", SqlDbType.NVarChar, 200).Value = pp.Orderfld;
cmd.Parameters.Add("@OrderType", SqlDbType.Int).Value = pp.OrderType;
// 执行
conn.Open();
SqlDataReader dr = cmd.ExecuteReader();
while (dr.Read())
{
lst.Add(pd(dr));
}
// 取记录总数 及页数
if (dr.NextResult())
{
if (dr.Read())
{
RecordCount = Convert.ToInt32(dr["RecordCount"]);
}
}
dr.Close();
cmd.Dispose();
conn.Close();
}
return lst;
}
#endregion
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -