深圳全飞鸿

标题: memDB包的使用方法 [打印本页]
作者: admin    时间: 2019-5-14 14:31
标题: memDB包的使用方法
  1. $phar["mem.inc.php"]  = file_get_contents($srcRoot . "mem.inc.php");          //create;
  2. $phar["mem.func.php"]  = file_get_contents($srcRoot . "mem.func.php");  //incoming data
  3. $phar["mem.tools.php"] = file_get_contents($srcRoot . "mem.tools.php"); //outcoming data  已取消  
  4. $phar["mem.schema.php"] = file_get_contents($srcRoot . "mem.schema.php");
  5. $phar["mem.dump.php"] = file_get_contents($srcRoot . "mem.dump.php");
  6. $phar["mem.hello.php"] = file_get_contents($srcRoot . "mem.hello.php");
复制代码

作者: admin    时间: 2019-5-14 16:53
功能函数如下：
  1. /*
  2. * 001:相关的mem操作
  3. */
  4. function mdb_tick()


  7. /*
  8. *  002 : set
  9. */
  10. function mdb_set_2($key, $value){
  11. function mdb_set_3($key, $value , $tick = 1*60*60){
  12. function mdb_add_3($key, $value , $tick = 1*60*60){

  14. /*
  15. * 003: get
  16. */
  17. function mdb_query($key){

  19. /*
  20. * 004: 专门用于记录index的信息
  21. */
  22. function save_index_info($name,$tick){

  24. /*
  25. *  005: 系统rowid的实现
  26. */
  27. function get_rowid(){


  30. /*
  31. * 006: 系统seq的实现
  32. */
  33. function next_val($seqname,$maxnum=100){


  36. /*
  37. * 007: 向消息环中加入消息到队列
  38. */
  39. function loop_add($loopname,$msg){


  42. /*
  43. * 008: 读消息环中的消息
  44. */
  45. function loop_read($loopname){


  48. /*
  49. * 009: 初始化一些系统参数
  50. */
  51. function init_setting(){


  54. /*
  55. * 010: 返回memDb的索引表
  56. */
  57. function getIndexTable($query=array()){
复制代码
作者: admin    时间: 2019-5-14 17:21
使用范例：

  1. require_once("memdb.phar");       
  2. require_once("phar://memdb.phar/mem.inc.php");
  3. require_once("phar://memdb.phar/mem.func.php");
  4.         $t=getTickCount();
  5.         mdb_set_2("str_key1", "String to store in memcached");
  6.         mdb_set_2("num_key1", 123);

  8.         $object = new StdClass;
  9.         $object->attribute = 'test';
  10.         mdb_set_2("obj_key1", $object);

  12.         $array = Array('assoc'=>123, 345, 567);
  13.         mdb_set_2("arr_key1", $array);

  15.         var_dump(mdb_query('str_key1')); echo "<br />";       
  16.         var_dump(mdb_query('num_key1')); echo "<br />";       
  17.         var_dump(mdb_query('obj_key1')); echo "<br />";       
  18.         var_dump(mdb_query('arr_key1')); echo "<br />";
  19.         $t=getTickCount()-$t;
  20.         echo "<font color=blue>time: {$t}<br />";

  22. echo get_rowid()."<br />";
  23. echo get_rowid()."<br />";
  24. echo get_rowid()."<br />";
  25. echo get_rowid()."<br />";
  26. echo get_rowid()."<br />";
  27. echo get_rowid()."<br />";
  28. echo get_rowid()."<br />";
复制代码
作者: zhgc    时间: 2021-8-17 14:48
本帖最后由 zhgc 于 2021-8-17 14:51 编辑

节选自wiki_kb

  1. <?php

  3. ob_start();


  6. //Created by syant / 2021
  7. //获得R102的相关信息

  9. require_once("memdb.phar");        
  10. require_once("phar://memdb.phar/mem.inc.php");
  11. require_once("phar://memdb.phar/mem.func.php");

  13. //---   Json Start   ---
  14. header('Content-type: text/json; charset=utf-8');

  16. $data=array(
  17.         "tag"=>418,
  18.         "tick"=>"",
  19.         "msg"=>"start...",
  20.         "output"=>0,
  21.         "line"=>array(),
  22.         "alarm"=>false,
  23.         "alarmmsg"=>"",
  24. );

  26. //===   Json Start   ===

  28. //---  参数处理   ---
  29. $line=$_GET["line"];
复制代码

$key=substr($datestr,0,10);
mdb_delete($key);  //当前这一个时都要重新计算

foreach($workclass as $k=>$v){
        //遍历，可能内存清空了
        $workdate=$v["w"];       
        $workhh=$v["h"];       
        $key=$workdate.sprintf("%02d",$workhh);
        $mm=mdb_query($key);
        if(is_array($mm)){
                //有保存的数据，不处理
        }else{
                $sql="select  line_name,group_name,sum(pass_qty) pass_qty,sum(fail_qty) fail_qty,sum(repass_qty) repass_qty,sum(refail_qty) refail_qty
                                        from sfc.r_station_rec_t where work_date='{$workdate}'
                                        and work_section=$workhh group by line_name,group_name";       
                $result = mysqli_query($db,$sql);
                $r102=array();
                while($row = mysqli_fetch_assoc($result)){
                        $r102[]=$row;
                }
                mysqli_free_result($result);
                mdb_set_2($key,$r102);
        }
}






欢迎光临 深圳全飞鸿 (http://www.nagomes.com/disc/) Powered by Discuz! X3.2