2014-09-18 17:22:54 +02:00
|
|
|
<?php
|
|
|
|
|
|
|
|
abstract class PhabricatorConfigSchemaSpec extends Phobject {
|
|
|
|
|
2014-09-18 17:25:34 +02:00
|
|
|
private $server;
|
|
|
|
private $utf8Charset;
|
|
|
|
private $utf8Collation;
|
|
|
|
|
|
|
|
public function setUTF8Collation($utf8_collation) {
|
|
|
|
$this->utf8Collation = $utf8_collation;
|
|
|
|
return $this;
|
|
|
|
}
|
|
|
|
|
|
|
|
public function getUTF8Collation() {
|
|
|
|
return $this->utf8Collation;
|
|
|
|
}
|
|
|
|
|
|
|
|
public function setUTF8Charset($utf8_charset) {
|
|
|
|
$this->utf8Charset = $utf8_charset;
|
|
|
|
return $this;
|
|
|
|
}
|
|
|
|
|
|
|
|
public function getUTF8Charset() {
|
|
|
|
return $this->utf8Charset;
|
|
|
|
}
|
|
|
|
|
|
|
|
public function setServer(PhabricatorConfigServerSchema $server) {
|
|
|
|
$this->server = $server;
|
|
|
|
return $this;
|
|
|
|
}
|
|
|
|
|
|
|
|
public function getServer() {
|
|
|
|
return $this->server;
|
|
|
|
}
|
|
|
|
|
|
|
|
abstract public function buildSchemata();
|
|
|
|
|
|
|
|
protected function buildLiskSchemata($base) {
|
|
|
|
|
|
|
|
$objects = id(new PhutilSymbolLoader())
|
|
|
|
->setAncestorClass($base)
|
|
|
|
->loadObjects();
|
|
|
|
|
|
|
|
foreach ($objects as $object) {
|
2014-09-18 17:32:44 +02:00
|
|
|
$this->buildLiskObjectSchema($object);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
protected function buildTransactionSchema(
|
|
|
|
PhabricatorApplicationTransaction $xaction,
|
|
|
|
PhabricatorApplicationTransactionComment $comment = null) {
|
|
|
|
|
|
|
|
$this->buildLiskObjectSchema($xaction);
|
|
|
|
if ($comment) {
|
|
|
|
$this->buildLiskObjectSchema($comment);
|
|
|
|
}
|
|
|
|
}
|
2014-09-18 17:25:34 +02:00
|
|
|
|
2014-09-19 20:46:44 +02:00
|
|
|
protected function buildCustomFieldSchemata(
|
|
|
|
PhabricatorLiskDAO $storage,
|
|
|
|
array $indexes) {
|
|
|
|
|
|
|
|
$this->buildLiskObjectSchema($storage);
|
|
|
|
foreach ($indexes as $index) {
|
|
|
|
$this->buildLiskObjectSchema($index);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2014-09-18 17:32:44 +02:00
|
|
|
private function buildLiskObjectSchema(PhabricatorLiskDAO $object) {
|
2014-09-18 17:36:22 +02:00
|
|
|
$this->buildRawSchema(
|
|
|
|
$object->getApplicationName(),
|
|
|
|
$object->getTableName(),
|
|
|
|
$object->getSchemaColumns(),
|
|
|
|
$object->getSchemaKeys());
|
|
|
|
}
|
|
|
|
|
|
|
|
protected function buildRawSchema(
|
|
|
|
$database_name,
|
|
|
|
$table_name,
|
|
|
|
array $columns,
|
|
|
|
array $keys) {
|
|
|
|
$database = $this->getDatabase($database_name);
|
2014-09-18 17:25:34 +02:00
|
|
|
|
2014-09-18 17:36:22 +02:00
|
|
|
$table = $this->newTable($table_name);
|
2014-09-18 17:25:34 +02:00
|
|
|
|
2014-09-18 17:36:22 +02:00
|
|
|
foreach ($columns as $name => $type) {
|
2014-09-18 20:15:49 +02:00
|
|
|
if ($type === null) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
2014-09-18 17:32:44 +02:00
|
|
|
$details = $this->getDetailsForDataType($type);
|
|
|
|
list($column_type, $charset, $collation, $nullable) = $details;
|
2014-09-18 17:25:34 +02:00
|
|
|
|
2014-09-18 17:32:44 +02:00
|
|
|
$column = $this->newColumn($name)
|
|
|
|
->setDataType($type)
|
|
|
|
->setColumnType($column_type)
|
|
|
|
->setCharacterSet($charset)
|
|
|
|
->setCollation($collation)
|
|
|
|
->setNullable($nullable);
|
2014-09-18 17:25:34 +02:00
|
|
|
|
2014-09-18 17:32:44 +02:00
|
|
|
$table->addColumn($column);
|
2014-09-18 17:25:34 +02:00
|
|
|
}
|
2014-09-18 17:32:44 +02:00
|
|
|
|
|
|
|
foreach ($keys as $key_name => $key_spec) {
|
2014-09-18 20:15:38 +02:00
|
|
|
if ($key_spec === null) {
|
|
|
|
// This is a subclass removing a key which Lisk expects.
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
2014-09-18 17:32:44 +02:00
|
|
|
$key = $this->newKey($key_name)
|
|
|
|
->setColumnNames(idx($key_spec, 'columns', array()));
|
|
|
|
|
2014-09-19 20:46:30 +02:00
|
|
|
$key->setUnique((bool)idx($key_spec, 'unique'));
|
|
|
|
|
2014-09-18 17:32:44 +02:00
|
|
|
$table->addKey($key);
|
|
|
|
}
|
|
|
|
|
|
|
|
$database->addTable($table);
|
2014-09-18 17:25:34 +02:00
|
|
|
}
|
|
|
|
|
2014-09-18 20:15:38 +02:00
|
|
|
protected function buildEdgeSchemata(PhabricatorLiskDAO $object) {
|
|
|
|
$this->buildRawSchema(
|
|
|
|
$object->getApplicationName(),
|
|
|
|
PhabricatorEdgeConfig::TABLE_NAME_EDGE,
|
|
|
|
array(
|
|
|
|
'src' => 'phid',
|
|
|
|
'type' => 'uint32',
|
|
|
|
'dst' => 'phid',
|
|
|
|
'dateCreated' => 'epoch',
|
|
|
|
'seq' => 'uint32',
|
|
|
|
'dataID' => 'id?',
|
|
|
|
),
|
|
|
|
array(
|
|
|
|
'PRIMARY' => array(
|
|
|
|
'columns' => array('src', 'type', 'dst'),
|
2014-09-19 20:46:44 +02:00
|
|
|
'unique' => true,
|
|
|
|
),
|
|
|
|
'src' => array(
|
|
|
|
'columns' => array('src', 'type', 'dateCreated', 'seq'),
|
2014-09-18 20:15:38 +02:00
|
|
|
),
|
|
|
|
));
|
|
|
|
|
|
|
|
$this->buildRawSchema(
|
|
|
|
$object->getApplicationName(),
|
|
|
|
PhabricatorEdgeConfig::TABLE_NAME_EDGEDATA,
|
|
|
|
array(
|
|
|
|
'id' => 'id',
|
|
|
|
'data' => 'text',
|
|
|
|
),
|
|
|
|
array(
|
|
|
|
'PRIMARY' => array(
|
|
|
|
'columns' => array('id'),
|
2014-09-19 20:46:44 +02:00
|
|
|
'unique' => true,
|
2014-09-18 20:15:38 +02:00
|
|
|
),
|
|
|
|
));
|
|
|
|
}
|
2014-09-18 17:25:34 +02:00
|
|
|
|
2014-09-19 14:45:24 +02:00
|
|
|
public function buildCounterSchema(PhabricatorLiskDAO $object) {
|
|
|
|
$this->buildRawSchema(
|
|
|
|
$object->getApplicationName(),
|
|
|
|
PhabricatorLiskDAO::COUNTER_TABLE_NAME,
|
|
|
|
array(
|
|
|
|
'counterName' => 'text32',
|
|
|
|
'counterValue' => 'id64',
|
|
|
|
),
|
|
|
|
array(
|
|
|
|
'PRIMARY' => array(
|
|
|
|
'columns' => array('counterName'),
|
|
|
|
),
|
|
|
|
));
|
|
|
|
}
|
|
|
|
|
2014-09-18 17:25:34 +02:00
|
|
|
protected function getDatabase($name) {
|
|
|
|
$server = $this->getServer();
|
|
|
|
|
|
|
|
$database = $server->getDatabase($this->getNamespacedDatabase($name));
|
|
|
|
if (!$database) {
|
|
|
|
$database = $this->newDatabase($name);
|
|
|
|
$server->addDatabase($database);
|
|
|
|
}
|
|
|
|
|
|
|
|
return $database;
|
|
|
|
}
|
|
|
|
|
|
|
|
protected function newDatabase($name) {
|
|
|
|
return id(new PhabricatorConfigDatabaseSchema())
|
|
|
|
->setName($this->getNamespacedDatabase($name))
|
|
|
|
->setCharacterSet($this->getUTF8Charset())
|
|
|
|
->setCollation($this->getUTF8Collation());
|
|
|
|
}
|
|
|
|
|
|
|
|
protected function getNamespacedDatabase($name) {
|
|
|
|
$namespace = PhabricatorLiskDAO::getStorageNamespace();
|
|
|
|
return $namespace.'_'.$name;
|
|
|
|
}
|
|
|
|
|
|
|
|
protected function newTable($name) {
|
|
|
|
return id(new PhabricatorConfigTableSchema())
|
|
|
|
->setName($name)
|
|
|
|
->setCollation($this->getUTF8Collation());
|
|
|
|
}
|
|
|
|
|
|
|
|
protected function newColumn($name) {
|
|
|
|
return id(new PhabricatorConfigColumnSchema())
|
|
|
|
->setName($name);
|
|
|
|
}
|
|
|
|
|
2014-09-18 17:32:44 +02:00
|
|
|
protected function newKey($name) {
|
|
|
|
return id(new PhabricatorConfigKeySchema())
|
|
|
|
->setName($name);
|
|
|
|
}
|
|
|
|
|
2014-09-18 17:25:34 +02:00
|
|
|
private function getDetailsForDataType($data_type) {
|
|
|
|
$column_type = null;
|
|
|
|
$charset = null;
|
|
|
|
$collation = null;
|
|
|
|
|
2014-09-18 17:32:44 +02:00
|
|
|
// If the type ends with "?", make the column nullable.
|
|
|
|
$nullable = false;
|
|
|
|
if (preg_match('/\?$/', $data_type)) {
|
|
|
|
$nullable = true;
|
|
|
|
$data_type = substr($data_type, 0, -1);
|
|
|
|
}
|
|
|
|
|
2014-09-18 17:25:34 +02:00
|
|
|
switch ($data_type) {
|
|
|
|
case 'id':
|
|
|
|
case 'epoch':
|
2014-09-18 17:32:44 +02:00
|
|
|
case 'uint32':
|
2014-09-18 17:25:34 +02:00
|
|
|
$column_type = 'int(10) unsigned';
|
|
|
|
break;
|
2014-09-18 17:36:22 +02:00
|
|
|
case 'id64':
|
2014-09-18 20:15:29 +02:00
|
|
|
case 'uint64':
|
2014-09-18 17:36:22 +02:00
|
|
|
$column_type = 'bigint(20) unsigned';
|
|
|
|
break;
|
2014-09-19 20:46:44 +02:00
|
|
|
case 'sint64':
|
|
|
|
$column_type = 'bigint(20)';
|
|
|
|
break;
|
2014-09-18 17:25:34 +02:00
|
|
|
case 'phid':
|
2014-09-18 17:32:44 +02:00
|
|
|
case 'policy';
|
2014-09-18 17:25:34 +02:00
|
|
|
$column_type = 'varchar(64)';
|
|
|
|
$charset = 'binary';
|
|
|
|
$collation = 'binary';
|
|
|
|
break;
|
2014-09-18 20:15:29 +02:00
|
|
|
case 'bytes40':
|
|
|
|
$column_type = 'char(40)';
|
|
|
|
$charset = 'binary';
|
|
|
|
$collation = 'binary';
|
|
|
|
break;
|
2014-09-18 17:36:22 +02:00
|
|
|
case 'bytes12':
|
|
|
|
$column_type = 'char(12)';
|
|
|
|
$charset = 'binary';
|
|
|
|
$collation = 'binary';
|
|
|
|
break;
|
|
|
|
case 'bytes':
|
2014-09-18 17:25:34 +02:00
|
|
|
$column_type = 'longblob';
|
|
|
|
$charset = 'binary';
|
|
|
|
$collation = 'binary';
|
|
|
|
break;
|
2014-09-18 20:15:29 +02:00
|
|
|
case 'text255':
|
|
|
|
$column_type = 'varchar(255)';
|
|
|
|
$charset = $this->getUTF8Charset();
|
|
|
|
$collation = $this->getUTF8Collation();
|
|
|
|
break;
|
2014-09-18 17:32:44 +02:00
|
|
|
case 'text128':
|
|
|
|
$column_type = 'varchar(128)';
|
|
|
|
$charset = $this->getUTF8Charset();
|
|
|
|
$collation = $this->getUTF8Collation();
|
|
|
|
break;
|
|
|
|
case 'text64':
|
|
|
|
$column_type = 'varchar(64)';
|
|
|
|
$charset = $this->getUTF8Charset();
|
|
|
|
$collation = $this->getUTF8Collation();
|
|
|
|
break;
|
|
|
|
case 'text32':
|
|
|
|
$column_type = 'varchar(32)';
|
|
|
|
$charset = $this->getUTF8Charset();
|
|
|
|
$collation = $this->getUTF8Collation();
|
|
|
|
break;
|
2014-09-18 20:15:38 +02:00
|
|
|
case 'text20':
|
|
|
|
$column_type = 'varchar(20)';
|
|
|
|
$charset = $this->getUTF8Charset();
|
|
|
|
$collation = $this->getUTF8Collation();
|
|
|
|
break;
|
2014-09-18 17:36:22 +02:00
|
|
|
case 'text16':
|
|
|
|
$column_type = 'varchar(16)';
|
|
|
|
$charset = $this->getUTF8Charset();
|
|
|
|
$collation = $this->getUTF8Collation();
|
|
|
|
break;
|
2014-09-18 17:32:44 +02:00
|
|
|
case 'text12':
|
|
|
|
$column_type = 'varchar(12)';
|
|
|
|
$charset = $this->getUTF8Charset();
|
|
|
|
$collation = $this->getUTF8Collation();
|
|
|
|
break;
|
2014-09-18 20:15:29 +02:00
|
|
|
case 'text8':
|
|
|
|
$column_type = 'varchar(8)';
|
|
|
|
$charset = $this->getUTF8Charset();
|
|
|
|
$collation = $this->getUTF8Collation();
|
|
|
|
break;
|
|
|
|
case 'text4':
|
|
|
|
$column_type = 'varchar(4)';
|
|
|
|
$charset = $this->getUTF8Charset();
|
|
|
|
$collation = $this->getUTF8Collation();
|
|
|
|
break;
|
2014-09-18 17:25:34 +02:00
|
|
|
case 'text':
|
|
|
|
$column_type = 'longtext';
|
|
|
|
$charset = $this->getUTF8Charset();
|
|
|
|
$collation = $this->getUTF8Collation();
|
|
|
|
break;
|
2014-09-18 17:32:44 +02:00
|
|
|
case 'bool':
|
|
|
|
$column_type = 'tinyint(1)';
|
|
|
|
break;
|
2014-09-19 14:45:24 +02:00
|
|
|
case 'double':
|
|
|
|
$column_type = 'double';
|
|
|
|
break;
|
2014-09-19 20:46:20 +02:00
|
|
|
case 'date':
|
|
|
|
$column_type = 'date';
|
|
|
|
break;
|
2014-09-18 17:25:34 +02:00
|
|
|
default:
|
|
|
|
$column_type = pht('<unknown>');
|
|
|
|
$charset = pht('<unknown>');
|
|
|
|
$collation = pht('<unknown>');
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
2014-09-18 17:32:44 +02:00
|
|
|
return array($column_type, $charset, $collation, $nullable);
|
2014-09-18 17:25:34 +02:00
|
|
|
}
|
2014-09-18 17:22:54 +02:00
|
|
|
|
|
|
|
}
|