blob: 551141b80d3678968011b0e0b4ecc9b262ffa1c8 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
<?php
namespace Kanboard\Core\Plugin;
use PDOException;
use RuntimeException;
/**
* Class SchemaHandler
*
* @package Kanboard\Core\Plugin
* @author Frederic Guillot
*/
class SchemaHandler extends \Kanboard\Core\Base
{
/**
* Schema version table for plugins
*
* @var string
*/
const TABLE_SCHEMA = 'plugin_schema_versions';
/**
* Get schema filename
*
* @static
* @access public
* @param string $pluginName
* @return string
*/
public static function getSchemaFilename($pluginName)
{
return PLUGINS_DIR.'/'.$pluginName.'/Schema/'.ucfirst(DB_DRIVER).'.php';
}
/**
* Return true if the plugin has schema
*
* @static
* @access public
* @param string $pluginName
* @return boolean
*/
public static function hasSchema($pluginName)
{
return file_exists(self::getSchemaFilename($pluginName));
}
/**
* Load plugin schema
*
* @access public
* @param string $pluginName
*/
public function loadSchema($pluginName)
{
require_once self::getSchemaFilename($pluginName);
$this->migrateSchema($pluginName);
}
/**
* Execute plugin schema migrations
*
* @access public
* @param string $pluginName
*/
public function migrateSchema($pluginName)
{
$lastVersion = constant('\Kanboard\Plugin\\'.$pluginName.'\Schema\VERSION');
$currentVersion = $this->getSchemaVersion($pluginName);
try {
$this->db->startTransaction();
$this->db->getDriver()->disableForeignKeys();
for ($i = $currentVersion + 1; $i <= $lastVersion; $i++) {
$functionName = '\Kanboard\Plugin\\'.$pluginName.'\Schema\version_'.$i;
if (function_exists($functionName)) {
call_user_func($functionName, $this->db->getConnection());
}
}
$this->db->getDriver()->enableForeignKeys();
$this->db->closeTransaction();
$this->setSchemaVersion($pluginName, $i - 1);
} catch (PDOException $e) {
$this->db->cancelTransaction();
$this->db->getDriver()->enableForeignKeys();
throw new RuntimeException('Unable to migrate schema for the plugin: '.$pluginName.' => '.$e->getMessage());
}
}
/**
* Get current plugin schema version
*
* @access public
* @param string $plugin
* @return integer
*/
public function getSchemaVersion($plugin)
{
return (int) $this->db->table(self::TABLE_SCHEMA)->eq('plugin', strtolower($plugin))->findOneColumn('version');
}
/**
* Save last plugin schema version
*
* @access public
* @param string $plugin
* @param integer $version
* @return boolean
*/
public function setSchemaVersion($plugin, $version)
{
$dictionary = array(
strtolower($plugin) => $version
);
return $this->db->getDriver()->upsert(self::TABLE_SCHEMA, 'plugin', 'version', $dictionary);
}
}
|
