zoukankan      html  css  js  c++  java
  • 串行写队列的MYSQL大文本参数

    public void AsyncWriteDataBase()
            {
                var spName = "";
                while (true)
                {
                    try
                    {
                    var jsonText = RedisHelper.BlockingPopItemFromList("async_write_list");
                    var o = (JObject)JsonConvert.DeserializeObject(jsonText);
    
                    if (o["need_newcache"].ToString() != "0") continue;
                    spName=o["action"].ToString();
                    var jObject = o["paras"];
    
                    var paras = new MySqlParameter[jObject.Children().Count()];
                    var count = 0;
                    foreach (JProperty item in jObject.Children())
                    {
                        if (item.Value.ToString().Length >=1024)
                        {
                            paras[count] = new MySqlParameter(item.Name, MySqlDbType.MediumText);
                            //var bytes = System.Text.Encoding.UTF8.GetBytes(item.Value.ToString()); 
                            //paras[count].Value = bytes;
                            //如果下面的代码不行,试试上面注释掉的代码
                            paras[count].Value = item.Value.ToString();
                        }
                        else
                        {
                            paras[count] = new MySqlParameter(item.Name, MySqlDbType.VarChar, 1024);
                            paras[count].Value = item.Value;
        
                        }
                        
                        count++;
                    }
                      SqlHelper.ExecuteNonQuery(SqlHelper.ConnectionString, CommandType.StoredProcedure, spName, paras);
                      Program.myFrm.SetTextMessage("成功写入异步数据库记录,调用的存储过程:" + spName, 3);
                    }
                    catch (Exception err)
                    {
                        Program.myFrm.SetTextMessage("写入异步数据库记录失败,调用的存储过程:" + spName+",错误原因:"+err, 3);
                    }
                }
            }
  • 相关阅读:
    网络编程(四)
    网络编程(三)
    网络编程(二)
    网络编程(一)
    异常处理
    Python 的名称空间和作用域
    如何在Java 8中愉快地处理日期和时间
    线段树入门整理、
    最小生成树prim、
    <climits>头文件
  • 原文地址:https://www.cnblogs.com/littlehb/p/4002696.html
Copyright © 2011-2022 走看看