<?php
ini_set('memory_limit', '-1');
$con=mysql_connect("192.168.1.198","open","123456");
if($con){    for($i=0;$i<10;$i++){//10个库$sql="drop database cloude_{$i};";//删库 谨慎mysql_query($sql);$sql="create database cloude_{$i} default character set utf8 collate utf8_general_ci;";$do=mysql_query($sql,$con)or die(mysql_error());if($do){mysql_select_db("cloude_{$i}",$con);mysql_query("set name gtf8");for($j=0;$j<10;$j++){        //10个表$sql="drop table if exists user_{$j};";mysql_query($sql);$sql="create table user_{$j}(id char(36) not null primary key,name char(15) not null default '',password char(32) not null default '',sex char(1) not null default '男')engine=InnoDB;";$do=mysql_query($sql,$con) or die(mysql_error());if($do){//echo "create table user_{$j} successful! <br/>";}else{//echo "create error!";}}}}
}else{echo "connect error!!!!";
}

<?php
class Config{  public $dsn;  public $user;  public $password;  public $dbname; //分库分表后得到的数据库名public $table; //分库分表后得到的表名private static $config;//mysql配置数组private static $configFile = 'mysql.php'; //配置文件路径 public function __construct($dbname, $table, $id = 0){  if (is_null(static::$config)) {  $config = include(static::$configFile);  static::$config = $config;  }  $config = static::$config;  if (isset($config['shared']) && isset($config['shared'][$dbname])) {  $dbconfig = $config['shared'][$dbname];  $id = is_numeric($id) ? (int)$id : crc32($id);  $database_id = ($id / $dbconfig['database_split'][0]) % $dbconfig['database_split'][1];  $table_id = ($id / $dbconfig['table_split'][0]) % $dbconfig['table_split'][1];  foreach ($dbconfig['host'] as $key => $conf) {  list($from, $to) = explode('-', $key);  if ($from <= $database_id && $database_id <= $to) {  $the_config = $conf;  }  }  $this->dbname = $dbname . '_' . $database_id;  $this->table = $table . '_' . $table_id;  } else {  $this->dbname = $dbname;  $this->table = $table;  $the_config = $config['db'][$dbname];  }  $c = $the_config;  if (isset($c['unix_socket']) && $c['unix_socket']) {  $this->dsn = sprintf('mysql:dbname=%s;unix_socket=%s', $this->dbname, $c['unix_socket']);  } else {  $this->dsn = sprintf('mysql:dbname=%s;host=%s;port=%s', $this->dbname, $c['host'], $c['port']);  }  $this->user = $c['user'];  $this->password = $c['password'];  }  }

<?php
$default = array(  'unix_socket' => null,  'host' => '192.168.1.198',  'port' => '3306',  'user' => 'open',  'password' => '123456',
);
$db_199 = array(  'unix_socket' => null,  'host' => '192.168.1.199',  'port' => '3306',  'user' => 'open',  'password' => '123456',
);
$config = array(  // 不进行分库分表的数据库  'db' => array(  'hadoop' => $default,  ),  // 分库分表  'shared' => array(  'cloude' => array(  'host' => array(  /** * 编号为 0 到 4 的库使用的链接配置 */ '0-4' => $default,  /** * 编号为 5 到 9 的库使用的链接配置 */ '5-9' => $db_199,   ),  // 分库分表规则  /** * 下面的配置对应10库10表* 如果根据 uid 进行分表，假设 uid 为 224，对应的库表为： *  (224 / 1) % 10 = 4 为编号为 4 的库 *  (224 / 10) % 10 = 1 为编号为 2 的表 */ 'database_split' => array(1, 10),  'table_split' => array(10, 10),  ),  ),
);
return $config;

<?php
require_once 'Config.php';//引入配置信息
class Model{  public $config;        //数据库配置public $connection;    //pdoprotected $dbnamePrefix; //库前缀如cloude_50 前缀为cloude protected $tablePrefix;  //表前缀protected $dbname;    //分库分表后对应的库protected $table;     //分库分表后对应的库表public function __construct($id){  $this->config = new Config($this->dbnamePrefix, $this->tablePrefix, $id);                     //根据id找到对应库和表$this->connection = new Pdo($this->config->dsn, $this->config->user, $this->config->password);//实例化pdo  $this->connection->exec("set names utf8");   $this->dbname = $this->config->dbname;$this->table = $this->config->table;  }  public function update(array $data, array $where = array()){  }  public function select(array $condition){ $sqlwhere='';if(!empty($condition)){   foreach ($condition as $field => $value) {  $where[] = '`'.$field.'`='."'".addslashes($value)."'";  }  $sqlwhere .= ' '.implode(' and ', $where);   }$sql="select * from ".$this->dbname.'.'.$this->table;if($sqlwhere){$sql.=" where $sqlwhere";}$res=$this->connection->query($sql);$data['data']=$res->fetchAll(PDO::FETCH_ASSOC);$data['info']=array("dsn"=>$this->config->dsn,"dbname"=>$this->dbname,"table"=>$this->table,"sql"=>$sql);return $data;   }  public function insert(array $arrData) {$name = $values = '';$flag = $flagV = 1;$true = is_array( current($arrData) );//判断是否一次插入多条数据if($true) {//构建插入多条数据的sql语句foreach($arrData as $arr) {$values .= $flag ? '(' : ',(';foreach($arr as $key => $value) {if($flagV) {if($flag) $name .= "$key";$values .= "'$value'";$flagV = 0;} else {if($flag) $name .= ",$key";$values .= ",'$value'";}}$values .= ') ';$flag = 0;$flagV = 1;}} else {//构建插入单条数据的sql语句foreach($arrData as $key => $value) {if($flagV) {$name = "$key";$values = "('$value'";$flagV = 0;} else {$name .= ",$key";$values .= ",'$value'";}}$values .= ") ";}$sql = "insert into ".$this->dbname.'.'.$this->table." ($name) values $values";if( ($rs = $this->connection->exec($sql) ) > 0 ) {return array("dsn"=>$this->config->dsn,"dbname"=>$this->dbname,"table"=>$this->table,"sql"=>$sql);}return false;}public function query($sql){  return $this->connection->query($sql);  }
}

<?php
require 'Config.php';
require 'Model.php';
class User extends Model
{  protected $dbnamePrefix = 'cloude';  protected $tablePrefix = 'user';
}
//生成唯一uuid
function create_uuid($prefix = ""){    //可以指定前缀$str = md5(uniqid(mt_rand(), true));   $uuid  = substr($str,0,8) . '-';   $uuid .= substr($str,8,4) . '-';   $uuid .= substr($str,12,4) . '-';   $uuid .= substr($str,16,4) . '-';   $uuid .= substr($str,20,12);   return $prefix . $uuid;
}$userId=create_uuid();
$user = new User($userId);
$data=array('id'=>$userId,'name'=>'大明'.$userId,'password'=>'14e1b600b1fd579f47433b88e8d85291','sex'=>'男');
if($result=$user->insert($data)){echo '插入成功：','<pre/>';print_r($result);
}$condition=array("id"=>$userId);
$list=$user->select($condition);
if($list){echo '查询成功：','<pre/>';print_r($list);
}