📄 dclassmovement.cs
字号:
if (searcher.MovementDateIsValid)
{
condition += " and Movement_Date=@Movement_Date_C";
cmd.Parameters.Add(new SqlParameter("@Movement_Date_C", searcher.MovementDate));
}
if (searcher.MovementTimeIsValid)
{
condition += " and movement_Time=@movement_Time_C";
cmd.Parameters.Add(new SqlParameter("@movement_Time_C", searcher.MovementTime));
}
if (searcher.IsAmIsValid)
{
condition += " and is_am=@is_am_C";
cmd.Parameters.Add(new SqlParameter("@is_am_C", searcher.IsAm));
}
if (condition != string.Empty)
{
condition = " where" + condition.Substring(4);
}
cmd.CommandText = "update ClassMovement set " + updateString.Substring(1) + condition;
result = cmd.ExecuteNonQuery();
}
}
return result;
}
/// <summary>
/// 根据查询对象构建过滤条件并使用事务的更新方法
/// </summary>
/// <param name="connection">实现共享Command的对象</param>
/// <param name="searcher">查询对象</param>
/// <param name="newValues">要更新的新值</param>
/// <returns>影响的记录行数</returns>
public int Update(IConnection connection, ClassMovementSearcher searcher, ClassMovementSearcher newValues)
{
string updateString = string.Empty;
string condition = string.Empty;
SqlCommand cmd = connection.Command as SqlCommand;
cmd.Parameters.Clear();
if (newValues.ClassMovementIDIsValid)
{
updateString += ",Class_Movement_ID=@Class_Movement_ID_V";
cmd.Parameters.Add(new SqlParameter("@Class_Movement_ID_V", newValues.ClassMovementID));
}
if (newValues.ClassIDIsValid)
{
updateString += ",Class_ID=@Class_ID_V";
cmd.Parameters.Add(new SqlParameter("@Class_ID_V", newValues.ClassID));
}
if (newValues.MovementIDIsValid)
{
updateString += ",Movement_ID=@Movement_ID_V";
cmd.Parameters.Add(new SqlParameter("@Movement_ID_V", newValues.MovementID));
}
if (newValues.MovementDateIsValid)
{
updateString += ",Movement_Date=@Movement_Date_V";
cmd.Parameters.Add(new SqlParameter("@Movement_Date_V", newValues.MovementDate));
}
if (newValues.MovementTimeIsValid)
{
updateString += ",movement_Time=@movement_Time_V";
cmd.Parameters.Add(new SqlParameter("@movement_Time_V", newValues.MovementTime));
}
if (newValues.IsAmIsValid)
{
updateString += ",is_am=@is_am_V";
cmd.Parameters.Add(new SqlParameter("@is_am_V", newValues.IsAm));
}
if (searcher.ClassMovementIDIsValid)
{
condition += " and Class_Movement_ID=@Class_Movement_ID_C";
cmd.Parameters.Add(new SqlParameter("@Class_Movement_ID_C", searcher.ClassMovementID));
}
if (searcher.ClassIDIsValid)
{
condition += " and Class_ID=@Class_ID_C";
cmd.Parameters.Add(new SqlParameter("@Class_ID_C", searcher.ClassID));
}
if (searcher.MovementIDIsValid)
{
condition += " and Movement_ID=@Movement_ID_C";
cmd.Parameters.Add(new SqlParameter("@Movement_ID_C", searcher.MovementID));
}
if (searcher.MovementDateIsValid)
{
condition += " and Movement_Date=@Movement_Date_C";
cmd.Parameters.Add(new SqlParameter("@Movement_Date_C", searcher.MovementDate));
}
if (searcher.MovementTimeIsValid)
{
condition += " and movement_Time=@movement_Time_C";
cmd.Parameters.Add(new SqlParameter("@movement_Time_C", searcher.MovementTime));
}
if (searcher.IsAmIsValid)
{
condition += " and is_am=@is_am_C";
cmd.Parameters.Add(new SqlParameter("@is_am_C", searcher.IsAm));
}
if (condition != string.Empty)
{
condition = " where" + condition.Substring(4);
}
cmd.CommandText = "update ClassMovement set " + updateString.Substring(1) + condition;
return cmd.ExecuteNonQuery();
}
#endregion
#region 查询实体集合
/// <summary>
/// 根据查询对象构建过滤条件查询
/// </summary>
/// <param name="searcher">查询对象</param>
/// <returns>实体类对象列表</returns>
public ArrayList Select(ClassMovementSearcher searcher)
{
ArrayList entities = new ArrayList();
string connectionString = System.Configuration.ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
using (SqlCommand cmd = conn.CreateCommand())
{
entities = Select(cmd, searcher);
}
}
return entities;
}
/// <summary>
/// 使用事务并且依据查询对象构建过滤条件查询
/// </summary>
/// <param name="connection">实现共享Command的对象</param>
/// <param name="searcher">查询对象</param>
/// <returns>实体类对象列表</returns>
public ArrayList Select(IConnection connection, ClassMovementSearcher searcher)
{
SqlCommand cmd = connection.Command as SqlCommand;
return Select(cmd, searcher);
}
public ArrayList Select(SqlCommand command, ClassMovementSearcher searcher)
{
string condition = string.Empty;
command.Parameters.Clear();
ArrayList entities = new ArrayList();
if (searcher.ClassMovementIDIsValid)
{
condition += " and Class_Movement_ID=@Class_Movement_ID_C";
command.Parameters.Add(new SqlParameter("@Class_Movement_ID_C", searcher.ClassMovementID));
}
if (searcher.ClassIDIsValid)
{
condition += " and Class_ID=@Class_ID_C";
command.Parameters.Add(new SqlParameter("@Class_ID_C", searcher.ClassID));
}
if (searcher.MovementIDIsValid)
{
condition += " and Movement_ID=@Movement_ID_C";
command.Parameters.Add(new SqlParameter("@Movement_ID_C", searcher.MovementID));
}
if (searcher.MovementDateIsValid)
{
condition += " and Movement_Date=@Movement_Date_C";
command.Parameters.Add(new SqlParameter("@Movement_Date_C", searcher.MovementDate));
}
if (searcher.MovementTimeIsValid)
{
condition += " and movement_Time=@movement_Time_C";
command.Parameters.Add(new SqlParameter("@movement_Time_C", searcher.MovementTime));
}
if (searcher.IsAmIsValid)
{
condition += " and is_am=@is_am_C";
command.Parameters.Add(new SqlParameter("@is_am_C", searcher.IsAm));
}
if (condition != string.Empty)
{
condition = " where" + condition.Substring(4);
}
command.CommandText = "select * from ClassMovement" + condition;
return ExcuteSelectCommand(command);
}
/// <summary>
/// 执行Command获取对象列表
/// </summary>
/// <param name="cmd">Command对象</param>
/// <returns>实体类对象列表</returns>
private ArrayList ExcuteSelectCommand(SqlCommand cmd)
{
ArrayList entities = new ArrayList();
using (SqlDataReader dr = cmd.ExecuteReader())
{
while (dr.Read())
{
ClassMovement entity = DataReaderToEntity(dr);
entities.Add(entity);
}
}
SetForeignKeyEntity(cmd, ref entities);
return entities;
}
private void SetForeignKeyEntity(SqlCommand command, ref ArrayList entities)
{
//由外键获取相关实体
DClass dClass = new DClass();
DMovement dMovement = new DMovement();
foreach (ClassMovement entity in entities)
{
entity.Class = dClass.SelectSingle(command, entity.ClassID);
entity.Movement = dMovement.SelectSingle(command, entity.MovementID);
}
}
/// <summary>
/// 查询所有实体
/// </summary>
/// <returns>实体类对象列表</returns>
public ArrayList Select()
{
ArrayList entities = new ArrayList();
string connectionString = System.Configuration.ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
using (SqlCommand cmd = conn.CreateCommand())
{
cmd.CommandText = "select * from ClassMovement";
entities = ExcuteSelectCommand(cmd);
}
return entities;
}
}
/// <summary>
/// 使用事务查询查询所有实体
/// </summary>
/// <param name="connection">实现共享Command的对象</param>
/// <param name="searcher">查询对象</param>
/// <returns>实体类对象列表</returns>
public ArrayList Select(IConnection connection)
{
ArrayList entities = new ArrayList();
SqlCommand cmd = connection.Command as SqlCommand;
cmd.Parameters.Clear();
cmd.CommandText = "select * from ClassMovement";
return ExcuteSelectCommand(cmd);
}
#endregion
#region 查询单个实体
/// <summary>
/// 按主键字段查询特定实体
/// </summary>
/// <param name="pkValue">主键值</param>
/// <returns>实体类对象</returns>
public ClassMovement SelectSingle(object pkValue)
{
ClassMovement entity = null;
string connectionString = System.Configuration.ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
using (SqlCommand cmd = conn.CreateCommand())
{
entity = SelectSingle(cmd, pkValue);
}
}
return entity;
}
/// <summary>
/// 使用事务并按主键字段查询特定实体
/// </summary>
/// <param name="pkValue">主键值</param>
/// <returns>实体类对象</returns>
public ClassMovement SelectSingle(IConnection connection, object pkValue)
{
SqlCommand cmd = connection.Command as SqlCommand;
return SelectSingle(cmd, pkValue);
}
public ClassMovement SelectSingle(SqlCommand command, object pkValue)
{
ClassMovement entity = null;
command.Parameters.Clear();
command.CommandText = "select * from ClassMovement where Class_Movement_ID=@pk";
command.Parameters.Add(new SqlParameter("@pk", pkValue));
using (SqlDataReader dr = command.ExecuteReader())
{
if (dr.Read())
entity = DataReaderToEntity(dr);
}
//由外键获取相关实体
DClass dClass = new DClass();
DMovement dMovement = new DMovement();
entity.Class = dClass.SelectSingle(command, entity.ClassID);
entity.Movement = dMovement.SelectSingle(command, entity.MovementID);
return entity;
}
#endregion
/// <summary>
/// 从DataReader中取出值生成实体对象
/// </summary>
/// <param name="searcher">查询对象</param>
/// <returns>过滤条件字符串</returns>
private ClassMovement DataReaderToEntity(SqlDataReader dr)
{
ClassMovement entity = new ClassMovement();
if (dr["Class_Movement_ID"] != System.DBNull.Value)
{
entity.ClassMovementID = Convert.ToInt32(dr["Class_Movement_ID"]);
}
if (dr["Class_ID"] != System.DBNull.Value)
{
entity.ClassID = Convert.ToInt32(dr["Class_ID"]);
}
if (dr["Movement_ID"] != System.DBNull.Value)
{
entity.MovementID = Convert.ToInt32(dr["Movement_ID"]);
}
if (dr["Movement_Date"] != System.DBNull.Value)
{
entity.MovementDate = Convert.ToDateTime(dr["Movement_Date"]);
}
if (dr["movement_Time"] != System.DBNull.Value)
{
entity.MovementTime = Convert.ToDateTime(dr["movement_Time"]);
}
if (dr["is_am"] != System.DBNull.Value)
{
entity.IsAm = Convert.ToBoolean(dr["is_am"]);
}
return entity;
}
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -