使用Flex,Java，Json更新Mysql数据【高级篇】

package jsongrid; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import net.sf.json.JSONArray; import net.sf.json.JSONObject; public class JsonGrid { private Connection con = null; private String myDriver = "com.mysql.jdbc.Driver"; private String conURL = "jdbc:mysql://localhost:3306/test"; private String userName = "root"; private String userPass = "liceven"; public Connection conToDB(){ try{ Class.forName(myDriver); con = DriverManager.getConnection(conURL,userName,userPass); }catch(Exception e){ e.printStackTrace(); } return con; } public String getJsonArray(){ JSONArray jsonEmployeeArray = new JSONArray(); ResultSet rs = null; String result= new String(); try{ Connection conToDb = conToDB(); Statement stmt = conToDb.createStatement(); rs=stmt.executeQuery("select * from employee"); while(rs.next()){ JSONObject jsonEmployee = new JSONObject(); jsonEmployee.put("id", rs.getString("id")); jsonEmployee.put("name", rs.getString("name")); jsonEmployee.put("gender", rs.getString("gender")); jsonEmployee.put("department", rs.getString("department")); jsonEmployeeArray.add(jsonEmployee); } result = jsonEmployeeArray.toString(); conToDb.close(); //result = new JSONObject().put("jsonEmployeeArray",jsonEmployeeArray).toString(); }catch(SQLException ex){ ex.printStackTrace(); } return result; } public String sendJsonArray(String jsonData){ String result= new String(); //jsonData = jsonData.replace("\\", ""); JSONArray jsonArray = JSONArray.fromObject(jsonData); System.out.println(jsonArray.toString()); try{ Connection conToDb = conToDB(); Statement stmt = conToDb.createStatement(); for(int i=0;i<jsonArray.size();i++){ JSONObject jsonObject = JSONObject.fromObject(jsonArray.getString(i)); String operation = jsonObject.getString("operation"); if(operation.equals("update")){ String name = jsonObject.getString("name"); String id = jsonObject.getString("id"); stmt.executeUpdate("update employee set name='"+name+"' where id='"+id+"'"); result="恭喜，成功更新"+name+"数据！"; System.out.println(result); }else if(operation.equals("delete")){ String id = jsonObject.getString("id"); stmt.executeUpdate("delete from employee where id = '"+id+"'"); result="恭喜，成功删除"+id+"数据!"; } //String name = jsonObject.getString("name"); //stmt.executeUpdate("update employee set name='"+name+"' where id='"+id+"'"); } conToDb.close(); }catch(Exception e){ result = e.getLocalizedMessage(); } return result; } }