📄 form1.cs
字号:
// alError.Add(strError);
// break;
// case "InsertQuery2":
// strError = "表名:\t\tNEW_TABLE2\r\n";
// strError = strError + "行ID:\t\t" + newDr2["NEW_ID"] + "\r\n";
// strError = strError + "异常信息:\t" + e.Message;
// strError = strError + "\r\n-------------------\r\n\r\n";
// alError.Add(strError);
// break;
// case "InsertQuery3":
// strError = "表名:\t\tNEW_TABLE3\r\n";
// strError = strError + "行ID:\t\t" + newDr3["NEW_ID"] + "\r\n";
// strError = strError + "异常信息:\t" + e.Message;
// strError = strError + "\r\n-------------------\r\n\r\n";
// alError.Add(strError);
// break;
// case "InsertQuery4":
// strError = "表名:\t\tNEW_TABLE4\r\n";
// strError = strError + "行ID:\t\t" + newDr4["NEW_ID"] + "\r\n";
// strError = strError + "异常信息:\t" + e.Message;
// strError = strError + "\r\n-------------------\r\n\r\n";
// alError.Add(strError);
// break;
// default:
// break;
//}
//不带表名的异常串
strError = "行ID:\t\t" + newDr1["NEW_ID"] + "\r\n";
strError = strError + "异常信息:\t" + e.Message;
strError = strError + "\r\n-------------------\r\n\r\n";
alError.Add(strError);
//事务回滚
trans.Rollback();
//判断数据链接是否打开,如果打开则关闭
if (nta1.Connection.State == ConnectionState.Open)
{
//关闭数据库链接
nta1.Connection.Close();
}
}
finally //不管是否出现异常,都做以下处理
{
//判断数据链接是否打开,如果打开则关闭
if (nta1.Connection.State == ConnectionState.Open)
{
//关闭数据库链接
nta1.Connection.Close();
}
}
}
//写错误日志
CreateLogFile(alError);
//显示成功信息
MessageBox.Show("拷贝数据完成!", "成功", MessageBoxButtons.OK, MessageBoxIcon.Information);
}
//-------------------------------------------------------------------------
//自定义函数,用于将原始数据insert到物理数据库表中(每张现今用表对应一个此函数)
//访问类型: private
//返回类型: int
//返回意义: 插入提交后影响的数据行数, 出错则返回-1
//参数类型: 根据现今用表中跟原始数据重复的列决定
//参数意义: 现今用表中跟原始数据重复的列
//-------------------------------------------------------------------------
private int InsertQuery1(decimal NEW_ID, string NEW_XINGMING, string NEW_NIANLING, System.Nullable<bool> NEW_XINGBIE, string NEW_XUELI)
{
//创建数据库访问语句变量,并对其初始化
throw new Exception();
System.Data.SqlClient.SqlCommand command = new System.Data.SqlClient.SqlCommand();
command.Connection = trans.Connection;
command.CommandText = @"INSERT INTO NEW_TABLE1
(NEW_ID, NEW_XINGMING, NEW_NIANLING, NEW_XINGBIE, NEW_XUELI)
VALUES (@NEW_ID,@NEW_XINGMING,@NEW_NIANLING,@NEW_XINGBIE,@NEW_XUELI);
SELECT NEW_ID, NEW_XINGMING, NEW_NIANLING, NEW_XINGBIE, NEW_XUELI, NEW_XUEXIAO, NEW_SHENGRI, NEW_GONGZUONIAN FROM NEW_TABLE1 WHERE (NEW_ID = @NEW_ID)";
command.CommandType = CommandType.Text;
command.Parameters.Add(new System.Data.SqlClient.SqlParameter("@NEW_ID", System.Data.SqlDbType.Decimal, 9, System.Data.ParameterDirection.Input, 10, 0, "NEW_ID", System.Data.DataRowVersion.Current, false, null, "", "", ""));
command.Parameters.Add(new System.Data.SqlClient.SqlParameter("@NEW_XINGMING", System.Data.SqlDbType.VarChar, 10, System.Data.ParameterDirection.Input, 0, 0, "NEW_XINGMING", System.Data.DataRowVersion.Current, false, null, "", "", ""));
command.Parameters.Add(new System.Data.SqlClient.SqlParameter("@NEW_NIANLING", System.Data.SqlDbType.VarChar, 3, System.Data.ParameterDirection.Input, 0, 0, "NEW_NIANLING", System.Data.DataRowVersion.Current, false, null, "", "", ""));
command.Parameters.Add(new System.Data.SqlClient.SqlParameter("@NEW_XINGBIE", System.Data.SqlDbType.Bit, 1, System.Data.ParameterDirection.Input, 0, 0, "NEW_XINGBIE", System.Data.DataRowVersion.Current, false, null, "", "", ""));
command.Parameters.Add(new System.Data.SqlClient.SqlParameter("@NEW_XUELI", System.Data.SqlDbType.VarChar, 5, System.Data.ParameterDirection.Input, 0, 0, "NEW_XUELI", System.Data.DataRowVersion.Current, false, null, "", "", ""));
command.Transaction = trans;
//依次根据参数将值添加到语句中
command.Parameters[0].Value = ((decimal)(NEW_ID));
if ((NEW_XINGMING == null))
{
command.Parameters[1].Value = System.DBNull.Value;
}
else
{
command.Parameters[1].Value = ((string)(NEW_XINGMING));
}
if ((NEW_NIANLING == null))
{
command.Parameters[2].Value = System.DBNull.Value;
}
else
{
command.Parameters[2].Value = ((string)(NEW_NIANLING));
}
if ((NEW_XINGBIE.HasValue == true))
{
command.Parameters[3].Value = ((bool)(NEW_XINGBIE.Value));
}
else
{
command.Parameters[3].Value = System.DBNull.Value;
}
if ((NEW_XUELI == null))
{
command.Parameters[4].Value = System.DBNull.Value;
}
else
{
command.Parameters[4].Value = ((string)(NEW_XUELI));
}
//创建返回值变量
int returnValue;
//执行语句
try
{
//执行数据库访问语句,将记录添加进去,并返回影响的行数
returnValue = command.ExecuteNonQuery();
}
catch //出现异常
{
//将返回值置为-1
returnValue = -1;
}
//返回
return returnValue;
}
private int InsertQuery2(decimal NEW_ID, string NEW_BUMEN, string NEW_ZHIWEI)
{
System.Data.SqlClient.SqlCommand command = new System.Data.SqlClient.SqlCommand();
command.Connection = trans.Connection;
command.CommandText = "INSERT INTO NEW_TABLE2\r\n (NEW_ID, NEW_BUMEN, NEW_ZHIWEI)\r\nVALUES (@NEW_ID,@N" +
"EW_BUMEN,@NEW_ZHIWEI); \r\nSELECT NEW_ID, NEW_BUMEN, NEW_ZHIWEI, NEW_GONGZI, NEW_Y" +
"EJIMIAOSHU FROM NEW_TABLE2 WHERE (NEW_ID = @NEW_ID)";
command.CommandType = CommandType.Text;
command.Parameters.Add(new System.Data.SqlClient.SqlParameter("@NEW_ID", System.Data.SqlDbType.Decimal, 9, System.Data.ParameterDirection.Input, 18, 0, "NEW_ID", System.Data.DataRowVersion.Current, false, null, "", "", ""));
command.Parameters.Add(new System.Data.SqlClient.SqlParameter("@NEW_BUMEN", System.Data.SqlDbType.VarChar, 20, System.Data.ParameterDirection.Input, 0, 0, "NEW_BUMEN", System.Data.DataRowVersion.Current, false, null, "", "", ""));
command.Parameters.Add(new System.Data.SqlClient.SqlParameter("@NEW_ZHIWEI", System.Data.SqlDbType.VarChar, 20, System.Data.ParameterDirection.Input, 0, 0, "NEW_ZHIWEI", System.Data.DataRowVersion.Current, false, null, "", "", ""));
command.Transaction = trans;
command.Parameters[0].Value = ((decimal)(NEW_ID));
if ((NEW_BUMEN == null))
{
command.Parameters[1].Value = System.DBNull.Value;
}
else
{
command.Parameters[1].Value = ((string)(NEW_BUMEN));
}
if ((NEW_ZHIWEI == null))
{
command.Parameters[2].Value = System.DBNull.Value;
}
else
{
command.Parameters[2].Value = ((string)(NEW_ZHIWEI));
}
int returnValue;
try
{
returnValue = command.ExecuteNonQuery();
}
catch
{
returnValue = -1;
}
return returnValue;
}
private int InsertQuery3(decimal NEW_ID, string NEW_DIANHUA, string NEW_SHOUJI, string NEW_DIZHI)
{
System.Data.SqlClient.SqlCommand command = new System.Data.SqlClient.SqlCommand();
command.Connection = trans.Connection;
command.CommandText = "INSERT INTO NEW_TABLE3\r\n (NEW_ID, NEW_DIANHUA, NEW_SHOUJI, NEW_DIZHI)\r\nVALUE" +
"S (@NEW_ID,@NEW_DIANHUA,@NEW_SHOUJI,@NEW_DIZHI); \r\nSELECT NEW_ID, NEW_DIANHUA, N" +
"EW_SHOUJI, NEW_DIZHI, NEW_QITA FROM NEW_TABLE3 WHERE (NEW_ID = @NEW_ID)";
command.CommandType = CommandType.Text;
command.Parameters.Add(new System.Data.SqlClient.SqlParameter("@NEW_ID", System.Data.SqlDbType.Decimal, 9, System.Data.ParameterDirection.Input, 18, 0, "NEW_ID", System.Data.DataRowVersion.Current, false, null, "", "", ""));
command.Parameters.Add(new System.Data.SqlClient.SqlParameter("@NEW_DIANHUA", System.Data.SqlDbType.VarChar, 20, System.Data.ParameterDirection.Input, 0, 0, "NEW_DIANHUA", System.Data.DataRowVersion.Current, false, null, "", "", ""));
command.Parameters.Add(new System.Data.SqlClient.SqlParameter("@NEW_SHOUJI", System.Data.SqlDbType.VarChar, 20, System.Data.ParameterDirection.Input, 0, 0, "NEW_SHOUJI", System.Data.DataRowVersion.Current, false, null, "", "", ""));
command.Parameters.Add(new System.Data.SqlClient.SqlParameter("@NEW_DIZHI", System.Data.SqlDbType.VarChar, 50, System.Data.ParameterDirection.Input, 0, 0, "NEW_DIZHI", System.Data.DataRowVersion.Current, false, null, "", "", ""));
command.Transaction = trans;
command.Parameters[0].Value = ((decimal)(NEW_ID));
if ((NEW_DIANHUA == null))
{
command.Parameters[1].Value = System.DBNull.Value;
}
else
{
command.Parameters[1].Value = ((string)(NEW_DIANHUA));
}
if ((NEW_SHOUJI == null))
{
command.Parameters[2].Value = System.DBNull.Value;
}
else
{
command.Parameters[2].Value = ((string)(NEW_SHOUJI));
}
if ((NEW_DIZHI == null))
{
command.Parameters[3].Value = System.DBNull.Value;
}
else
{
command.Parameters[3].Value = ((string)(NEW_DIZHI));
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -