mysql大数据分表记录app用户的坐标数据

1 ‘DB_CONFIG2‘=>array(
2      ‘db_type‘=>‘mysql‘,
3      ‘db_user‘=>‘root‘,
4      ‘db_pwd‘=>‘‘,
5      ‘db_host‘=>‘localhost‘,
6      ‘db_port‘=>‘3306‘,
7      ‘db_name‘=>‘test‘,
8  ),

1 CREATE TABLE `create_id` (
2   `id` bigint(20) NOT NULL AUTO_INCREMENT,
3   PRIMARY KEY (`id`)
4 ) ENGINE=MyISAM DEFAULT CHARSET=utf8 COMMENT=‘自增ID表‘;

  1 class TestAction extends Action {
  2    
  3     function _initialize(){
  4         $this->db_2= M()->db(2,"DB_CONFIG2");
  5         $this->union_sql="CREATE TABLE IF NOT EXISTS `%s` (
  6   `id` int(11) NOT NULL,
  7   `longitude` decimal(10,6) NOT NULL COMMENT ‘经度‘,
  8   `latitude` decimal(10,6) NOT NULL COMMENT ‘纬度‘,
  9   `addtime` int(11) NOT NULL COMMENT ‘添加时间‘,
 10   `uid` int(11) NOT NULL COMMENT ‘用户ID‘,
 11   PRIMARY KEY (`id`)
 12 ) ENGINE=MRG_MyISAM DEFAULT CHARSET=utf8 INSERT_METHOD=LAST UNION=(`%s`);";
 13         $this->num_sql="CREATE TABLE IF NOT EXISTS `%s` (
 14   `id` int(11) NOT NULL,
 15   `longitude` decimal(10,6) NOT NULL COMMENT ‘经度‘,
 16   `latitude` decimal(10,6) NOT NULL COMMENT ‘纬度‘,
 17   `addtime` int(11) NOT NULL COMMENT ‘添加时间‘,
 18   `uid` int(11) NOT NULL COMMENT ‘用户ID‘,
 19   PRIMARY KEY (`id`)
 20 ) ENGINE=MyISAM DEFAULT CHARSET=utf8;";
 21         
 22     }
 23 
 24     public function index() {
 25        $uid=228; 
 26        $id = 10000099;
 27        //$id = $this->create_id();//生成自增ID
 28        //$uid=trim($_GET[‘uid‘]);
 29        $union_table_name="point_".$uid;//总表表名
 30        //新增记录分配分表名
 31        $num_table_name= $this->get_data_table($uid,$id);
 32        //分表名拼接
 33        $union_table_string=$this->get_union_string($uid,$id);
 34        //分表语句 
 35        $num_sql=sprintf($this->num_sql,$num_table_name);
 36        $this->execute($num_sql);//新建分表
 37        //总表语句  
 38        $union_sql=sprintf($this->union_sql,$union_table_name,$union_table_string);    
 39        echo $union_sql;
 40        $re1= $this->execute($union_sql);//创建总表
 41        echo ($this->db_2->getDbError());
 42       
 43        //新增记录
 44        $re=$this->execute("INSERT INTO $num_table_name (`id`, `longitude`, `latitude`, `addtime`, `uid`) VALUES (‘$id‘, ‘1111.000000‘, ‘2222.000000‘, ‘22222‘, ‘$uid‘);");
 45        
 46        if($re){
 47            echo json_encode(array("status"=>1,"info"=>true));
 48        }else{
 49            echo json_encode(array("status"=>0,"info"=>false));
 50        }
 51        
 52        
 53     }
 54      
 55    
 56     /**
 57      * 创建一个自增主键
 58      * @return int
 59      */
 60     private function create_id(){
 61       $sql = "insert into create_id (id) values(‘‘)";
 62       $this->db_2->execute($sql);
 63       return $this->db_2->getLastInsID();
 64     }
 65     
 66     /**
 67      * 获得表名
 68      * @return string
 69      */
 70     private function get_data_table($uid=null,$id=null){
 71         if(empty($uid)||empty($id)){
 72             return false;
 73         }
 74         return ‘point_‘.$uid.‘_‘.$this->get_table_num($id);
 75     }
 76     
 77     /**
 78      * 获得记录所在表序号
 79      * @param  $id  记录ID
 80      * @param  $max 表最大记录数
 81      * @return int
 82      */
 83     private function get_table_num($id,$max=10000000){
 84         $num = ($id<$max) ? 1 : intval($id/$max); //整除取整，默认1
 85         $add =  ($id%$max)>0 && ($id>$max)  ?1:0;//有余数，序号加1
 86         return $num+$add;
 87     }
 88     
 89     /**
 90      * 判断表是否存在
 91      */
 92     private function table_exit_create($table=null){
 93      return $this->db_2->query("show tables like ‘%{$table}%‘"); 
 94 //       return $this->db_2->query("desc {$table}"); 
 95     }
 96     
 97     
 98     /**
 99      * 建表
100      * @return bool 
101      */
102     private function execute($sql){
103         return $this->db_2->execute($sql); 
104     }
105     
106     /**
107      * 生成拼接分表名字符串
108      * @param type $uid
109      * @param type $id
110      * @return string
111      */
112     private function get_union_string($uid=null,$id=null){
113        $res = $this->table_exit_create("point_".$uid."_");
114        if($res){
115            if(count($res)>1){
116                $arr=array();
117                foreach($res as $v){
118                    $arr[]=$v["Tables_in_test (%point_".$uid."_%)"];
119                }
120               $str= implode(‘,‘,$arr);
121            }else{
122             $str= "point_".$uid."_".$this->get_table_num($id);  
123            }
124         }else{
125             $str= "point_".$uid."_".$this->get_table_num($id);
126         }
127         
128          return $str;
129       
130        
131     }