1

我有一个班级 People_val。我在另一个班级列出了这个班级。现在我在这个列表上做一个 foreach 并且对于每个项目我调用它的 ToSQL() 函数，它给了我一个插入查询。列表计数超过 50,000 条记录。第 9774 个查询未完全形成。 9771 INSERT INTO CONVERSION_PEOPLE_VALIDATION VALUES（16413，'Jnto'，'Johnson'，因此命令未执行并且事务回滚。我应该怎么做才能在 foreach 中获取完整的字符串。

public class People_Val
{
    public int MEMBERS_ID;
    public string PFirstName;
    public string PLastName;

    public DateTime? BIRTH_DATE;
    public string RELATIONSHP;

    public string ToSQL()
    {            
        return string.Format("INSERT INTO CONVERSION_PEOPLE_VALIDATION VALUES ({0},'{1}','{2}','{3}', TO_CHAR('{4}', 'DD-MON-YYYY'))",
                             MEMBERS_ID, PFirstName.Replace("'","\""), PLastName.Replace("'","\""), RELATIONSHP, BIRTH_DATE);
    }
}

public void insertPeopleValTrans(List<People_Val> _lstPeoplevals)
{
    int count=0;
    TextWriter tw = new StreamWriter(@"C:\PeopleVal.txt");
    using (OracleConnection conn = new OracleConnection(connectionStr)) {
        conn.Open();
        OracleTransaction trans;
        trans = conn.BeginTransaction();
        try {
            foreach (People_Val peopleVal in _lstPeoplevals) {
                OracleCommand cmd = new OracleCommand(peopleVal.ToSQL(), conn, trans);
                cmd.ExecuteNonQuery();
                count++;
                if (count % 500 == 0) {
                    Console.WriteLine("saving " + count.ToString() + " Records");
                }
                tw.WriteLine(count.ToString()+" "+ peopleVal.ToSQL());
            }
            trans.Commit();
            tw.Close();
        } catch (Exception ex) {
            Console.WriteLine(ex.Message);
            trans.Rollback();
        }
        conn.Close();
    }          
}
4

2 回答 2

3

您可能在某些数据中有一个撇号，这会导致您的查询失败。

尝试参数化您的输入...看起来 RELATIONSHIP 字段是原始数据，这可能是问题所在。看看http://www.devart.com/dotconnect/oracle/articles/parameters.html我很确定这会解决你的问题。

粘贴到第 9771 行让我们看看...

于 2012-09-28T22:56:53.410 回答
0

真的有必要将所有 50000 条记录一起成功或失败吗？否则跳过事务或至少更频繁地提交，也许像......

if (count % 500 == 0)
{
    trans.Commit();
    Console.WriteLine("saving " + count.ToString() + " Records");
    trans = conn.BeginTransaction();
}

我同意前面的评论，这将是使用实体框架代码优先的最小努力。

于 2012-09-28T22:39:34.560 回答