memDB包的使用方法

admin

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

功能函数如下：

1. /*
   
2. * 001:相关的mem操作
   
3. */
   
4. function mdb_tick()
   
5. 
   
6. 
   
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){
    
13. 
    
14. /*
    
15. * 003: get
    
16. */
    
17. function mdb_query($key){
    
18. 
    
19. /*
    
20. * 004: 专门用于记录index的信息
    
21. */
    
22. function save_index_info($name,$tick){
    
23. 
    
24. /*
    
25. *  005: 系统rowid的实现
    
26. */
    
27. function get_rowid(){
    
28. 
    
29. 
    
30. /*
    
31. * 006: 系统seq的实现
    
32. */
    
33. function next_val($seqname,$maxnum=100){
    
34. 
    
35. 
    
36. /*
    
37. * 007: 向消息环中加入消息到队列
    
38. */
    
39. function loop_add($loopname,$msg){
    
40. 
    
41. 
    
42. /*
    
43. * 008: 读消息环中的消息
    
44. */
    
45. function loop_read($loopname){
    
46. 
    
47. 
    
48. /*
    
49. * 009: 初始化一些系统参数
    
50. */
    
51. function init_setting(){
    
52. 
    
53. 
    
54. /*
    
55. * 010: 返回memDb的索引表
    
56. */
    
57. function getIndexTable($query=array()){

复制代码

admin

使用范例：

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);
   
7. 
   
8.         $object = new StdClass;
   
9.         $object->attribute = 'test';
   
10.         mdb_set_2("obj_key1", $object);
    
11. 
    
12.         $array = Array('assoc'=>123, 345, 567);
    
13.         mdb_set_2("arr_key1", $array);
    
14. 
    
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 />";
    
21. 
    
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

节选自wiki_kb

1. <?php
   
2. 
   
3. ob_start();
   
4. 
   
5. 
   
6. //Created by syant / 2021
   
7. //获得R102的相关信息
   
8. 
   
9. require_once("memdb.phar");        
   
10. require_once("phar://memdb.phar/mem.inc.php");
    
11. require_once("phar://memdb.phar/mem.func.php");
    
12. 
    
13. //---   Json Start   ---
    
14. header('Content-type: text/json; charset=utf-8');
    
15. 
    
16. $data=array(
    
17.         "tag"=>418,
    
18.         "tick"=>"",
    
19.         "msg"=>"start...",
    
20.         "output"=>0,
    
21.         "line"=>array(),
    
22.         "alarm"=>false,
    
23.         "alarmmsg"=>"",
    
24. );
    
25. 
    
26. //===   Json Start   ===
    
27. 
    
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);
        }
}