在使用参数化查询插入之前检查 foxpro 数据库中是否存在记录

Question

我创建了一个程序，它从 excel 电子表格中提取数据并将其推送到 foxpro 数据库。但是我遇到了出现重复客户记录的问题。

这是由于一个客户端与多个其他记录相关联。

我需要知道如何在写入之前检查数据库以查看特定记录是否存在，但是我正在绘制一个完整的空白。

我的代码（对于这个特定的类）如下所示：

namespace PropertyImport
{
public class Landlord
{
    public void Import()
    {
        int IDCOUNT = 0;
        using (var exportConnection = new OleDbConnection(connectionString: Settings.ImportFrom))
        using (var importConnection = new OleDbConnection(connectionString: Settings.ImportTo))


        using (OleDbCommand exportCommand = new OleDbCommand(@"SELECT 
[clcodel salute],
[clcodel fname],
[clcodel sname]
from [export_test$]"
, exportConnection))
        using (OleDbCommand importCommand = new OleDbCommand(@"INSERT INTO CLIENT 
        (CLCODE,CLCODEDESC,CLCLASS,
        FNAME,MNAME,SNAME
        )
        VALUES 
        (?,?,?,?,?,?,?,?)",
                    importConnection))
        {
            OleDbDataReader exportReader;
            //

            importCommand.Parameters.AddWithValue("CLCODE", "");
            importCommand.Parameters.AddWithValue("CLCODEDESC", "");
            //importCommand.Parameters.AddWithValue("CLCLASS", "");
            //importCommand.Parameters.AddWithValue("NEGOTIATOR", "");
            //importCommand.Parameters.AddWithValue("TITLE", "");
            importCommand.Parameters.AddWithValue("FNAME", "");
            importCommand.Parameters.AddWithValue("MNAME", "");
            importCommand.Parameters.AddWithValue("SNAME", "");

            // Open connections to excel sheet and foxpro database
            exportConnection.Open();
            importConnection.Open();

            Console.WriteLine("Visual Foxpro connection open");
            Console.WriteLine("Writing to table");
            Console.WriteLine("...");

            int nLoopCount = 0;
            string space = " ";

            // Initiate the reader to excel
            exportReader = exportCommand.ExecuteReader();
            // Start reading
            while (exportReader != null && exportReader.Read())
            {

                //Set parameter values whilst reading from excel
                string LandTitle = exportReader.IsDBNull(0)
                    ? string.Empty
                    : Convert.ToString(exportReader.GetValue(0)).Trim();
                string LandFname = exportReader.IsDBNull(1)
                    ? string.Empty
                    : Convert.ToString(exportReader.GetValue(1)).Trim();
                string LandSname = exportReader.IsDBNull(2)
                    ? string.Empty
                    : Convert.ToString(exportReader.GetValue(2));
                string CLCODE = string.Concat(LandFname, space, LandSname, " (P)").Trim();
                Console.WriteLine("Working on record {0}, {1}", IDCOUNT, CLCODE);


                importCommand.Parameters["CLCODE"].Value = string.Concat(LandFname, space, LandSname, " (P)").Trim();
                importCommand.Parameters["CLCODEDESC"].Value = string.Concat(LandTitle, space, LandFname, space, LandSname).Trim();
                importCommand.Parameters["TITLE"].Value = LandTitle.Trim();
                importCommand.Parameters["FNAME"].Value = LandFname.Trim();
                importCommand.Parameters["SNAME"].Value = LandSname.Trim();

                try
                {
                    importCommand.ExecuteNonQuery();
                }
                catch (Exception e)
                {
                    Console.Write("Error Writing to database");
                    Console.Write(e);
                    Console.ReadKey();
                }

                // We must close and re-open the connection after a certain number of records or the OLEDB FoxPro SQL will eventually fail
                if (nLoopCount % 100 == 0)
                {
                    importConnection.Close();
                    importConnection.Open();
                }

            }

            // done
            exportConnection.Close();
            importConnection.Close();

            Console.WriteLine("Landlord Import Complete!");
            Console.WriteLine("Press any key to continue...");
            Console.ReadKey();
            if (Settings.ImportPropertyPause) Console.ReadKey();

        }
    }

}

}

我想做这样的事情：

if (CLCODE exists)
{
Do not not create record
}
else
{
create record
}

Answer 1

约书亚， 你让它变得不必要的复杂。在多用户环境中，您会遇到“如果不存在则检查并插入”逻辑的问题。如果您认为这不是问题，您可以执行 ExecuteScalar() 来检查该 clcode 的行数。如果为 0 则不存在。

如果您愿意这样做，那么更喜欢使用 Linq。使用 Linq，它只是一个：

bool exists = vfpdb.Clients.Any(c=>c.ClCode == "codetocheck");

看看它是否存在。

无论如何，有一个更简单的方法，这确实是一个技巧，但是一个有效的方法。假设您在“d:\backyard\temp”和“d:\temp\myclients.xlsx”文件下有client.dbf（仅出于演示目的，这是我选择的）：

void Main()
{
    string vfpInsert = @"Insert Into client 
    (CLCODE,CLCODEDESC,CLCLASS,FNAME,MNAME,SNAME) 
    SELECT CLCODE,CLCODEDESC,CLCLASS,FNAME,MNAME,SNAME 
     from (Iif(Xmltocursor(?,'xlData') > 0, 'xlData','')) xl 
     where Not Exists
      (Select * From client c2 Where c2.CLCODE == xl.CLCODE)";

    var xml = GetExcelData();

    using (OleDbConnection con=new OleDbConnection(@"provider=VFPOLEDB;Data Source="+@"d:\backyard\temp"))
    using (OleDbCommand cmd = new OleDbCommand(vfpInsert,con))
    {
        cmd.Parameters.Add("xldata", OleDbType.VarChar).Value = xml;
        con.Open();
        cmd.ExecuteNonQuery();
        con.Close();
    }
}

private string GetExcelData()
{
    string dataSource = @"D:\temp\myclients.xlsx";
    DataTable t = new DataTable("Clients");

    using (OleDbConnection con = new OleDbConnection("Provider=Microsoft.ACE.OLEDB.12.0;" +
      string.Format("Data Source={0};", dataSource) +
      "Extended Properties=\"Excel 12.0;HDR=Yes\""))
    using (OleDbCommand cmd = new OleDbCommand("Select * from [clients$]", con))
    {
        con.Open();
        t.Load(cmd.ExecuteReader());
        con.Close();
    }
    using (MemoryStream ms = new MemoryStream())
    using (var xmlwriter = XmlTextWriter.Create(ms))
    {
        t.WriteXml(xmlwriter, XmlWriteMode.WriteSchema);
        xmlwriter.Flush();
        xmlwriter.Close();
        ms.Position = 0;
        using (StreamReader streamreader = new StreamReader(ms))
        {
            return streamreader.ReadToEnd();
        }
    }
}

编辑：这里解释一下代码的作用：

• 从 excel 中获取数据作为 DataTable 并转换为 XML 字符串。
• 将 XML 作为参数传递给 VFP 插入命令。
• Insert 命令，将 XML 扩展为游标（几乎总是在内存中的表），然后选择那些不存在的（使用 ClCode）并一次性将它们插入到客户端表中。