MySQL创建webservice_WebService实现数据库操作(示例代码)

墨蓝 2022-10-31 12:24 236阅读 0赞

1.数据库连接：

\[WebMethod\]public string InsertPoint(stringdata)

\{//解决跨域问题//Context.Response.AddHeader("Access-Control-Allow-Origin", "\*");

string database = "Data Source=.;Initial Catalog=test;Persist Security Info=True;User ID=sa;Password=password1633";//string data = HttpContext.Current.Request\["data"\];

try\{if (data.Equals("") || data == null)

\{return "data is null";

\}else\{

OverlaysPoint opoint= JsonConvert.DeserializeObject(data);// 将接收的参数data实例化为一个对象(方便操作)，注意该类的变量名要和json的key值对应/\*foreach (Data\_Opoint dtpoint in opoint.overlays)

sql = "insert into Map\_Overlays(wf\_pictureid,wf\_picturename,wf\_railid,wf\_name,wf\_location,wf\_createtime,wf\_pid,wf\_lng,wf\_lat) values(‘" + "123456789" + "‘,‘" + opoint.picturename + "‘,‘" + opoint.id + "‘,‘" + opoint.name + "‘,‘" + opoint.location + "‘,‘" + opoint.createime + "‘,‘" + dtpoint.pid + "‘,‘" + dtpoint.lng.ToString() + "‘,‘" + dtpoint.lat.ToString() + "‘)";

ExecuteUpdate(sql, database);

\}\*/

string\[\] xyArray = opoint.position.Split(new string\[\] \{ "(", ",", ")"\}, StringSplitOptions.RemoveEmptyEntries); //处理json字符串

//执行sql语句string sql = "insert into map\_img\_points(miid,pointtype,pointid, pointcode, positionx, positiony, pointinfo) values (‘地图id‘, ‘" + opoint.point\_type + "‘, ‘" + opoint.point\_bm + "‘,‘" + opoint.point\_code + "‘,‘" + xyArray\[0\] + "‘,‘" + xyArray\[1\] + "‘, ‘" + opoint.point\_info + "‘)";

executeUpdate(sql, database);return "success";

\}catch(NullReferenceException e)

\{returne.StackTrace;

Data Source ：  一个点默认为本地数据库，其他数据库填写相应ip ；

Initial Catelog：是目标数据库名称

我们接收一个json字符串，将其value填入一个实例化的类对象，通过这个类的实例化对象来使用它

OverlaysPoint opoint = JsonConvert.DeserializeObject(data);

OverPoint类：

public classOverlaysPoint

\{public stringpoint\_type;public stringpoint\_bm;public stringpoint\_code;public stringposition;public stringpoint\_info;public stringcon\_bussiness;public stringcon\_entity;public stringcon\_fields;public stringshowpic;public stringshowtext;public stringshowdata;public stringcreate\_time;public stringdata\_refresh\_rate;

executeQuery和executeUpdate方法：

//对数据库操作//用于查询

private DataTable executeQuery(string sqlStr, stringsqlCon)

SqlConnection con= newSqlConnection(@sqlCon);

con.Open();

SqlCommand cmd= newSqlCommand();

cmd.Connection=con;

cmd.CommandType=CommandType.Text;

cmd.CommandText=sqlStr;

DataTable dt= new DataTable(); //实例化数据表

SqlDataAdapter msda;

msda= new SqlDataAdapter(cmd); //实例化适配器