MYSQL Socket 增删改差之增

1.像服务器数据库发送消息,添加数据

//WPF端的代码:

void SaveData()//房体是wpf上传的
{
if (fileSaveName == null || fileSaveName == "")
{
saveName savename = new saveName();
bool? saveState = savename.ShowDialog();
if (saveState == true)
{
fileSaveName = savename.text;
if (fileSaveName == null || fileSaveName == "")
{
PopSure popsure = new PopSure();
popsure.Label_Tip.Content = "请输入名字";
popsure.ShowDialog();

SaveData();
return;
}
}
else
{
saveDataState = false;
return;
}
}
var json = edit.GetLayoutJson();//房体的信息
UserData.Data["loadLayout"] = json;
if (System.IO.Directory.Exists("tempfile") == false)
{
System.IO.Directory.CreateDirectory("tempfile");
}
var bs = System.Text.Encoding.UTF8.GetBytes(json.ToString());
var hash = Sha1.CalcSHA1String(bs);
string filename = "tempfile\\" + hash + ".layout.txt";
System.IO.File.WriteAllBytes(filename, bs);

UserData.Data["HouseLayoutIndex"] = new MyJson.JsonNode_ValueString(hash);

System.Collections.Specialized.NameValueCollection dict = new System.Collections.Specialized.NameValueCollection();
dict["token"] = UserData.Data.asDict()["token"].AsString();
dict["userName"] = UserData.Data["userName"].AsString();
string url = UserData.BaseUrl + "homedecor/useruploadfile.aspx";//用户上传的接口
//上传2D房体资源
var taskLayout = HttpMgr.Task.Create(url, HttpMgr.Method.POST_File, HttpMgr.ReturnType.TEXT, dict,
filename,
(s, e) =>
{
if (e is Exception)
{
System.Windows.Forms.MessageBox.Show((e as Exception).Message + s.url);
}
else if (e is string)
{
//上传成功不用管
}
}
);
HttpMgr.Instance.GetLayer(0).QueueTask(taskLayout);
//上传2D房体缩略图
string[] picfile = this.edit.SaveJpeg();
if (picfile == null)
{
return;
}
filename = picfile[0];
UserData.Data["HouseLayoutPic"] = new MyJson.JsonNode_ValueString(picfile[1]);//图片哈希
taskLayout = HttpMgr.Task.Create(url, HttpMgr.Method.POST_File, HttpMgr.ReturnType.TEXT, dict,
filename,
(s, e) =>
{
if (e is Exception)
{
System.Windows.Forms.MessageBox.Show((e as Exception).Message);
}
else if (e is string)
{
//上传成功不用管
}
}
);
HttpMgr.Instance.GetLayer(0).QueueTask(taskLayout);
//添加数据库记录
dict = new System.Collections.Specialized.NameValueCollection();
dict["token"] = UserData.Data.asDict()["token"].ToString();
dict["id"] = UserData.Data.asDict()["HouseLayoutID"].ToString();
dict["name"] = fileSaveName;
dict["index"] = UserData.Data.asDict()["HouseLayoutIndex"].ToString() + ".layout.txt";
dict["pic"] = UserData.Data.asDict()["HouseLayoutPic"].ToString();
dict["layers"] = UserData.Data.asDict()["layers"].ToString();
if (editType == EditType.insert)
{
url = UserData.BaseUrl + "homedecor/houseLayoutAdd.aspx";
}
else if (editType == EditType.update)
{
url = UserData.BaseUrl + "homedecor/houselayoutupdate.aspx";
}
var task = HttpMgr.Task.Create(url,
HttpMgr.Method.GET,//提交类型
HttpMgr.ReturnType.TEXT,//返回类型
dict,//参数
null,//文件名,仅postfile 模式才有用
SaveDataCallBack//回调
);
HttpMgr.Instance.GetLayer(0).QueueTask(task);
}
void SaveDataCallBack(HttpMgr.Task task, object data)
{
if (data is Exception)
{
System.Windows.MessageBox.Show(data.ToString());
return;
}
try
{
var jsonData = MyJson.Parse(data as string);
var state = jsonData.asDict()["state"].ToString();
if (state == "1")
{
if (editType == EditType.insert)
{
editType = EditType.update;
UserData.Data.asDict()["HouseLayoutID"] = jsonData.asDict()["id"];
}
suffixName = 0;
}
else
{
var message = jsonData.asDict()["msg"].ToString();
if(message=="name repeat") //重名自动后缀保存
{
string name = "";
name = fileSaveName + "__" + suffixName.ToString();
task.paramlist["name"] = name;
HttpMgr.Instance.GetLayer(0).QueueTask(task);
suffixName++;
}
else
{
MessageBox.Show("保存失败!详细:" + data.ToString());
}

}
}
catch (Exception err)
{
MessageBox.Show(err.ToString());
}
}

//服务器端的代码

using System;
using MySql.Data.MySqlClient;

namespace homeDecor
{
public partial class houseLayoutAdd : System.Web.UI.Page
{
protected void Page_Load(object sender, EventArgs e)
{
MyJson.JsonNode_Object json = new MyJson.JsonNode_Object();
string token = Request.Params["token"];
string name = Request.Params["name"];
string index = Request.Params["index"];
string layers = Request.Params["layers"];
string pic = Request.Params["pic"];

if (token != null && name != null && index != null && pic != null && layers != null)
{
userStatusCheck userstatuscheck = new userStatusCheck(token);
int userid = userstatuscheck.userState[0];
int isAdmin = userstatuscheck.userState[1];
if (userid != 0)
{

string sqlcmdRepeat = "select count(*) as num from houseLayout where name = ‘" + name + "‘ and uid = " + userid;

using (MySqlConnection myconn = dbhelper.getMySqlCon())
{
MySqlCommand mySqlCommand = dbhelper.getSqlCommand(sqlcmdRepeat, myconn);
myconn.Open();
MySqlDataReader read = mySqlCommand.ExecuteReader();
if (read.Read())
{
int num = int.Parse(read["num"].ToString());
if (num > 0)
{
//重命名了
json.SetDictValue("state", -1);
json.SetDictValue("msg", "name repeat");
Response.Write(json.ToString());
return;
}
}

}

string sql = "insert into houseLayout(`createtime`,`name`,`index`,`uid`,`pic`,`layers`,`flg`) values(now(),‘" + name + "‘,‘" + index + "‘,‘" + userid + "‘,‘" + pic + "‘,‘" + layers + "‘,0)";

using (MySqlConnection myconn = dbhelper.getMySqlCon())
{
int id = -1;
MySqlCommand mySqlCommand = dbhelper.getSqlCommand(sql, myconn);
myconn.Open();
if (dbhelper.getUpdate(mySqlCommand) > 0)
{
mySqlCommand = dbhelper.getSqlCommand("SELECT LAST_INSERT_ID()", myconn);
MySqlDataReader reader = mySqlCommand.ExecuteReader();
while (reader.Read())
{
if (reader.HasRows)
{
id = int.Parse(reader["LAST_INSERT_ID()"].ToString());
}
}
json.asDict()["state"] = new MyJson.JsonNode_ValueNumber(1);
json.asDict()["id"] = new MyJson.JsonNode_ValueNumber(id);
}
else
{
json.asDict()["state"] = new MyJson.JsonNode_ValueNumber(-1);
json.asDict()["msg"] = new MyJson.JsonNode_ValueString("houselayout add error");
}
}

}
else
{
json.asDict()["state"] = new MyJson.JsonNode_ValueNumber(-1);
json.asDict()["msg"] = new MyJson.JsonNode_ValueString("user or password error");
}
}
else
{
json.asDict()["state"] = new MyJson.JsonNode_ValueNumber(-1);
json.asDict()["msg"] = new MyJson.JsonNode_ValueString("need token,name,index");
}
Response.Write(json.ToString());
}
}
}

时间: 2024-08-17 15:01:31

MYSQL Socket 增删改差之增的相关文章

大数据基本的 增删改差 Demo(资源来自网络本人属于收藏总结)

今天第一天接触大数据 做一些基本的增删改差,来这总结一下 ,资源来自网络本人属于收藏总结 这一篇只有demo合运行结果 ,下一篇有一点对代码的分析合自己的理解 先看一下数据库 的数据 查询数据 1 public static void main(String args[]) throws TRSException { 2 TRSConnection conn = new TRSConnection("http://127.0.0.1:5555", "admin",

Oracle增删改查--之增

Oracle增删改查--之增 1.新建数据库用户并设置密码 create user 用户名 identified by 密码 2.为新建用户授权dba grant dba to 用户名; 3.登陆验证feiyu用户 conn feiyu: 4.创建表(首先切到当前用户下) create table 表名(id number(6)not null primary key,id_username char(4)); 5.给chengji表添加数据 insert into 表名 values('2',

vue.js带复选框表单的增删改差

近段时间由于公司项目要求,前端开始使用VUE框架进行开发,最近刚开始学习,做了一个表单的增删改查,和大家分享一下. 页面模型代码设计如下 <template> <div id="navi_108_page"> <i-button type="info" @click="adds">添加类型</i-button> <i-button type="warning" @click

JS源生代码“增删改查”之增

51呢最近在做一个管理数据的,第一次接触到用JS的源代码去实现一些功能,才知道网页里的许多功能都是依赖于“增删改查”完成的,下面的几张图片就是对于增的演示: 下面是有关HTML的代码:这个主要是弹窗部分的HTML代码 <div id="addDialog"> <div id="div11"> <form action="" id="from"> <table class="b

Sql Server2008温故而知新系列02:数据增删改查之&quot;增&quot;

增删改查-数据库最基本使用方法,也是数据库最常用的操作方法: 用到的命令:insert[into] 插入:delete from  删除:update 修改:select 查询. 首先说一说插入的格式(即新增数据): 1.insert into table_name(field1,field2,field3,…………)  values(字段1记录,字段2记录,…………) 如有多行记录重复写入多行 2.insert into table_name(field1,field2,field3,…………

mybatis06 增删改差 源码

user.java package cn.itcast.mybatis.po; import java.util.Date; public class User { private int id; private String username;// 用户姓名 private String sex;// 性别 private Date birthday;// 生日 private String address;// 地址 public int getId() { return id; } pub

MySQL增删改查之“增”

插入记录有两种个基本语法: 插入基本语法一 类别 详细解示 基本语法 insert into 表 values(值1,值2,值n); 示例 INSERT INTO user values(2,'php中文网','男') 示例说明 向user表中插入值id为2,姓名为李文凯,性别为男 插入基本语法二 类别 详细解示 基本语法 insert into 表(字段1,字段2,字段n) values(值1,值2,值n); 示例 INSERT INTO user(id,username,sex) value

PHP MYSQL 增删改查之增 jsonAdd

<?php //header("Content-type: text/html; charset=UTF8"); //header("Content-Type: text/html;charset=utf-8"); $end=array(); $id = $_POST['id']; $name = $_POST['name']; $age = $_POST['age']; $sex = $_POST['sex']; $end['name']=$name; $m

MySQL增删改查--之增

MySQL增加数据 1.新建数据库用户 //新建feiyu数据库用户允许在所有IP地址登陆mysql> create user 'feiyu'@'%' identified by '123'; //新建guest数据库用户允许在192.168.1网段所有地址登陆mysql> create user 'guest'@'192.168.1.%' identified by '123'; 注:新建完数据库新用户如果出现以下登陆错误为默认密码错误 解决办法有两种:(如下)(1) 此方法只可解决普通用户