|
@@ -6,376 +6,376 @@ Lib::loadClass('Router');
|
|
|
|
|
|
|
|
class Schema_SystemObjectStorageAcl extends Core_AclSimpleSchemaBase {
|
|
class Schema_SystemObjectStorageAcl extends Core_AclSimpleSchemaBase {
|
|
|
|
|
|
|
|
- public $_simpleSchema = [
|
|
|
|
|
- 'root' => [
|
|
|
|
|
- '@namespace' => 'default_objects/SystemObject',
|
|
|
|
|
- '@primaryKey' => 'namespace',
|
|
|
|
|
- 'idZasob' => [ '@type' => 'xsd:integer' ],
|
|
|
|
|
- 'idDatabase' => [ '@type' => 'xsd:integer' ],
|
|
|
|
|
- 'namespace' => [ '@type' => 'xsd:string' ],
|
|
|
|
|
- '_rootTableName' => [ '@type' => 'xsd:string' ],
|
|
|
|
|
- '_type' => [ '@type' => 'xsd:string' ],
|
|
|
|
|
- 'hasStruct' => [ '@type' => 'xsd:integer' ], // 0 - removed, old, 1 - has config, structure
|
|
|
|
|
- 'isStructInstalled' => [ '@type' => 'xsd:integer' ], // installed
|
|
|
|
|
- 'isObjectActive' => [ '@type' => 'xsd:integer' ], // (0,1) - admin settings with restrictions: (hasStruct, isStructInstalled, all fields installed and with idZasob)
|
|
|
|
|
- 'description' => [ '@type' => 'xsd:string' ],
|
|
|
|
|
- 'name' => [ '@type' => 'p5:string' ],
|
|
|
|
|
- 'typeName' => [ '@type' => 'p5:string' ],
|
|
|
|
|
- 'nsPrefix' => [ '@type' => 'p5:string' ],
|
|
|
|
|
- 'reinstallLink' => [ '@type' => 'p5:www_link' ],
|
|
|
|
|
- // 'A_RECORD_CREATE_AUTHOR' => [ '@type' => 'xsd:string' , '@label' => 'autor' ],
|
|
|
|
|
- // 'A_RECORD_CREATE_DATE' => [ '@type' => 'xsd:date' , '@label' => 'utworzono' ],
|
|
|
|
|
- // 'A_RECORD_UPDATE_AUTHOR' => [ '@type' => 'xsd:string' , '@label' => 'zaktualizował' ],
|
|
|
|
|
- // 'A_RECORD_UPDATE_DATE' => [ '@type' => 'xsd:date', '@label' => 'zaktualizowano' ],
|
|
|
|
|
- 'field' => [ '@ref' => 'default_objects/SystemObjectField', '@maxOccurs' => 'unbounded' ]
|
|
|
|
|
- ]
|
|
|
|
|
- ];
|
|
|
|
|
- // public $_rootTableName = 'CRM_LISTA_ZASOBOW';
|
|
|
|
|
- public $_rootTableName = 'CRM_#CACHE_ACL_OBJECT';
|
|
|
|
|
- public $_version = '1';
|
|
|
|
|
|
|
+ public $_simpleSchema = [
|
|
|
|
|
+ 'root' => [
|
|
|
|
|
+ '@namespace' => 'default_objects/SystemObject',
|
|
|
|
|
+ '@primaryKey' => 'namespace',
|
|
|
|
|
+ 'idZasob' => [ '@type' => 'xsd:integer' ],
|
|
|
|
|
+ 'idDatabase' => [ '@type' => 'xsd:integer' ],
|
|
|
|
|
+ 'namespace' => [ '@type' => 'xsd:string' ],
|
|
|
|
|
+ '_rootTableName' => [ '@type' => 'xsd:string' ],
|
|
|
|
|
+ '_type' => [ '@type' => 'xsd:string' ],
|
|
|
|
|
+ 'hasStruct' => [ '@type' => 'xsd:integer' ], // 0 - removed, old, 1 - has config, structure
|
|
|
|
|
+ 'isStructInstalled' => [ '@type' => 'xsd:integer' ], // installed
|
|
|
|
|
+ 'isObjectActive' => [ '@type' => 'xsd:integer' ], // (0,1) - admin settings with restrictions: (hasStruct, isStructInstalled, all fields installed and with idZasob)
|
|
|
|
|
+ 'description' => [ '@type' => 'xsd:string' ],
|
|
|
|
|
+ 'name' => [ '@type' => 'p5:string' ],
|
|
|
|
|
+ 'typeName' => [ '@type' => 'p5:string' ],
|
|
|
|
|
+ 'nsPrefix' => [ '@type' => 'p5:string' ],
|
|
|
|
|
+ 'reinstallLink' => [ '@type' => 'p5:www_link' ],
|
|
|
|
|
+ // 'A_RECORD_CREATE_AUTHOR' => [ '@type' => 'xsd:string' , '@label' => 'autor' ],
|
|
|
|
|
+ // 'A_RECORD_CREATE_DATE' => [ '@type' => 'xsd:date' , '@label' => 'utworzono' ],
|
|
|
|
|
+ // 'A_RECORD_UPDATE_AUTHOR' => [ '@type' => 'xsd:string' , '@label' => 'zaktualizował' ],
|
|
|
|
|
+ // 'A_RECORD_UPDATE_DATE' => [ '@type' => 'xsd:date', '@label' => 'zaktualizowano' ],
|
|
|
|
|
+ 'field' => [ '@ref' => 'default_objects/SystemObjectField', '@maxOccurs' => 'unbounded' ]
|
|
|
|
|
+ ]
|
|
|
|
|
+ ];
|
|
|
|
|
+ // public $_rootTableName = 'CRM_LISTA_ZASOBOW';
|
|
|
|
|
+ public $_rootTableName = 'CRM_#CACHE_ACL_OBJECT';
|
|
|
|
|
+ public $_version = '1';
|
|
|
|
|
|
|
|
- // public function __construct($simpleSchema = null) {
|
|
|
|
|
- // parent::__construct($simpleSchema);
|
|
|
|
|
- // self::updateCacheIfNeeded(array($this, 'updateCache'));
|
|
|
|
|
- // }
|
|
|
|
|
|
|
+ // public function __construct($simpleSchema = null) {
|
|
|
|
|
+ // parent::__construct($simpleSchema);
|
|
|
|
|
+ // self::updateCacheIfNeeded(array($this, 'updateCache'));
|
|
|
|
|
+ // }
|
|
|
|
|
|
|
|
- // public static function updateCacheIfNeeded($updateCallback) {
|
|
|
|
|
- // static $_cacheUpdated = null;
|
|
|
|
|
- // if (null !== $_cacheUpdated) return;
|
|
|
|
|
- // $conf = DB::getPDO()->fetchFirst("
|
|
|
|
|
- // select (select CONF_VAL from CRM_CONFIG where CONF_KEY = 'SystemObject__last_cache_update_date') as lastCacheUpdate
|
|
|
|
|
- // , (select CONF_VAL from CRM_CONFIG where CONF_KEY = 'SystemObject__force_cache_update') as forceCacheUpdate
|
|
|
|
|
- // , (select CONF_VAL from CRM_CONFIG where CONF_KEY = 'SystemObject__schema_version') as schemaVersion
|
|
|
|
|
- // , (select CONF_VAL from CRM_CONFIG where CONF_KEY = 'tbl_indexer_CRM_PROCES_last_exec_end') as lastProcesIndexer
|
|
|
|
|
- // , (
|
|
|
|
|
- // select IF('N/S;' = A_RECORD_UPDATE_DATE or A_RECORD_UPDATE_DATE is null or '' = A_RECORD_UPDATE_DATE, A_RECORD_CREATE_DATE, A_RECORD_UPDATE_DATE) as lastUpdateDate
|
|
|
|
|
- // from CRM_LISTA_ZASOBOW_HIST
|
|
|
|
|
- // order by ID DESC
|
|
|
|
|
- // limit 1
|
|
|
|
|
- // ) as lastZasobyUpdate
|
|
|
|
|
- // ");
|
|
|
|
|
- // if ($conf['lastZasobyUpdate']) {// fix date format - convert to Mysql date time format '2002-05-30 09:00:00'
|
|
|
|
|
- // if (preg_match('/^\d\d\d\d\-\d\d\-\d\d\-\d\d:\d\d$/', $conf['lastZasobyUpdate'])) { // 'Y-m-d-H:i'
|
|
|
|
|
- // $conf['lastZasobyUpdate'] = substr($conf['lastZasobyUpdate'], 0, 10) . " " . substr($conf['lastZasobyUpdate'], 11) . ":00";
|
|
|
|
|
- // } else if (preg_match('/^\d\d\d\d\-\d\d\-\d\d\-\d\d:\d\d:\d\d$/', $conf['lastZasobyUpdate'])) { // 'Y-m-d-H:i:s'
|
|
|
|
|
- // $conf['lastZasobyUpdate'] = substr($conf['lastZasobyUpdate'], 0, 10) . " " . substr($conf['lastZasobyUpdate'], 11);
|
|
|
|
|
- // } else if (preg_match('/^\d\d\d\d\-\d\d\-\d\d\ \d\d:\d\d:\d\d$/', $conf['lastZasobyUpdate'])) {
|
|
|
|
|
- // $conf['lastZasobyUpdate'] = substr($conf['lastZasobyUpdate'], 0, 10) . " " . substr($conf['lastZasobyUpdate'], 11);
|
|
|
|
|
- // }
|
|
|
|
|
- // }
|
|
|
|
|
- // // $lastProcesIndexer = DB::getPDO()->fetchValue(" select CONF_VAL from CRM_CONFIG where CONF_KEY = 'tbl_indexer_CRM_PROCES_last_exec_end' ");
|
|
|
|
|
- // $updateReason = null;
|
|
|
|
|
- // if ('1' == $conf['forceCacheUpdate']) $updateReason = 'forceCacheUpdate = 1';
|
|
|
|
|
- // if (!$conf['lastCacheUpdate']) $updateReason = '!lastCacheUpdate';
|
|
|
|
|
- // if (!$conf['schemaVersion']) $updateReason = '!schemaVersion';
|
|
|
|
|
- // else if ($conf['schemaVersion'] < $this->_version) $updateReason = 'schemaVersion < ' . $this->_version;
|
|
|
|
|
- // if ($conf['lastCacheUpdate'] && $conf['lastZasobyUpdate'] && $conf['lastCacheUpdate'] < $conf['lastZasobyUpdate']) $updateReason = 'lastZasobyUpdate';
|
|
|
|
|
- // if ($updateReason) {
|
|
|
|
|
- // DBG::simpleLog('schema', "SystemObject: update cache reason '{$updateReason}' '" . json_encode($conf) . "'");
|
|
|
|
|
- // call_user_func($updateCallback);
|
|
|
|
|
- // }
|
|
|
|
|
- // DB::getPDO()->execSql("
|
|
|
|
|
- // insert into CRM_CONFIG (CONF_KEY, CONF_VAL)
|
|
|
|
|
- // values('SystemObject__last_cache_update_date', NOW())
|
|
|
|
|
- // on duplicate key update CONF_VAL = NOW()
|
|
|
|
|
- // ");
|
|
|
|
|
- // DB::getPDO()->execSql("
|
|
|
|
|
- // insert into CRM_CONFIG (CONF_KEY, CONF_VAL)
|
|
|
|
|
- // values('SystemObject__schema_version', {$this->_version})
|
|
|
|
|
- // on duplicate key update CONF_VAL = {$this->_version}
|
|
|
|
|
- // ");
|
|
|
|
|
- // if ('1' == $conf['forceCacheUpdate']) DB::getPDO()->execSql(" update CRM_CONFIG set CONF_VAL = '0' where CONF_KEY = 'SystemObject__force_cache_update' ");
|
|
|
|
|
- // $_cacheUpdated = true;
|
|
|
|
|
- // }
|
|
|
|
|
|
|
+ // public static function updateCacheIfNeeded($updateCallback) {
|
|
|
|
|
+ // static $_cacheUpdated = null;
|
|
|
|
|
+ // if (null !== $_cacheUpdated) return;
|
|
|
|
|
+ // $conf = DB::getPDO()->fetchFirst("
|
|
|
|
|
+ // select (select CONF_VAL from CRM_CONFIG where CONF_KEY = 'SystemObject__last_cache_update_date') as lastCacheUpdate
|
|
|
|
|
+ // , (select CONF_VAL from CRM_CONFIG where CONF_KEY = 'SystemObject__force_cache_update') as forceCacheUpdate
|
|
|
|
|
+ // , (select CONF_VAL from CRM_CONFIG where CONF_KEY = 'SystemObject__schema_version') as schemaVersion
|
|
|
|
|
+ // , (select CONF_VAL from CRM_CONFIG where CONF_KEY = 'tbl_indexer_CRM_PROCES_last_exec_end') as lastProcesIndexer
|
|
|
|
|
+ // , (
|
|
|
|
|
+ // select IF('N/S;' = A_RECORD_UPDATE_DATE or A_RECORD_UPDATE_DATE is null or '' = A_RECORD_UPDATE_DATE, A_RECORD_CREATE_DATE, A_RECORD_UPDATE_DATE) as lastUpdateDate
|
|
|
|
|
+ // from CRM_LISTA_ZASOBOW_HIST
|
|
|
|
|
+ // order by ID DESC
|
|
|
|
|
+ // limit 1
|
|
|
|
|
+ // ) as lastZasobyUpdate
|
|
|
|
|
+ // ");
|
|
|
|
|
+ // if ($conf['lastZasobyUpdate']) {// fix date format - convert to Mysql date time format '2002-05-30 09:00:00'
|
|
|
|
|
+ // if (preg_match('/^\d\d\d\d\-\d\d\-\d\d\-\d\d:\d\d$/', $conf['lastZasobyUpdate'])) { // 'Y-m-d-H:i'
|
|
|
|
|
+ // $conf['lastZasobyUpdate'] = substr($conf['lastZasobyUpdate'], 0, 10) . " " . substr($conf['lastZasobyUpdate'], 11) . ":00";
|
|
|
|
|
+ // } else if (preg_match('/^\d\d\d\d\-\d\d\-\d\d\-\d\d:\d\d:\d\d$/', $conf['lastZasobyUpdate'])) { // 'Y-m-d-H:i:s'
|
|
|
|
|
+ // $conf['lastZasobyUpdate'] = substr($conf['lastZasobyUpdate'], 0, 10) . " " . substr($conf['lastZasobyUpdate'], 11);
|
|
|
|
|
+ // } else if (preg_match('/^\d\d\d\d\-\d\d\-\d\d\ \d\d:\d\d:\d\d$/', $conf['lastZasobyUpdate'])) {
|
|
|
|
|
+ // $conf['lastZasobyUpdate'] = substr($conf['lastZasobyUpdate'], 0, 10) . " " . substr($conf['lastZasobyUpdate'], 11);
|
|
|
|
|
+ // }
|
|
|
|
|
+ // }
|
|
|
|
|
+ // // $lastProcesIndexer = DB::getPDO()->fetchValue(" select CONF_VAL from CRM_CONFIG where CONF_KEY = 'tbl_indexer_CRM_PROCES_last_exec_end' ");
|
|
|
|
|
+ // $updateReason = null;
|
|
|
|
|
+ // if ('1' == $conf['forceCacheUpdate']) $updateReason = 'forceCacheUpdate = 1';
|
|
|
|
|
+ // if (!$conf['lastCacheUpdate']) $updateReason = '!lastCacheUpdate';
|
|
|
|
|
+ // if (!$conf['schemaVersion']) $updateReason = '!schemaVersion';
|
|
|
|
|
+ // else if ($conf['schemaVersion'] < $this->_version) $updateReason = 'schemaVersion < ' . $this->_version;
|
|
|
|
|
+ // if ($conf['lastCacheUpdate'] && $conf['lastZasobyUpdate'] && $conf['lastCacheUpdate'] < $conf['lastZasobyUpdate']) $updateReason = 'lastZasobyUpdate';
|
|
|
|
|
+ // if ($updateReason) {
|
|
|
|
|
+ // DBG::simpleLog('schema', "SystemObject: update cache reason '{$updateReason}' '" . json_encode($conf) . "'");
|
|
|
|
|
+ // call_user_func($updateCallback);
|
|
|
|
|
+ // }
|
|
|
|
|
+ // DB::getPDO()->execSql("
|
|
|
|
|
+ // insert into CRM_CONFIG (CONF_KEY, CONF_VAL)
|
|
|
|
|
+ // values('SystemObject__last_cache_update_date', NOW())
|
|
|
|
|
+ // on duplicate key update CONF_VAL = NOW()
|
|
|
|
|
+ // ");
|
|
|
|
|
+ // DB::getPDO()->execSql("
|
|
|
|
|
+ // insert into CRM_CONFIG (CONF_KEY, CONF_VAL)
|
|
|
|
|
+ // values('SystemObject__schema_version', {$this->_version})
|
|
|
|
|
+ // on duplicate key update CONF_VAL = {$this->_version}
|
|
|
|
|
+ // ");
|
|
|
|
|
+ // if ('1' == $conf['forceCacheUpdate']) DB::getPDO()->execSql(" update CRM_CONFIG set CONF_VAL = '0' where CONF_KEY = 'SystemObject__force_cache_update' ");
|
|
|
|
|
+ // $_cacheUpdated = true;
|
|
|
|
|
+ // }
|
|
|
|
|
|
|
|
- public function updateCache($idDatabase = null) {
|
|
|
|
|
- DBG::simpleLog('schema', "SystemObject::updateCache...");
|
|
|
|
|
- // DB::getPDO()->execSql(" drop table if exists `{$this->_rootTableName}` "); // TODO: DBG
|
|
|
|
|
- DB::getPDO()->execSql("
|
|
|
|
|
- create table if not exists `{$this->_rootTableName}` (
|
|
|
|
|
- `idZasob` int(11) DEFAULT NULL,
|
|
|
|
|
- `idDatabase` int(11) NOT NULL,
|
|
|
|
|
- `namespace` varchar(255) DEFAULT '',
|
|
|
|
|
- `_rootTableName` varchar(255) DEFAULT '',
|
|
|
|
|
- `_type` varchar(255) DEFAULT '',
|
|
|
|
|
- `hasStruct` tinyint(1) NOT NULL DEFAULT 0 COMMENT 'has structure',
|
|
|
|
|
- `isStructInstalled` tinyint(1) NOT NULL DEFAULT 0 COMMENT 'has installed structure',
|
|
|
|
|
- `isObjectActive` tinyint(1) NOT NULL DEFAULT 0 COMMENT 'object is active',
|
|
|
|
|
- `description` varchar(255) DEFAULT '',
|
|
|
|
|
- UNIQUE KEY `idZasob` (idZasob),
|
|
|
|
|
- UNIQUE KEY `namespace` (namespace),
|
|
|
|
|
- KEY `isObjectActive` (isObjectActive)
|
|
|
|
|
- ) ENGINE=MyISAM DEFAULT CHARSET=latin2
|
|
|
|
|
- ");
|
|
|
|
|
- DB::getPDO()->execSql(" update `{$this->_rootTableName}` set hasStruct = 0 ");
|
|
|
|
|
- $idDefDB = DB::getPDO()->getZasobId();
|
|
|
|
|
|
|
+ public function updateCache($idDatabase = null) {
|
|
|
|
|
+ DBG::simpleLog('schema', "SystemObject::updateCache...");
|
|
|
|
|
+ // DB::getPDO()->execSql(" drop table if exists `{$this->_rootTableName}` "); // TODO: DBG
|
|
|
|
|
+ DB::getPDO()->execSql("
|
|
|
|
|
+ create table if not exists `{$this->_rootTableName}` (
|
|
|
|
|
+ `idZasob` int(11) DEFAULT NULL,
|
|
|
|
|
+ `idDatabase` int(11) NOT NULL,
|
|
|
|
|
+ `namespace` varchar(255) DEFAULT '',
|
|
|
|
|
+ `_rootTableName` varchar(255) DEFAULT '',
|
|
|
|
|
+ `_type` varchar(255) DEFAULT '',
|
|
|
|
|
+ `hasStruct` tinyint(1) NOT NULL DEFAULT 0 COMMENT 'has structure',
|
|
|
|
|
+ `isStructInstalled` tinyint(1) NOT NULL DEFAULT 0 COMMENT 'has installed structure',
|
|
|
|
|
+ `isObjectActive` tinyint(1) NOT NULL DEFAULT 0 COMMENT 'object is active',
|
|
|
|
|
+ `description` varchar(255) DEFAULT '',
|
|
|
|
|
+ UNIQUE KEY `idZasob` (idZasob),
|
|
|
|
|
+ UNIQUE KEY `namespace` (namespace),
|
|
|
|
|
+ KEY `isObjectActive` (isObjectActive)
|
|
|
|
|
+ ) ENGINE=MyISAM DEFAULT CHARSET=latin2
|
|
|
|
|
+ ");
|
|
|
|
|
+ DB::getPDO()->execSql(" update `{$this->_rootTableName}` set hasStruct = 0 ");
|
|
|
|
|
+ $idDefDB = DB::getPDO()->getZasobId();
|
|
|
|
|
|
|
|
- $sourceStorage = SchemaFactory::loadDefaultObject('SystemSource');
|
|
|
|
|
- foreach ($sourceStorage->getItems([ 'f_hasConfig' => 1 ]) as $source) {
|
|
|
|
|
- if ('default_objects' == $source['nsPrefix']) {
|
|
|
|
|
- foreach (glob(APP_PATH_LIB . "/Schema/*StorageAcl.php", GLOB_NOSORT) as $file) {
|
|
|
|
|
|
|
+ $sourceStorage = SchemaFactory::loadDefaultObject('SystemSource');
|
|
|
|
|
+ foreach ($sourceStorage->getItems([ 'f_hasConfig' => 1 ]) as $source) {
|
|
|
|
|
+ if ('default_objects' == $source['nsPrefix']) {
|
|
|
|
|
+ foreach (glob(APP_PATH_LIB . "/Schema/*StorageAcl.php", GLOB_NOSORT) as $file) {
|
|
|
$clsName = substr(basename($file), 0, -1 * strlen('StorageAcl.php'));
|
|
$clsName = substr(basename($file), 0, -1 * strlen('StorageAcl.php'));
|
|
|
try {
|
|
try {
|
|
|
$acl = SchemaFactory::loadDefaultObject($clsName);
|
|
$acl = SchemaFactory::loadDefaultObject($clsName);
|
|
|
$namespace = $acl->getNamespace();
|
|
$namespace = $acl->getNamespace();
|
|
|
- DB::getPDO()->insertOrUpdate($this->_rootTableName, [
|
|
|
|
|
- 'namespace' => $namespace,
|
|
|
|
|
- 'idDatabase' => $source['idZasob'],
|
|
|
|
|
- '_type' => "StorageAcl",
|
|
|
|
|
- 'hasStruct' => 1
|
|
|
|
|
- ]);
|
|
|
|
|
|
|
+ DB::getPDO()->insertOrUpdate($this->_rootTableName, [
|
|
|
|
|
+ 'namespace' => $namespace,
|
|
|
|
|
+ 'idDatabase' => $source['idZasob'],
|
|
|
|
|
+ '_type' => "StorageAcl",
|
|
|
|
|
+ 'hasStruct' => 1
|
|
|
|
|
+ ]);
|
|
|
} catch (Exception $e) {
|
|
} catch (Exception $e) {
|
|
|
UI::alert('danger', $e->getMessage());
|
|
UI::alert('danger', $e->getMessage());
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- DB::getPDO()->execSql("
|
|
|
|
|
- insert into `{$this->_rootTableName}` (namespace, idZasob, idDatabase, description, hasStruct)
|
|
|
|
|
- select concat('{$source['nsPrefix']}/', t.`DESC`)
|
|
|
|
|
- , t.ID as idZasob
|
|
|
|
|
- , '{$source['idZasob']}' as idDatabase
|
|
|
|
|
- , t.`OPIS` as description
|
|
|
|
|
- , 1 as hasStruct
|
|
|
|
|
- from CRM_LISTA_ZASOBOW t
|
|
|
|
|
- where t.`TYPE` = 'TABELA'
|
|
|
|
|
- and t.A_STATUS in('NORMAL', 'WAITING')
|
|
|
|
|
- and t.PARENT_ID = {$source['idZasob']}
|
|
|
|
|
- and t.`DESC` not like '%/%'
|
|
|
|
|
- on duplicate key update idZasob = t.ID
|
|
|
|
|
- , hasStruct = 1
|
|
|
|
|
- ");
|
|
|
|
|
- }
|
|
|
|
|
- else {
|
|
|
|
|
- try {
|
|
|
|
|
- $dbName = DB::getPDO($source['idZasob'])->getDatabaseName();
|
|
|
|
|
- $dbType = DB::getPDO($source['idZasob'])->getType();
|
|
|
|
|
- if ('mysql' == $dbType) {
|
|
|
|
|
- UI::alert('warning', "TODO: { id: {$source['idZasob']}, nsPrefix: '{$source['nsPrefix']}', dbName: '{$dbName}', dbType: '{$dbType}'} ...");
|
|
|
|
|
- // TODO: if another DB split select and insert
|
|
|
|
|
- DB::getPDO()->execSql("
|
|
|
|
|
- insert into `{$this->_rootTableName}` (namespace, idDatabase, _rootTableName, _type, description)
|
|
|
|
|
- select concat('{$source['nsPrefix']}/', t.TABLE_NAME) as namespace
|
|
|
|
|
- , '{$source['idZasob']}' as idDatabase
|
|
|
|
|
- , t.TABLE_NAME as _rootTableName
|
|
|
|
|
- , 'TableAcl' as _type
|
|
|
|
|
- , t.TABLE_COMMENT as description
|
|
|
|
|
- from INFORMATION_SCHEMA.TABLES t
|
|
|
|
|
- where t.TABLE_SCHEMA = '{$dbName}'
|
|
|
|
|
- on duplicate key update _rootTableName = t.TABLE_NAME
|
|
|
|
|
- ");
|
|
|
|
|
- DB::getPDO()->execSql("
|
|
|
|
|
- insert into `{$this->_rootTableName}` (namespace, idZasob, idDatabase, description, hasStruct)
|
|
|
|
|
- select concat('{$source['nsPrefix']}/', t.`DESC`) as namespace
|
|
|
|
|
- , t.ID as idZasob
|
|
|
|
|
- , '{$source['idZasob']}' as idDatabase
|
|
|
|
|
- , t.`OPIS` as description
|
|
|
|
|
- , 1 as hasStruct
|
|
|
|
|
- from CRM_LISTA_ZASOBOW t
|
|
|
|
|
- where t.`TYPE` = 'TABELA'
|
|
|
|
|
- and t.A_STATUS in('NORMAL', 'WAITING')
|
|
|
|
|
- and t.PARENT_ID = {$source['idZasob']}
|
|
|
|
|
- on duplicate key update idZasob = t.ID
|
|
|
|
|
- , hasStruct = 1
|
|
|
|
|
- ");
|
|
|
|
|
- // } else if ('pgsql' == $dbType) {// TODO: use pgsql @see Storage Pgsql getTables from information_schema
|
|
|
|
|
- } else {
|
|
|
|
|
- UI::alert('warning', "TODO: { id: {$source['idZasob']}, nsPrefix: '{$source['nsPrefix']}', dbName: '{$dbName}', dbType: <b>'{$dbType}'</b>} ...");
|
|
|
|
|
- }
|
|
|
|
|
- } catch (Exception $e) {
|
|
|
|
|
- UI::alert('danger', "Error source '{$source['idZasob']}' " . $e->getMessage());
|
|
|
|
|
- continue;
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ DB::getPDO()->execSql("
|
|
|
|
|
+ insert into `{$this->_rootTableName}` (namespace, idZasob, idDatabase, description, hasStruct)
|
|
|
|
|
+ select concat('{$source['nsPrefix']}/', t.`DESC`)
|
|
|
|
|
+ , t.ID as idZasob
|
|
|
|
|
+ , '{$source['idZasob']}' as idDatabase
|
|
|
|
|
+ , t.`OPIS` as description
|
|
|
|
|
+ , 1 as hasStruct
|
|
|
|
|
+ from CRM_LISTA_ZASOBOW t
|
|
|
|
|
+ where t.`TYPE` = 'TABELA'
|
|
|
|
|
+ and t.A_STATUS in('NORMAL', 'WAITING')
|
|
|
|
|
+ and t.PARENT_ID = {$source['idZasob']}
|
|
|
|
|
+ and t.`DESC` not like '%/%'
|
|
|
|
|
+ on duplicate key update idZasob = t.ID
|
|
|
|
|
+ , hasStruct = 1
|
|
|
|
|
+ ");
|
|
|
|
|
+ }
|
|
|
|
|
+ else {
|
|
|
|
|
+ try {
|
|
|
|
|
+ $dbName = DB::getPDO($source['idZasob'])->getDatabaseName();
|
|
|
|
|
+ $dbType = DB::getPDO($source['idZasob'])->getType();
|
|
|
|
|
+ if ('mysql' == $dbType) {
|
|
|
|
|
+ UI::alert('warning', "TODO: { id: {$source['idZasob']}, nsPrefix: '{$source['nsPrefix']}', dbName: '{$dbName}', dbType: '{$dbType}'} ...");
|
|
|
|
|
+ // TODO: if another DB split select and insert
|
|
|
|
|
+ DB::getPDO()->execSql("
|
|
|
|
|
+ insert into `{$this->_rootTableName}` (namespace, idDatabase, _rootTableName, _type, description)
|
|
|
|
|
+ select concat('{$source['nsPrefix']}/', t.TABLE_NAME) as namespace
|
|
|
|
|
+ , '{$source['idZasob']}' as idDatabase
|
|
|
|
|
+ , t.TABLE_NAME as _rootTableName
|
|
|
|
|
+ , 'TableAcl' as _type
|
|
|
|
|
+ , t.TABLE_COMMENT as description
|
|
|
|
|
+ from INFORMATION_SCHEMA.TABLES t
|
|
|
|
|
+ where t.TABLE_SCHEMA = '{$dbName}'
|
|
|
|
|
+ on duplicate key update _rootTableName = t.TABLE_NAME
|
|
|
|
|
+ ");
|
|
|
|
|
+ DB::getPDO()->execSql("
|
|
|
|
|
+ insert into `{$this->_rootTableName}` (namespace, idZasob, idDatabase, description, hasStruct)
|
|
|
|
|
+ select concat('{$source['nsPrefix']}/', t.`DESC`) as namespace
|
|
|
|
|
+ , t.ID as idZasob
|
|
|
|
|
+ , '{$source['idZasob']}' as idDatabase
|
|
|
|
|
+ , t.`OPIS` as description
|
|
|
|
|
+ , 1 as hasStruct
|
|
|
|
|
+ from CRM_LISTA_ZASOBOW t
|
|
|
|
|
+ where t.`TYPE` = 'TABELA'
|
|
|
|
|
+ and t.A_STATUS in('NORMAL', 'WAITING')
|
|
|
|
|
+ and t.PARENT_ID = {$source['idZasob']}
|
|
|
|
|
+ on duplicate key update idZasob = t.ID
|
|
|
|
|
+ , hasStruct = 1
|
|
|
|
|
+ ");
|
|
|
|
|
+ // } else if ('pgsql' == $dbType) {// TODO: use pgsql @see Storage Pgsql getTables from information_schema
|
|
|
|
|
+ } else {
|
|
|
|
|
+ UI::alert('warning', "TODO: { id: {$source['idZasob']}, nsPrefix: '{$source['nsPrefix']}', dbName: '{$dbName}', dbType: <b>'{$dbType}'</b>} ...");
|
|
|
|
|
+ }
|
|
|
|
|
+ } catch (Exception $e) {
|
|
|
|
|
+ UI::alert('danger', "Error source '{$source['idZasob']}' " . $e->getMessage());
|
|
|
|
|
+ continue;
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
- // Ant objects in: SE/schema/ant-object/
|
|
|
|
|
- foreach (glob(APP_PATH_SCHEMA . "/ant-object/*/*/build.xml", GLOB_NOSORT) as $file) {
|
|
|
|
|
- // SE/schema/ant-object/default_db.test_perms/TestPermsAnt/build.xml
|
|
|
|
|
- $file = substr($file, strlen(APP_PATH_SCHEMA . '/ant-object/'), -1 * strlen('/build.xml'));
|
|
|
|
|
- DBG::nicePrint($file, '$file');
|
|
|
|
|
- list($partSource, $name) = explode('/', $file);
|
|
|
|
|
- list($sourceName, $rootTableName) = explode('.', $partSource);
|
|
|
|
|
- DBG::nicePrint([$sourceName, $rootTableName, $name], '[$lowerSource, $rootTableName, $name]');
|
|
|
|
|
- // $clsName = substr(basename($file), 0, -1 * strlen('StorageAcl.php'));
|
|
|
|
|
- try {
|
|
|
|
|
- Lib::loadClass('AntAclBase');
|
|
|
|
|
- $acl = AntAclBase::buildInstance(0, [
|
|
|
|
|
- 'source' => $sourceName,
|
|
|
|
|
- 'rootTableName' => $rootTableName,
|
|
|
|
|
- 'name' => $name
|
|
|
|
|
- ]);
|
|
|
|
|
- // $acl = SchemaFactory::loadDefaultObject($clsName);
|
|
|
|
|
- // $namespace = $acl->getNamespace();
|
|
|
|
|
- // $name = $acl->getName();
|
|
|
|
|
- $idDatabase = DB::getPDO($sourceName)->getZasobId();
|
|
|
|
|
- $namespace = "{$sourceName}/{$rootTableName}/{$name}";
|
|
|
|
|
- DB::getPDO()->insertOrUpdate($this->_rootTableName, [
|
|
|
|
|
- 'namespace' => $namespace,
|
|
|
|
|
- 'idDatabase' => $idDatabase,
|
|
|
|
|
- '_type' => "AntAcl",
|
|
|
|
|
- '_rootTableName' => $rootTableName,
|
|
|
|
|
- 'hasStruct' => 1
|
|
|
|
|
- ]);
|
|
|
|
|
- } catch (Exception $e) {
|
|
|
|
|
- UI::alert('danger', $e->getMessage());
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ // Ant objects in: SE/schema/ant-object/
|
|
|
|
|
+ foreach (glob(APP_PATH_SCHEMA . "/ant-object/*/*/build.xml", GLOB_NOSORT) as $file) {
|
|
|
|
|
+ // SE/schema/ant-object/default_db.test_perms/TestPermsAnt/build.xml
|
|
|
|
|
+ $file = substr($file, strlen(APP_PATH_SCHEMA . '/ant-object/'), -1 * strlen('/build.xml'));
|
|
|
|
|
+ DBG::nicePrint($file, '$file');
|
|
|
|
|
+ list($partSource, $name) = explode('/', $file);
|
|
|
|
|
+ list($sourceName, $rootTableName) = explode('.', $partSource);
|
|
|
|
|
+ DBG::nicePrint([$sourceName, $rootTableName, $name], '[$lowerSource, $rootTableName, $name]');
|
|
|
|
|
+ // $clsName = substr(basename($file), 0, -1 * strlen('StorageAcl.php'));
|
|
|
|
|
+ try {
|
|
|
|
|
+ Lib::loadClass('AntAclBase');
|
|
|
|
|
+ $acl = AntAclBase::buildInstance(0, [
|
|
|
|
|
+ 'source' => $sourceName,
|
|
|
|
|
+ 'rootTableName' => $rootTableName,
|
|
|
|
|
+ 'name' => $name
|
|
|
|
|
+ ]);
|
|
|
|
|
+ // $acl = SchemaFactory::loadDefaultObject($clsName);
|
|
|
|
|
+ // $namespace = $acl->getNamespace();
|
|
|
|
|
+ // $name = $acl->getName();
|
|
|
|
|
+ $idDatabase = DB::getPDO($sourceName)->getZasobId();
|
|
|
|
|
+ $namespace = "{$sourceName}/{$rootTableName}/{$name}";
|
|
|
|
|
+ DB::getPDO()->insertOrUpdate($this->_rootTableName, [
|
|
|
|
|
+ 'namespace' => $namespace,
|
|
|
|
|
+ 'idDatabase' => $idDatabase,
|
|
|
|
|
+ '_type' => "AntAcl",
|
|
|
|
|
+ '_rootTableName' => $rootTableName,
|
|
|
|
|
+ 'hasStruct' => 1
|
|
|
|
|
+ ]);
|
|
|
|
|
+ } catch (Exception $e) {
|
|
|
|
|
+ UI::alert('danger', $e->getMessage());
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
- // // foreach ... DB::getPDO($idDatabase)->fetchAll(select real _rootTableName)
|
|
|
|
|
- // foreach (Core_AclHelper::getCustomAclList() as $typeName) {
|
|
|
|
|
- // $ns = Core_AclHelper::parseTypeName($typeName);
|
|
|
|
|
- // $namespace = str_replace('__x3A__', '/', $ns['prefix']) . "/{$ns['name']}";
|
|
|
|
|
- // $sqlNs = DB::getPDO()->quote($namespace, PDO::PARAM_STR);
|
|
|
|
|
- // $idZasob = DB::getPDO()->fetchValue(" select ID from CRM_LISTA_ZASOBOW where `DESC` = {$sqlNs} and `TYPE` = 'TABELA' and A_STATUS in('WAITING', 'NORMAL') ");
|
|
|
|
|
- // if (!$idZasob) {
|
|
|
|
|
- // DBG::nicePrint($ns, "TODO: insert zasob PARENT_ID = ?");
|
|
|
|
|
- // }
|
|
|
|
|
- // }
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ // // foreach ... DB::getPDO($idDatabase)->fetchAll(select real _rootTableName)
|
|
|
|
|
+ // foreach (Core_AclHelper::getCustomAclList() as $typeName) {
|
|
|
|
|
+ // $ns = Core_AclHelper::parseTypeName($typeName);
|
|
|
|
|
+ // $namespace = str_replace('__x3A__', '/', $ns['prefix']) . "/{$ns['name']}";
|
|
|
|
|
+ // $sqlNs = DB::getPDO()->quote($namespace, PDO::PARAM_STR);
|
|
|
|
|
+ // $idZasob = DB::getPDO()->fetchValue(" select ID from CRM_LISTA_ZASOBOW where `DESC` = {$sqlNs} and `TYPE` = 'TABELA' and A_STATUS in('WAITING', 'NORMAL') ");
|
|
|
|
|
+ // if (!$idZasob) {
|
|
|
|
|
+ // DBG::nicePrint($ns, "TODO: insert zasob PARENT_ID = ?");
|
|
|
|
|
+ // }
|
|
|
|
|
+ // }
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
- public function _parseWhere($params = []) {
|
|
|
|
|
- $sqlWhere = [];
|
|
|
|
|
- DBG::log($params, 'array', "SystemObject::_parseWhere");
|
|
|
|
|
- if (!empty($params['#refFrom'])) {
|
|
|
|
|
- // '#refFrom' => [
|
|
|
|
|
- // 'namespace' => 'default_objects/SystemSource',
|
|
|
|
|
- // 'primaryKey' => $sourceItem['idZasob']
|
|
|
|
|
- // ]
|
|
|
|
|
- if (empty($params['#refFrom']['namespace'])) throw new Exception("Missing refFrom/namespace");
|
|
|
|
|
- if (empty($params['#refFrom']['primaryKey'])) throw new Exception("Missing refFrom/primaryKey");
|
|
|
|
|
|
|
+ public function _parseWhere($params = []) {
|
|
|
|
|
+ $sqlWhere = [];
|
|
|
|
|
+ DBG::log($params, 'array', "SystemObject::_parseWhere");
|
|
|
|
|
+ if (!empty($params['#refFrom'])) {
|
|
|
|
|
+ // '#refFrom' => [
|
|
|
|
|
+ // 'namespace' => 'default_objects/SystemSource',
|
|
|
|
|
+ // 'primaryKey' => $sourceItem['idZasob']
|
|
|
|
|
+ // ]
|
|
|
|
|
+ if (empty($params['#refFrom']['namespace'])) throw new Exception("Missing refFrom/namespace");
|
|
|
|
|
+ if (empty($params['#refFrom']['primaryKey'])) throw new Exception("Missing refFrom/primaryKey");
|
|
|
|
|
|
|
|
- if ('default_objects/SystemSource' != $params['#refFrom']['namespace']) throw new Exception("Unsupported refFrom/namespace '{$params['#refFrom']['namespace']}'");
|
|
|
|
|
- $sqlWhere[] = "t.idDatabase = " . DB::getPDO()->quote($params['#refFrom']['primaryKey'], PDO::PARAM_INT);
|
|
|
|
|
- }
|
|
|
|
|
- {
|
|
|
|
|
- $filterParams = [];
|
|
|
|
|
- $xsdFields = $this->getXsdTypes();
|
|
|
|
|
- foreach ($params as $k => $v) {
|
|
|
|
|
- if ('f_' != substr($k, 0, 2)) continue;
|
|
|
|
|
- $fieldName = substr($k, 2);
|
|
|
|
|
- if (!array_key_exists($fieldName, $xsdFields)) {
|
|
|
|
|
- // TODO: check query by xpath or use different param prefix
|
|
|
|
|
- throw new Exception("Field '{$fieldName}' not found in '{$this->_namespace}'");
|
|
|
|
|
- }
|
|
|
|
|
- if ('p5:www_link' == $xsdFields[$fieldName]) {
|
|
|
|
|
- continue;
|
|
|
|
|
- }
|
|
|
|
|
- $filterParams[$fieldName] = $v;
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
- if (!empty($filterParams)) {
|
|
|
|
|
- DBG::log($filterParams, 'array', "SystemObject::_parseWhere TODO \$filterParams");
|
|
|
|
|
- foreach ($filterParams as $fieldName => $value) {
|
|
|
|
|
- if (is_array($value)) {
|
|
|
|
|
- DBG::log($value, 'array', "TODO SystemObject::_parseWhere array value for \$filterParams[{$fieldName}]");
|
|
|
|
|
- } else if (is_scalar($value)) {
|
|
|
|
|
- if ('=' == substr($value, 0, 1)) {
|
|
|
|
|
- $sqlWhere[] = "t.{$fieldName} = " . DB::getPDO()->quote(substr($value, 1), PDO::PARAM_STR);
|
|
|
|
|
- } else {
|
|
|
|
|
- $sqlWhere[] = "t.{$fieldName} like " . DB::getPDO()->quote("%{$value}%", PDO::PARAM_STR);
|
|
|
|
|
- }
|
|
|
|
|
- } else {
|
|
|
|
|
- DBG::log($value, 'array', "BUG SystemObject::_parseWhere unknown type for \$filterParams[{$fieldName}]");
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
- return (!empty($sqlWhere)) ? "where " . implode(" and ", $sqlWhere) : '';
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ if ('default_objects/SystemSource' != $params['#refFrom']['namespace']) throw new Exception("Unsupported refFrom/namespace '{$params['#refFrom']['namespace']}'");
|
|
|
|
|
+ $sqlWhere[] = "t.idDatabase = " . DB::getPDO()->quote($params['#refFrom']['primaryKey'], PDO::PARAM_INT);
|
|
|
|
|
+ }
|
|
|
|
|
+ {
|
|
|
|
|
+ $filterParams = [];
|
|
|
|
|
+ $xsdFields = $this->getXsdTypes();
|
|
|
|
|
+ foreach ($params as $k => $v) {
|
|
|
|
|
+ if ('f_' != substr($k, 0, 2)) continue;
|
|
|
|
|
+ $fieldName = substr($k, 2);
|
|
|
|
|
+ if (!array_key_exists($fieldName, $xsdFields)) {
|
|
|
|
|
+ // TODO: check query by xpath or use different param prefix
|
|
|
|
|
+ throw new Exception("Field '{$fieldName}' not found in '{$this->_namespace}'");
|
|
|
|
|
+ }
|
|
|
|
|
+ if ('p5:www_link' == $xsdFields[$fieldName]) {
|
|
|
|
|
+ continue;
|
|
|
|
|
+ }
|
|
|
|
|
+ $filterParams[$fieldName] = $v;
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ if (!empty($filterParams)) {
|
|
|
|
|
+ DBG::log($filterParams, 'array', "SystemObject::_parseWhere TODO \$filterParams");
|
|
|
|
|
+ foreach ($filterParams as $fieldName => $value) {
|
|
|
|
|
+ if (is_array($value)) {
|
|
|
|
|
+ DBG::log($value, 'array', "TODO SystemObject::_parseWhere array value for \$filterParams[{$fieldName}]");
|
|
|
|
|
+ } else if (is_scalar($value)) {
|
|
|
|
|
+ if ('=' == substr($value, 0, 1)) {
|
|
|
|
|
+ $sqlWhere[] = "t.{$fieldName} = " . DB::getPDO()->quote(substr($value, 1), PDO::PARAM_STR);
|
|
|
|
|
+ } else {
|
|
|
|
|
+ $sqlWhere[] = "t.{$fieldName} like " . DB::getPDO()->quote("%{$value}%", PDO::PARAM_STR);
|
|
|
|
|
+ }
|
|
|
|
|
+ } else {
|
|
|
|
|
+ DBG::log($value, 'array', "BUG SystemObject::_parseWhere unknown type for \$filterParams[{$fieldName}]");
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ return (!empty($sqlWhere)) ? "where " . implode(" and ", $sqlWhere) : '';
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
- public function getTotal($params = []) {
|
|
|
|
|
- $sqlWhere = $this->_parseWhere($params);
|
|
|
|
|
- return DB::getPDO()->fetchValue("
|
|
|
|
|
- select count(1) as cnt
|
|
|
|
|
- from `{$this->_rootTableName}` t
|
|
|
|
|
- {$sqlWhere}
|
|
|
|
|
- ");
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ public function getTotal($params = []) {
|
|
|
|
|
+ $sqlWhere = $this->_parseWhere($params);
|
|
|
|
|
+ return DB::getPDO()->fetchValue("
|
|
|
|
|
+ select count(1) as cnt
|
|
|
|
|
+ from `{$this->_rootTableName}` t
|
|
|
|
|
+ {$sqlWhere}
|
|
|
|
|
+ ");
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
- public function getItem($pk, $params = []) {
|
|
|
|
|
- if (!$pk) throw new Exception("Missing primary key '{$this->_namespace}'");
|
|
|
|
|
- $pkField = $this->getSqlPrimaryKeyField();
|
|
|
|
|
- if (!$pkField) throw new Exception("Missing primary key field defined in '{$this->_namespace}'");
|
|
|
|
|
- $sqlPk = DB::getPDO()->quote($pk, PDO::PARAM_STR);
|
|
|
|
|
- $item = DB::getPDO()->fetchFirst("
|
|
|
|
|
- select t.*
|
|
|
|
|
- from `{$this->_rootTableName}` t
|
|
|
|
|
- where t.`{$pkField}` = {$sqlPk}
|
|
|
|
|
- ");
|
|
|
|
|
- if (!$item) throw new Exception("Item '{$pk}' not exists - type '{$this->_namespace}'");
|
|
|
|
|
- return $this->buildFeatureFromSqlRow($item, $params);
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ public function getItem($pk, $params = []) {
|
|
|
|
|
+ if (!$pk) throw new Exception("Missing primary key '{$this->_namespace}'");
|
|
|
|
|
+ $pkField = $this->getSqlPrimaryKeyField();
|
|
|
|
|
+ if (!$pkField) throw new Exception("Missing primary key field defined in '{$this->_namespace}'");
|
|
|
|
|
+ $sqlPk = DB::getPDO()->quote($pk, PDO::PARAM_STR);
|
|
|
|
|
+ $item = DB::getPDO()->fetchFirst("
|
|
|
|
|
+ select t.*
|
|
|
|
|
+ from `{$this->_rootTableName}` t
|
|
|
|
|
+ where t.`{$pkField}` = {$sqlPk}
|
|
|
|
|
+ ");
|
|
|
|
|
+ if (!$item) throw new Exception("Item '{$pk}' not exists - type '{$this->_namespace}'");
|
|
|
|
|
+ return $this->buildFeatureFromSqlRow($item, $params);
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
- public function getItems($params = []) {
|
|
|
|
|
- $sqlWhere = $this->_parseWhere($params);
|
|
|
|
|
|
|
+ public function getItems($params = []) {
|
|
|
|
|
+ $sqlWhere = $this->_parseWhere($params);
|
|
|
|
|
|
|
|
- $currSortCol = V::get('order_by', 'idZasob', $params);
|
|
|
|
|
- $currSortFlip = strtolower(V::get('order_dir', 'desc', $params));
|
|
|
|
|
- // TODO: validate $currSortCol is in field list
|
|
|
|
|
- // TODO: validate $currSortFlip ('asc' or 'desc')
|
|
|
|
|
- $xsdFields = $this->getXsdTypes();
|
|
|
|
|
- if (!array_key_exists($currSortCol, $xsdFields)) throw new Exception("Field '{$currSortCol}' not found in '{$this->_namespace}'");
|
|
|
|
|
- if (!in_array($currSortFlip, ['asc', 'desc'])) throw new Exception("Sort dir not allowed");
|
|
|
|
|
- $sqlOrderBy = "order by t.`{$currSortCol}` {$currSortFlip}";
|
|
|
|
|
|
|
+ $currSortCol = V::get('order_by', 'idZasob', $params);
|
|
|
|
|
+ $currSortFlip = strtolower(V::get('order_dir', 'desc', $params));
|
|
|
|
|
+ // TODO: validate $currSortCol is in field list
|
|
|
|
|
+ // TODO: validate $currSortFlip ('asc' or 'desc')
|
|
|
|
|
+ $xsdFields = $this->getXsdTypes();
|
|
|
|
|
+ if (!array_key_exists($currSortCol, $xsdFields)) throw new Exception("Field '{$currSortCol}' not found in '{$this->_namespace}'");
|
|
|
|
|
+ if (!in_array($currSortFlip, ['asc', 'desc'])) throw new Exception("Sort dir not allowed");
|
|
|
|
|
+ $sqlOrderBy = "order by t.`{$currSortCol}` {$currSortFlip}";
|
|
|
|
|
|
|
|
- $limit = V::get('limit', 0, $params, 'int');
|
|
|
|
|
- $limit = ($limit < 0) ? 0 : $limit;
|
|
|
|
|
- $offset = V::get('limitstart', 0, $params, 'int');
|
|
|
|
|
- $offset = ($offset < 0) ? 0 : $offset;
|
|
|
|
|
- $sqlLimit = ($limit > 0)
|
|
|
|
|
- ? "limit {$limit} offset {$offset}"
|
|
|
|
|
- : '';
|
|
|
|
|
|
|
+ $limit = V::get('limit', 0, $params, 'int');
|
|
|
|
|
+ $limit = ($limit < 0) ? 0 : $limit;
|
|
|
|
|
+ $offset = V::get('limitstart', 0, $params, 'int');
|
|
|
|
|
+ $offset = ($offset < 0) ? 0 : $offset;
|
|
|
|
|
+ $sqlLimit = ($limit > 0)
|
|
|
|
|
+ ? "limit {$limit} offset {$offset}"
|
|
|
|
|
+ : '';
|
|
|
|
|
|
|
|
- Lib::loadClass('AclQueryItems');
|
|
|
|
|
- $query = new AclQueryItems($this);
|
|
|
|
|
- $query->setParams($params);
|
|
|
|
|
- $query->setSource('default_db');
|
|
|
|
|
- $query->setRawSql("
|
|
|
|
|
- select t.*
|
|
|
|
|
- from `{$this->_rootTableName}` t
|
|
|
|
|
- {$sqlWhere}
|
|
|
|
|
- {$sqlOrderBy}
|
|
|
|
|
- {$sqlLimit}
|
|
|
|
|
- ");
|
|
|
|
|
- return $query->fetchAll();
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ Lib::loadClass('AclQueryItems');
|
|
|
|
|
+ $query = new AclQueryItems($this);
|
|
|
|
|
+ $query->setParams($params);
|
|
|
|
|
+ $query->setSource('default_db');
|
|
|
|
|
+ $query->setRawSql("
|
|
|
|
|
+ select t.*
|
|
|
|
|
+ from `{$this->_rootTableName}` t
|
|
|
|
|
+ {$sqlWhere}
|
|
|
|
|
+ {$sqlOrderBy}
|
|
|
|
|
+ {$sqlLimit}
|
|
|
|
|
+ ");
|
|
|
|
|
+ return $query->fetchAll();
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
- public function buildFeatureFromSqlRow($item, $params = []) {
|
|
|
|
|
- DBG::log($params, 'array', "buildFeatureFromSqlRow...");
|
|
|
|
|
- $exNs = explode('/', $item['namespace']);
|
|
|
|
|
- $item['name'] = array_pop($exNs);
|
|
|
|
|
- $item['nsPrefix'] = implode('__x3A__', $exNs);
|
|
|
|
|
- $item['typeName'] = implode('__x3A__', $exNs) . ':' . $item['name'];
|
|
|
|
|
- $item['reinstallLink'] = Router::getRoute('Storage')->getLink('objectReinstall', [ 'namespace' => $item['namespace'] ]);
|
|
|
|
|
- if (!empty($params['propertyName'])) {
|
|
|
|
|
- if (is_string($params['propertyName'])) $params['propertyName'] = explode(',', $params['propertyName']);
|
|
|
|
|
- if (!is_array($params['propertyName'])) throw new Exception("Wrong param propertyName - expected array or string");
|
|
|
|
|
- foreach ($params['propertyName'] as $fetchField) {
|
|
|
|
|
- if ('*' == $fetchField) continue;
|
|
|
|
|
- if ('field' == $fetchField) {
|
|
|
|
|
- $item['field'] = SchemaFactory::loadDefaultObject('SystemObjectField')->getItems([
|
|
|
|
|
- '__backRef' => [
|
|
|
|
|
- 'namespace' => 'default_objects/SystemObject',
|
|
|
|
|
- 'primaryKey' => $item['namespace']
|
|
|
|
|
- ]
|
|
|
|
|
- ]);
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
- return $item;
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ public function buildFeatureFromSqlRow($item, $params = []) {
|
|
|
|
|
+ DBG::log($params, 'array', "buildFeatureFromSqlRow...");
|
|
|
|
|
+ $exNs = explode('/', $item['namespace']);
|
|
|
|
|
+ $item['name'] = array_pop($exNs);
|
|
|
|
|
+ $item['nsPrefix'] = implode('__x3A__', $exNs);
|
|
|
|
|
+ $item['typeName'] = implode('__x3A__', $exNs) . ':' . $item['name'];
|
|
|
|
|
+ $item['reinstallLink'] = Router::getRoute('Storage')->getLink('objectReinstall', [ 'namespace' => $item['namespace'] ]);
|
|
|
|
|
+ if (!empty($params['propertyName'])) {
|
|
|
|
|
+ if (is_string($params['propertyName'])) $params['propertyName'] = explode(',', $params['propertyName']);
|
|
|
|
|
+ if (!is_array($params['propertyName'])) throw new Exception("Wrong param propertyName - expected array or string");
|
|
|
|
|
+ foreach ($params['propertyName'] as $fetchField) {
|
|
|
|
|
+ if ('*' == $fetchField) continue;
|
|
|
|
|
+ if ('field' == $fetchField) {
|
|
|
|
|
+ $item['field'] = SchemaFactory::loadDefaultObject('SystemObjectField')->getItems([
|
|
|
|
|
+ '__backRef' => [
|
|
|
|
|
+ 'namespace' => 'default_objects/SystemObject',
|
|
|
|
|
+ 'primaryKey' => $item['namespace']
|
|
|
|
|
+ ]
|
|
|
|
|
+ ]);
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ return $item;
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
- public function updateItem($itemPatch) {
|
|
|
|
|
- $pkField = $this->getPrimaryKeyField();
|
|
|
|
|
- $pk = V::get($pkField, null, $itemPatch);
|
|
|
|
|
- if (null === $pk) throw new Exception("BUG missing primary key field for '{$this->_namespace}' updateItem");
|
|
|
|
|
- DBG::log(['updateItem $itemPatch', $itemPatch]);
|
|
|
|
|
- unset($itemPatch[$pkField]);
|
|
|
|
|
- if (empty($itemPatch)) return 0;
|
|
|
|
|
- foreach ($itemPatch as $fieldName => $value) {
|
|
|
|
|
- if ('isStructInstalled' == $fieldName) continue;
|
|
|
|
|
- if ('isObjectActive' == $fieldName) continue;
|
|
|
|
|
- throw new Exception("Update field '{$fieldName}' not allowed for '{$this->_namespace}'");
|
|
|
|
|
- }
|
|
|
|
|
- return DB::getPDO()->update($this->_rootTableName, $pkField, $pk, $itemPatch);
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ public function updateItem($itemPatch) {
|
|
|
|
|
+ $pkField = $this->getPrimaryKeyField();
|
|
|
|
|
+ $pk = V::get($pkField, null, $itemPatch);
|
|
|
|
|
+ if (null === $pk) throw new Exception("BUG missing primary key field for '{$this->_namespace}' updateItem");
|
|
|
|
|
+ DBG::log(['updateItem $itemPatch', $itemPatch]);
|
|
|
|
|
+ unset($itemPatch[$pkField]);
|
|
|
|
|
+ if (empty($itemPatch)) return 0;
|
|
|
|
|
+ foreach ($itemPatch as $fieldName => $value) {
|
|
|
|
|
+ if ('isStructInstalled' == $fieldName) continue;
|
|
|
|
|
+ if ('isObjectActive' == $fieldName) continue;
|
|
|
|
|
+ throw new Exception("Update field '{$fieldName}' not allowed for '{$this->_namespace}'");
|
|
|
|
|
+ }
|
|
|
|
|
+ return DB::getPDO()->update($this->_rootTableName, $pkField, $pk, $itemPatch);
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
}
|
|
}
|