Вставка большого объема информации в базу данных MySQL - C# - Ответ 7144608

        public static IEnumerable read_file;
        public static IEnumerator line_list;
 
        public static Queue<Exception> exceptions = new Queue<Exception>();
 
        // ....
 
        read_file = File.ReadLines(file_name);
        line_list = read_file.GetEnumerator();

        public static int str_file_count, insert_count;
 
        public static int str_count; 
 
        public static string current_table; // текущая таблица
 
        // вывод на экран определяется случайно функцией Rand (от, до)
        public static int min; // минимальное кол-во. записей 
        public static int max;  // максимальное кол-во. записей
 
        public static string file_name, file_line, md5_file_line;
 
        public static int rand;
 
        public static bool pause_query;

        public static readonly Random getrandom = new Random();
        public static readonly object syncLock = new object();
 
        public static int GetRandomNumber(int min, int max)
        {
            lock (syncLock)
            {
                return getrandom.Next(min, max);
            }
        }

               
 
        Thread thread = new Thread(MySQL_insert_method);
        thread.Start();

        private void MySQL_insert_method()
        {
            while (true)
            {
                try
                {
                    lock (line_list)
                    {
                        if (line_list.MoveNext())
                        {
                            file_line = line_list.Current as string;
                        }
                        else
                        {
                            Settings.mysql_connect.Close();
                            Console.ReadLine();
                            break;
                        }
                    }
 
                    md5_file_line = StringHash.GetMD5Hash(MySqlHelper.EscapeString(file_line));
                    current_table = md5_file_line.Substring(0, 2);
 
                    try
                    {
                        if (pause_query == false)
                        {
 
                            Query.Insert("MD5" + current_table, file_line, md5_file_line);
 
                            insert_count++;
                            str_count++;
 
                            if (str_count > rand)
                            {
                                ConsoleWrite("[+] STR: " + md5_file_line + ":" + file_line, 7, 0);
                                ConsoleWrite("[+] INSERTED STRING TO: [MD5" + current_table + "] [COUNT: " + insert_count + "]", 9, 0);
 
                                str_count = 0;
                            }
                        }
                    }
                    catch (Exception exceptions)
                    {
                        StreamWriter WriteErrorlog = new StreamWriter("log\\" + DateTime.Now.ToString(@"MM\.dd\.yyyy") + "\\error.log", true);
                        WriteErrorlog.Write(DateTime.Now.ToString("HH:mm:ss") + ": [-] " + exceptions + "\r\n");
                        WriteErrorlog.Close();
                        break;
                    }
                }
                catch (ThreadAbortException)
                {
                    break;
                }
                catch (Exception exceptions)
                {
                    StreamWriter WriteErrorlog = new StreamWriter("log\\" + DateTime.Now.ToString(@"MM\.dd\.yyyy") + "\\error.log", true);
                    WriteErrorlog.Write(DateTime.Now.ToString("HH:mm:ss") + ": [-] " + exceptions + "\r\n");
                    WriteErrorlog.Close();
                    break;
                }
            }
        }

        public static void Insert(string table, string colum1, string colum2)
        {
            int sql_query_execute;
 
            MySqlCommand insert_command = new MySqlCommand("insert ignore into " + table + " (text, md5hash) values ('" + MySqlHelper.EscapeString(colum1) + "', '" + colum2 + "')", Settings.mysql_connect);
            sql_query_execute = insert_command.ExecuteNonQuery();
        }

    public static class StringHash
    {
        static readonly char[] HexChars = new char[] { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f' };
        static readonly MD5 md5 = MD5.Create();
        static readonly Encoding UTF8 = Encoding.UTF8;
 
        static public string GetMD5Hash(string S)
        {
            byte[] B = md5.ComputeHash(UTF8.GetBytes(S));
            char[] ar = new char[B.Length * 2];
 
            int Index = 0;
            foreach (byte bv in B)
            {
                ar[Index++] = HexChars[bv >> 4];
                ar[Index++] = HexChars[bv & 0xF];
            }
 
            return new string(ar);
        }
    }