0

我正在解析一个逐行工作并插入数据库的平面文件，但我想添加一个额外的步骤，实际上是额外的 2 个步骤。

首先，我只想要特定汽车制造商的召回记录，我有一个名为 AutoMake 的数据库表，其中包含我想要包含的所有品牌的列表。我需要将记录与该表进行比较，以确保它是我想要包含的品牌之一的记录。

然后我需要进行第二次检查以确保该记录不在我的数据库中。这是一个控制台应用程序，我为此使用实体。所以这是我的代码，我让自己发疯，试图编写和重写它以包括检查，但我只是没有得到它。

哦，这并不重要，因为如果有人可以让我朝着正确的方向前进，我可以从那里移动，但是and is 并且可以tokens[2]用来验证记录是否已经在数据库中，因为它是一个唯一值MAKETXTRCL_CMPT_IDtokens[23]RCL_CMPT_ID

    public static void ParseTSV(string location)
    {
        Console.WriteLine("Parsing.....");

        using (var reader = new StreamReader(location))
        {
            var lines = reader.ReadToEnd().Split(new char[] { '\n' });

            if (lines.Length > 0)
            {
               foreach (string line in lines)
               {
                  if (string.IsNullOrWhiteSpace(line))
                  {
                    continue;
                  }
                  var tokens = line.Trim().Split(new char[] { '\t' });

                  var recalls = new Recalls();

                  recalls.RECORD_ID = tokens[0];
                  recalls.CAMPNO = tokens[1];
                  recalls.MAKETXT = tokens[2];
                  recalls.MODELTXT = tokens[3];
                  recalls.YEARTXT = tokens[4];
                  recalls.MFGCAMPNO = tokens[5];
                  recalls.COMPNAME = tokens[6];
                  recalls.MFGNAME = tokens[7];
                  recalls.BGMAN = tokens[8];
                  recalls.ENDMAN = tokens[9];
                  recalls.RCLTYPECD = tokens[10];
                  recalls.POTAFF = tokens[11];
                  recalls.ODATE = tokens[12];
                  recalls.INFLUENCED_BY = tokens[13];
                  recalls.MFGTXT = tokens[14];
                  recalls.RCDATE = tokens[15];
                  recalls.DATEA = tokens[16];
                  recalls.RPNO = tokens[17];
                  recalls.FMVSS = tokens[18];
                  recalls.DESC_DEFECT = tokens[19];
                  recalls.CONEQUENCE_DEFECT = tokens[20];
                  recalls.CORRECTIVE_ACTION = tokens[21];
                  recalls.NOTES = tokens[22];
                  recalls.RCL_CMPT_ID = tokens[23];


                  string connectionString = GetConnectionString();
                  using (SqlConnection connection = new SqlConnection(connectionString))
                  {
                      SqlCommand cmdIns = new SqlCommand(GetInsertSqlCust(recalls), connection);
                      connection.Open();
                      cmdIns.ExecuteNonQuery();
                      connection.Close();
                      cmdIns.Dispose();
                      cmdIns = null;
                  }
              }
          }
      }
  }
4

2 回答 2

1

1：获取要检查的ID 2：获取需要进行搜索的表，例如 

 string strExpression="";
    (Datatable tdGeneric = dal.getsometable())

3：检查自动制作是否存在：

if ( tdGeneric != null && tdGeneric.Rows.Count > 0)
  {
   strExpression = "tablecolumnsname = '" + recalls.MAKETXT + "' ";
   tdGeneric.DefaultView.RowFilter = strExpression;
   tdGeneric = tdGeneric.DefaultView.ToTable();
    if (tdGeneric.Rows.Count > 0)
    {
          //make exist
    }
    else
     make don't exists

  }
  else
 {
   make don't exist skip that text file's record
 }

4：如果make存在，则检查表中是否存在记录。

获取原始表，在该表上搜索您的特定 id：

 (Datatable tdGeneric2 = dal.getsometable())
 if ( tdGeneric2 != null && tdGeneric.Rows.Count > 0)
      {
       strExpression = "tablecolumnsname = '" + recalls.RCL_CMPT_ID + "' ";
       tdGeneric2.DefaultView.RowFilter = strExpression;
       tdGeneric2 = tdGeneric2.DefaultView.ToTable();
          if (tdGeneric2.Rows.Count > 0)
        {
              //record exist
        }
        else
         record don't exists
      }
      else
     {
       record don't exist insert the record, or some flag to insert a record
     }
于 2012-10-14T20:15:14.313 回答
0

您可以利用缓存。在读取文件之前获取所有 Makes 并在现有 AutoMakes 的 List 或 Dictionary 中进行查找，以检查 AutoMake 是否已存在于数据库中或者它是否是新的。如果 AutoMake 是新的，则在数据库中插入记录并在 List\Dictionary 中添加 make。如果 AutoMake 已存在，请跳过该行并移至下一行。

于 2012-10-13T17:10:37.890 回答