初识通用数据库操作类——前端easyui-datagrid,form(php) |
初识通用数据库操作类——前端easyui-datagrid,form(php),实现代码比较简单,具体实现步骤请看下文 。 实现功能: 左端datagrid显示简略信息,右侧显示选中行详细信息,数据库增删改 (1)点击选中行,右侧显示详细信息,其中【新增】、【修改】、【删除】按钮可用,【保存】按钮禁用 (2)点击【新增】按钮,【修改】,【删除】按钮禁用,【保存】按钮启用 (3)点击【修改】按钮,【新增】,【删除】按钮禁用 难点:通用数据库操作类中insert方法跟update方法 最终效果图: 前端功能不是很完善,按钮之间逻辑还是有点问题,最后补充前端代码 其中Formain.php对前端传值判断,并调用actSQL.class.php获得结果 代码比较简单 如下: <?php require(include/mysql_connect/actSQL.class.php); $key=$_REQUEST[key]; $a=new actSQL(localhost,root,1234,tpss); //获取信息 if($key==1) { $a->getAllData(t_prekeychart); } if($key==2) { $objectstr=$_REQUEST[object]; if($a->insertData($objectstr,t_prekeychart)) { echo json_encode("true"); }else{ echo json_encode("false"); } //test //$test={"keychartid":"2","keyid":"2","keychartname":"2","level":"2","showtype":"2","helptips":"2","keylevel":"2","ishmap":"2"}; //$a->insertData($test,t_prekeychart); } if($key==3) { $prekey=$_REQUEST[keychartid]; $prekeyname=keychartname; if($a->delData($prekey,$prekeyname,t_prekeychart)) { echo json_encode("true"); }else{ echo json_encode("false"); } } if($key==4) { $objectstr=$_REQUEST[object]; $prekeyname=keychartid; if($a->updData($objectstr,$prekeyname,t_prekeychart)) { echo json_encode("true"); }else{ echo json_encode("false"); } } ?> 看Formain.php中出现的类的各个方法,简单思考一下 其中 getAllData($tablename)获取表格的所有信息,这个方法比较简单,一个简单的sql语句就可以搞定,最后将结果json格式返回即可 delData($prekey,$prekeyname,$tablename)删除指定信息,这个更简单,就不说了 insertData( $objectstr,$tablename ) ,其中$objectstr是json格式的字符串,$tablename表名, 难点是将拼凑成 insert into $tablename (......) values(.....) 这种语句 解决办法: (1)根据$tablename获取所有的列名,并将列名数组转换为字符串,为最后sql语句的拼凑做准备,除此获取列名还有个目的,往下看 (2)将json格式的字符串$objectstr转换为关联数组,调用json_decode() 方法 补充json_decode()方法 mixed json_decode ( string $json [, bool $assoc = false [, int $depth = 512 [, int $options = 0 ]]] ) (3)按 照查询到的列名顺序查询数据,数据为空时,赋值为NULL , 将结果存到数组,防止数据库插入数值错位(获取列名的另个原因) (4)将(3)的结果转化为字符串,调用implode()方法 补充implode()方法: string implode(string glue, array pieces); (5)拼凑sql语句字符串,然后向数据库插入 updData($objstr,$prekeyname,$tablename)方法难点也是在于sql语句的字符串拼凑,拼凑格式应该如下 update $tablename set ..... where $prekeyname=$data[$prekeyname] 前两步同insertData() (3)遍历列名字符数组,获取非主键名的列名值,按照 “列名=列名值” 的字符串格式存入数组 ,这里就是set 后面部分的不完全字符串 (4)将(3)结果转换为字符串,将数组元素以 , 分隔开,这个就是set后面最后的字符串 格式为“xx=xx,xx=xx” (5)拼凑sql字符串,然后更新数据库 insertData()以及updData()函数如下 /* * 添加信息 * @param:$objstr:json风格的数据库插入信息字符串 * $tablename:表名 */ function insertData($objstr,$tablename) { $dbc=$this->conData(); if($dbc) { $columnname=array(); $columnname=$this->getColumns($tablename); //echo $columnname[0]; $clos=implode(,,$columnname); //将列名数组转换为字符串 //echo $clos; $data=json_decode($objstr,true); //将json格式的字符串转换为关联数组 //echo $value[keychartname]; $values=array(); foreach($columnname as $value) { //按照查询到的列名查询数据,数据为空的,赋值为NULL,防止数据库插入数值错位 //echo $data[$value]."<br>"; if(isset($data[$value])) { array_push($values,$data[$value]); }else{ $data[$value]=NULL; array_push($value,$data[$value]); } } $strvalue=implode(,,$values); //echo $strvalue; /* * SQL: insert into $tablename($clos) values(...) */ $sql=<<<SQL insert into $tablename($clos) values($strvalue); SQL; //echo $sql; $res=mysqli_query($dbc,$sql); if($res) { return true; }else{ return false; } }else{ echo "连接错误!"; } } /* *更新信息 *@param: $objstr:json风格的数据库更新信息字符串 * $tablename:表名 * $prekeyname:主键名 * */ function updData($objstr,$prekeyname,$tablename) { $dbc=$this->conData(); if($dbc) { $columnname=array(); $columnname=$this->getColumns($tablename); //$clos=implode(,,$columnname); //将列名数组转换为字符串 $data=json_decode($objstr,true); //将json格式的字符串转换为关联数组 $sets=array(); foreach($columnname as $value) { //列名不等于主键名获取值 if($prekeyname!=$value) { //set $value=$data[$value]; array_push($sets,"$value=$data[$value]");//接好的set语句部分 } } //$sets数组转化为字符串 $stringsets=implode(,,$sets); //echo $stringsets; /* * SQL:update $tablename set ..... where $prekeyname=$data[$prekeyname]; * */ $sql=<<<SQL update $tablename set $stringsets where $prekeyname=$data[$prekeyname]; SQL; $res=mysqli_query($dbc,$sql); if($res) { return true; }else{ return false; } }else{ echo "连接错误"; } } /* *获取表的所有列名 *@param:$tablename:表名 */ function getColumns($tablename) { $dbc=@mysqli_connect(localhost,root,1234,information_schema); if(!$dbc) { echo "Connect Error".mysqli_connect_error($dbc); }else { //连接成功,从表COLUMNS获取表的所有列名 $sql="select COLUMN_NAME from columns where TABLE_NAME=$tablename"; $res=@mysqli_query($dbc,$sql); $items=array(); if($res) { while($row=mysqli_fetch_array($res,MYSQLI_ASSOC)) { $columnname=$row[COLUMN_NAME]; array_push($items,$columnname); } return $items; mysqli_close($dbc); } else{ echo "查询失败,请检查SQL语句!"; } } } 以上就是本文全部内容,希望大家喜欢 。 |