首页 > 代码库 > 串行写队列的MYSQL大文本参数
串行写队列的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 = http://www.mamicode.com/bytes;>//如果下面的代码不行,试试上面注释掉的代码 paras[count].Value =http://www.mamicode.com/ 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); } } }
串行写队列的MYSQL大文本参数
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。