0

我需要通过将定义的函数应用于该列来更新表列。以 MySqlCommand 为例。例如。我有一个 C# 定义的函数来清理文本string GetCleanText(string text_to_clean)，在我的一个表中，我有一列fullTxt包含要清理的文本，另一列txt现在是空的。

结果我应该有：txt = GetCleanText(fullTxt)。

我尝试使用foreach循环，但它是如此广泛，因为我的表中有几行。

这是我的代码：

// Get all entries in the log table that have the html log and do not have text answers
            MySqlCommand request1 = new MySqlCommand("SELECT * FROM my_table WHERE fullTxt IS NOT NULL AND txt IS NULL", conn);

            // loop over results and clean the text entries
            List<List<string>> tobefilled = new List<List<string>>(); 

            using (MySqlDataReader r = request1.ExecuteReader())
            {
                while (r.Read())
                {
                    string id = r.GetString("id");
                    string fullTxt = r.GetString("fullTxt");
                    string txt = this.GetCleanText(fullTxt);
                    tobefilled.Add(new List<string>() { id, txt });
                }
            }

            System.Console.WriteLine($"{tobefilled.Count} to be updated ...");
            // Update all entries in the log table that have the html log and do not have text answers
            MySqlCommand request2 = new MySqlCommand("UPDATE my_table SET txt = @txt WHERE id = @id", conn);
            request2.Parameters.AddWithValue("@txt", "");
            request2.Parameters.AddWithValue("@id", "");


            foreach (List<string> elem in tobefilled)
            {
                request2.Parameters["@txt"].Value = elem[1];
                request2.Parameters["@id"].Value = elem[0];

                request2.ExecuteNonQuery();
            }
4

1 回答 1

0

我不知道这是否像一种方法一样干净，但它的工作速度更快：

using System.Collections.Generic;
using System.Text;
using HtmlAgilityPack;
using MySql.Data.MySqlClient;

namespace DatabaseMigrations.MigrationScripts
{
    class MigrationScript
    {
        /// <summary>
        /// Take a string having html formatted content, and extract raw text
        /// </summary>
        /// <param name="html">input html string</param>
        /// <returns>cleaned text in a string</returns>
        public string GetCleanText(string html)
        {
            // parse the html in TxtMessage to extract text only
            var htmlDoc = new HtmlDocument();
            htmlDoc.LoadHtml(html);
            var htmlNodes = htmlDoc.DocumentNode.SelectNodes("/");  // all nodes in the html
            string txtMessage = (htmlNodes[0].InnerText).Trim();
            return txtMessage;
        }

        
        /// <summary>
        /// Fill the txt column of previous bot logs with the parsed html content from the fullTxt column
        /// </summary>
        /// <param name="conn"></param>
        public override void ApplyDataMigrationOperations(MySqlConnection conn)
        {
            // Get all entries in the log table that have the html log and do not have text answers
            MySqlCommand request1 = new MySqlCommand("SELECT * FROM logmessagefrombot WHERE fullTxt IS NOT NULL AND txt IS NULL", conn);

            // loop over results and clean the text entries
            List<List<string>> tobefilled = new List<List<string>>(); 

            using (MySqlDataReader r = request1.ExecuteReader())
            {
                while (r.Read())
                {
                    string id = r.GetString("id");
                    string fullTxt = r.GetString("fullTxt");
                    string txt = this.GetCleanText(fullTxt);
                    tobefilled.Add(new List<string>() { id, txt });
                }
            }

            System.Console.WriteLine($"{tobefilled.Count} to be updated ...");
            // Update all entries in the log table that have the html log and do not have text answers

            StringBuilder sb = new StringBuilder();
            string cases = " WHEN @id THEN \"@txt\" ";
            List<string> ids = new List<string>();
            sb.Append("UPDATE logmessagefrombot SET txt = ( CASE id ");

            if (tobefilled.Count > 0)
            {
                foreach (List<string> elem in tobefilled)
                {
                    sb.Append(cases.Replace("@id", elem[0]).Replace("@txt", elem[1].Replace("\n", " ").Replace("\"", "''")));
                    ids.Add(elem[0]);
                }
                sb.Append("ELSE txt ");
                sb.Append("END )");
                sb.Append("WHERE id IN ( ");
                sb.Append(string.Join(",", ids.ToArray()) + ")");
                MySqlCommand request2 = new MySqlCommand(sb.ToString(), conn);
                request2.ExecuteNonQuery();
            }
        }

        
    }
}

生成的查询，构建StringBuilder的太长了，但它有效。

于 2022-02-22T11:04:02.410 回答