<?php
// +----------------------------------------------------------------------
// | ThinkPHP [ WE CAN DO IT JUST THINK IT ]
// +----------------------------------------------------------------------
// | Copyright (c) 2010 http://thinkphp.cn All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: luofei614 <www.3g4k.com>
// +----------------------------------------------------------------------
// $Id: SaeKVClient.class.php 2766 2012-02-20 15:58:21Z luofei614@gmail.com $
/**
*KVDB模拟器
*使用到数据库表think_sae_kv
*/
class SaeKvClient extends SaeObject{

public function delete($key){
        $ret=self::$db->runSql("delete from sae_kv where k='$key'");
	return $ret?true:false;
}

public function get($key){
        $data=self::$db->getLine("select * from sae_kv where k='$key'");
	$value=$this->output(array($data));
	$ret=$value[$key];
	return $ret?$ret:false;
}
public function get_info(){
//todu
}
public function init(){
	return true;
}
public function mget($ary){
	if(empty($ary)) return null;
        array_walk($ary,function(&$r){
            $r="'$r'";
        });
        $where=implode(',', $ary);
        $data=self::$db->getData("select * from sae_kv where k in($where)");
	return $this->output($data);
}
public function pkrget($prefix_key,$count,$start_key){
//todu
}
public function set($key,$value){
	if(!is_string($value)){
		//如果不是字符串序列化
		$value=serialize($value);
		$isobj=1;
	}else{
		$isobj=0;
	}
	//判断是否存在键
	if(self::$db->getVar("select count(*) from sae_kv where k='$key'")>0){
                $ret=self::$db->runSql("update sae_kv set v='$value',isobj='$isobj' where k='$key'");
	}else{
                $ret=self::$db->runSql("insert into sae_kv(k,v,isobj) values('$key','$value','$isobj')");
	}
	return $ret?true:false;
}

private function output($arr){
	$ret=array();
	foreach($arr as $k=>$ary){
		$ret[$ary['k']]=$ary['isobj']?unserialize($ary['v']):$ary['v'];
	}
	return $ret;
}

}


?>