211 lines
9.1 KiB
PHP
211 lines
9.1 KiB
PHP
<?php
|
|
defined ( 'IN_TS' ) or die ( 'Access Denied.' );
|
|
/**
|
|
* tsDbLinker
|
|
* 数据库的表间关联程序
|
|
*/
|
|
class tsDbLinker
|
|
{
|
|
/**
|
|
* 模型对象
|
|
*/
|
|
private $model_obj = null;
|
|
|
|
/**
|
|
* 预准备的结果
|
|
*/
|
|
private $prepare_result = null;
|
|
|
|
/**
|
|
* 运行的结果
|
|
*/
|
|
private $run_result = null;
|
|
|
|
/**
|
|
* 可支持的关联方法
|
|
*/
|
|
private $methods = array('find','findBy','findAll','run','create','delete','deleteByPk','update');
|
|
/**
|
|
* 是否启用全部关联
|
|
*/
|
|
public $enabled = TRUE;
|
|
/**
|
|
* 函数式使用模型辅助类的输入函数
|
|
*/
|
|
public function __input(& $obj, $args = null){
|
|
$this->model_obj = $obj;
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* 开发者可以通过tsDbLinker()->run($result)对已经返回的数据进行关联findAll查找
|
|
* @param result 返回的数据
|
|
*/
|
|
public function run($result = FALSE){
|
|
if( FALSE == $result )return FALSE;
|
|
$this->run_result = $result;
|
|
return $this->__call('run', null);
|
|
}
|
|
|
|
/**
|
|
* 魔术函数，支持多重函数式使用类的方法
|
|
*
|
|
* 在tsDbLinker类中，__call执行了tsApp继承类的相关操作，以及按关联的描述进行了对关联数据模型类的操作。
|
|
*/
|
|
public function __call($func_name, $func_args){
|
|
if( in_array( $func_name, $this->methods ) && FALSE != $this->enabled ){
|
|
if( 'delete' == $func_name || 'deleteByPk' == $func_name )$maprecords = $this->prepare_delete($func_name, $func_args);
|
|
if( null != $this->run_result ){
|
|
$run_result = $this->run_result;
|
|
}elseif( !$run_result = call_user_func_array(array($this->model_obj, $func_name), $func_args) ){
|
|
if( 'update' != $func_name )return FALSE;
|
|
}
|
|
if( null != $this->model_obj->linker && is_array($this->model_obj->linker) ){
|
|
foreach( $this->model_obj->linker as $linkey => $thelinker ){
|
|
if( !isset($thelinker['map']) )$thelinker['map'] = $linkey;
|
|
if( FALSE == $thelinker['enabled'] )continue;
|
|
$thelinker['type'] = strtolower($thelinker['type']);
|
|
if( 'find' == $func_name || 'findBy' == $func_name ){
|
|
$run_result[$thelinker['map']] = $this->do_select( $thelinker, $run_result );
|
|
}elseif( 'findAll' == $func_name || 'run' == $func_name ){
|
|
foreach( $run_result as $single_key => $single_result )
|
|
$run_result[$single_key][$thelinker['map']] = $this->do_select( $thelinker, $single_result );
|
|
}elseif( 'create' == $func_name ){
|
|
$this->do_create( $thelinker, $run_result, $func_args );
|
|
}elseif( 'update' == $func_name ){
|
|
$this->do_update( $thelinker, $func_args );
|
|
}elseif( 'delete' == $func_name || 'deleteByPk' == $func_name ){
|
|
$this->do_delete( $thelinker, $maprecords );
|
|
}
|
|
}
|
|
}
|
|
return $run_result;
|
|
}elseif(in_array($func_name, $GLOBALS['G_SP']["auto_load_model"])){
|
|
return aac($func_name)->__input($this, $func_args);
|
|
}else{
|
|
return call_user_func_array(array($this->model_obj, $func_name), $func_args);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 私有函数，辅助删除数据操作
|
|
* @param func_name 需要执行的函数名称
|
|
* @param func_args 函数的参数
|
|
*/
|
|
private function prepare_delete($func_name, $func_args)
|
|
{
|
|
if('deleteByPk'==$func_name){
|
|
return $this->model_obj->findAll(array($this->model_obj->pk=>$func_args[0]));
|
|
}else{
|
|
return $this->model_obj->findAll($func_args[0]);
|
|
}
|
|
}
|
|
/**
|
|
* 私有函数，进行关联删除数据操作
|
|
* @param thelinker 关联的描述
|
|
* @param maprecords 对应的记录
|
|
*/
|
|
private function do_delete( $thelinker, $maprecords ){
|
|
if( FALSE == $maprecords )return FALSE;
|
|
foreach( $maprecords as $singlerecord ){
|
|
if(!empty($thelinker['condition'])){
|
|
if( is_array($thelinker['condition']) ){
|
|
$fcondition = array($thelinker['fkey']=>$singlerecord[$thelinker['mapkey']]) + $thelinker['condition'];
|
|
}else{
|
|
$fcondition = "{$thelinker['fkey']} = '{$singlerecord[$thelinker['mapkey']]}' AND {$thelinker['condition']}";
|
|
}
|
|
}else{
|
|
$fcondition = array($thelinker['fkey']=>$singlerecord[$thelinker['mapkey']]);
|
|
}
|
|
$returns = aac($thelinker['fclass'])->delete($fcondition);
|
|
}
|
|
return $returns;
|
|
}
|
|
/**
|
|
* 私有函数，进行关联更新数据操作
|
|
* @param thelinker 关联的描述
|
|
* @param func_args 进行操作的参数
|
|
*/
|
|
private function do_update( $thelinker, $func_args ){
|
|
if( !is_array($func_args[1][$thelinker['map']]) )return FALSE;
|
|
if( !$maprecords = $this->model_obj->findAll($func_args[0]))return FALSE;
|
|
foreach( $maprecords as $singlerecord ){
|
|
if(!empty($thelinker['condition'])){
|
|
if( is_array($thelinker['condition']) ){
|
|
$fcondition = array($thelinker['fkey']=>$singlerecord[$thelinker['mapkey']]) + $thelinker['condition'];
|
|
}else{
|
|
$fcondition = "{$thelinker['fkey']} = '{$singlerecord[$thelinker['mapkey']]}' AND {$thelinker['condition']}";
|
|
}
|
|
}else{
|
|
$fcondition = array($thelinker['fkey']=>$singlerecord[$thelinker['mapkey']]);
|
|
}
|
|
$returns = aac($thelinker['fclass'])->update($fcondition, $func_args[1][$thelinker['map']]);
|
|
}
|
|
return $returns;
|
|
}
|
|
/**
|
|
* 私有函数，进行关联新增数据操作
|
|
* @param thelinker 关联的描述
|
|
* @param newid 主表新增记录后的关联ID
|
|
* @param func_args 进行操作的参数
|
|
*/
|
|
private function do_create( $thelinker, $newid, $func_args ){
|
|
if( !is_array($func_args[0][$thelinker['map']]) )return FALSE;
|
|
if('hasone'==$thelinker['type']){
|
|
$newrows = $func_args[0][$thelinker['map']];
|
|
$newrows[$thelinker['fkey']] = $newid;
|
|
return aac($thelinker['fclass'])->create($newrows);
|
|
}elseif('hasmany'==$thelinker['type']){
|
|
if(array_key_exists(0,$func_args[0][$thelinker['map']])){ // 多个新增
|
|
foreach($func_args[0][$thelinker['map']] as $singlerows){
|
|
$newrows = $singlerows;
|
|
$newrows[$thelinker['fkey']] = $newid;
|
|
$returns = aac($thelinker['fclass'])->create($newrows);
|
|
}
|
|
return $returns;
|
|
}else{ // 单个新增
|
|
$newrows = $func_args[0][$thelinker['map']];
|
|
$newrows[$thelinker['fkey']] = $newid;
|
|
return aac($thelinker['fclass'])->create($newrows);
|
|
}
|
|
}
|
|
}
|
|
/**
|
|
* 私有函数，进行关联查找数据操作
|
|
* @param thelinker 关联的描述
|
|
* @param run_result 主表执行查找后返回的结果
|
|
*/
|
|
private function do_select( $thelinker, $run_result ){
|
|
if(empty($thelinker['mapkey']))$thelinker['mapkey'] = $this->model_obj->pk;
|
|
if( 'manytomany' == $thelinker['type'] ){
|
|
$do_func = 'findAll';
|
|
$midcondition = array($thelinker['mapkey']=>$run_result[$thelinker['mapkey']]);
|
|
if( !$midresult = aac($thelinker['midclass'])->findAll($midcondition,null,$thelinker['fkey']) )return FALSE;
|
|
$tmpkeys = array();foreach( $midresult as $val )$tmpkeys[] = "'".$val[$thelinker['fkey']]."'";
|
|
if(!empty($thelinker['condition'])){
|
|
if( is_array($thelinker['condition']) ){
|
|
$fcondition = "{$thelinker['fkey']} in (".join(',',$tmpkeys).")";
|
|
foreach( $thelinker['condition'] as $tmpkey => $tmpvalue )$fcondition .= " AND {$tmpkey} = '{$tmpvalue}'";
|
|
}else{
|
|
$fcondition = "{$thelinker['fkey']} in (".join(',',$tmpkeys).") AND {$thelinker['condition']}";
|
|
}
|
|
}else{
|
|
$fcondition = "{$thelinker['fkey']} in (".join(',',$tmpkeys).")";
|
|
}
|
|
}else{
|
|
$do_func = ( 'hasone' == $thelinker['type'] ) ? 'find' : 'findAll';
|
|
if(!empty($thelinker['condition'])){
|
|
if( is_array($thelinker['condition']) ){
|
|
$fcondition = array($thelinker['fkey']=>$run_result[$thelinker['mapkey']]) + $thelinker['condition'];
|
|
}else{
|
|
$fcondition = "{$thelinker['fkey']} = '{$run_result[$thelinker['mapkey']]}' AND {$thelinker['condition']}";
|
|
}
|
|
}else{
|
|
$fcondition = array($thelinker['fkey']=>$run_result[$thelinker['mapkey']]);
|
|
}
|
|
}
|
|
if(TRUE == $thelinker['countonly'])$do_func = "findCount";
|
|
return aac($thelinker['fclass'])->$do_func($fcondition, $thelinker['sort'], $thelinker['field'], $thelinker['limit'] );
|
|
}
|
|
}
|