$this->db(1,"mysql://root:123456@localhost:3306/test")->query("查询sql");//数据库连接信息可放在配置文件
$this->db(1)->query("查询sql");//下次直接使用编号1定位

server1：192.168.1.198

server2：192.168.1.199

<?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; //pdo
protected $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); 
} 
}
1

<?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);
}