Thomas Müller
10 years ago
14 changed files with 9 additions and 282 deletions
-
5core/command/db/converttype.php
-
5core/js/setup.js
-
3core/templates/installation.php
-
2lib/private/db.php
-
6lib/private/db/connectionfactory.php
-
3lib/private/db/mdb2schemamanager.php
-
37lib/private/db/mssqlmigrator.php
-
7lib/private/setup.php
-
203lib/private/setup/mssql.php
-
2lib/private/setup/mysql.php
-
4tests/lib/db/mdb2schemamanager.php
-
6tests/lib/db/migrator.php
-
3tests/lib/dbschema.php
-
5tests/lib/setup.php
@ -1,37 +0,0 @@ |
|||
<?php |
|||
/** |
|||
* @author Morris Jobke <hey@morrisjobke.de> |
|||
* @author Thomas Müller <thomas.mueller@tmit.eu> |
|||
* |
|||
* @copyright Copyright (c) 2015, ownCloud, Inc. |
|||
* @license AGPL-3.0 |
|||
* |
|||
* This code is free software: you can redistribute it and/or modify |
|||
* it under the terms of the GNU Affero General Public License, version 3, |
|||
* as published by the Free Software Foundation. |
|||
* |
|||
* This program is distributed in the hope that it will be useful, |
|||
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|||
* GNU Affero General Public License for more details. |
|||
* |
|||
* You should have received a copy of the GNU Affero General Public License, version 3, |
|||
* along with this program. If not, see <http://www.gnu.org/licenses/> |
|||
* |
|||
*/ |
|||
|
|||
namespace OC\DB; |
|||
|
|||
use Doctrine\DBAL\Schema\Schema; |
|||
|
|||
class MsSqlMigrator extends Migrator { |
|||
|
|||
/** |
|||
* @param \Doctrine\DBAL\Schema\Schema $targetSchema |
|||
*/ |
|||
public function migrate(Schema $targetSchema) { |
|||
throw new MigrationException('', |
|||
'Database migration is required to continue operation. This feature is provided within the Enterprise Edition.'); |
|||
} |
|||
|
|||
} |
|||
@ -1,203 +0,0 @@ |
|||
<?php |
|||
/** |
|||
* @author Bart Visscher <bartv@thisnet.nl> |
|||
* @author Joas Schilling <nickvergessen@owncloud.com> |
|||
* @author Morris Jobke <hey@morrisjobke.de> |
|||
* @author Thomas Müller <thomas.mueller@tmit.eu> |
|||
* |
|||
* @copyright Copyright (c) 2015, ownCloud, Inc. |
|||
* @license AGPL-3.0 |
|||
* |
|||
* This code is free software: you can redistribute it and/or modify |
|||
* it under the terms of the GNU Affero General Public License, version 3, |
|||
* as published by the Free Software Foundation. |
|||
* |
|||
* This program is distributed in the hope that it will be useful, |
|||
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|||
* GNU Affero General Public License for more details. |
|||
* |
|||
* You should have received a copy of the GNU Affero General Public License, version 3, |
|||
* along with this program. If not, see <http://www.gnu.org/licenses/> |
|||
* |
|||
*/ |
|||
namespace OC\Setup; |
|||
|
|||
class MSSQL extends AbstractDatabase { |
|||
public $dbprettyname = 'MS SQL Server'; |
|||
|
|||
public function setupDatabase($username) { |
|||
//check if the database user has admin right
|
|||
$masterConnectionInfo = array( "Database" => "master", "UID" => $this->dbuser, "PWD" => $this->dbpassword); |
|||
|
|||
$masterConnection = @sqlsrv_connect($this->dbhost, $masterConnectionInfo); |
|||
if(!$masterConnection) { |
|||
$entry = ''; |
|||
if( ($errors = sqlsrv_errors() ) != null) { |
|||
$entry='DB Error: "'.print_r(sqlsrv_errors()).'"<br />'; |
|||
} |
|||
throw new \OC\DatabaseSetupException($this->trans->t('MS SQL username and/or password not valid: %s', array($entry)), |
|||
$this->trans->t('You need to enter either an existing account or the administrator.')); |
|||
} |
|||
|
|||
\OC_Config::setValues([ |
|||
'dbuser' => $this->dbuser, |
|||
'dbpassword' => $this->dbpassword, |
|||
]); |
|||
|
|||
$this->createDBLogin($masterConnection); |
|||
|
|||
$this->createDatabase($masterConnection); |
|||
|
|||
$this->createDBUser($masterConnection); |
|||
|
|||
sqlsrv_close($masterConnection); |
|||
|
|||
$this->createDatabaseStructure(); |
|||
} |
|||
|
|||
private function createDBLogin($connection) { |
|||
$query = "SELECT * FROM master.sys.server_principals WHERE name = '".$this->dbuser."';"; |
|||
$result = sqlsrv_query($connection, $query); |
|||
if ($result === false) { |
|||
if ( ($errors = sqlsrv_errors() ) != null) { |
|||
$entry='DB Error: "'.print_r(sqlsrv_errors()).'"<br />'; |
|||
} else { |
|||
$entry = ''; |
|||
} |
|||
$entry.='Offending command was: '.$query.'<br />'; |
|||
\OCP\Util::writeLog('setup.mssql', $entry, \OCP\Util::WARN); |
|||
} else { |
|||
$row = sqlsrv_fetch_array($result); |
|||
|
|||
if ($row === false) { |
|||
if ( ($errors = sqlsrv_errors() ) != null) { |
|||
$entry='DB Error: "'.print_r(sqlsrv_errors()).'"<br />'; |
|||
} else { |
|||
$entry = ''; |
|||
} |
|||
$entry.='Offending command was: '.$query.'<br />'; |
|||
\OCP\Util::writeLog('setup.mssql', $entry, \OCP\Util::WARN); |
|||
} else { |
|||
if ($row == null) { |
|||
$query = "CREATE LOGIN [".$this->dbuser."] WITH PASSWORD = '".$this->dbpassword."';"; |
|||
$result = sqlsrv_query($connection, $query); |
|||
if (!$result or $result === false) { |
|||
if ( ($errors = sqlsrv_errors() ) != null) { |
|||
$entry='DB Error: "'.print_r(sqlsrv_errors()).'"<br />'; |
|||
} else { |
|||
$entry = ''; |
|||
} |
|||
$entry.='Offending command was: '.$query.'<br />'; |
|||
\OCP\Util::writeLog('setup.mssql', $entry, \OCP\Util::WARN); |
|||
} |
|||
} |
|||
} |
|||
} |
|||
} |
|||
|
|||
private function createDBUser($connection) { |
|||
$query = "SELECT * FROM [".$this->dbname."].sys.database_principals WHERE name = '".$this->dbuser."';"; |
|||
$result = sqlsrv_query($connection, $query); |
|||
if ($result === false) { |
|||
if ( ($errors = sqlsrv_errors() ) != null) { |
|||
$entry='DB Error: "'.print_r(sqlsrv_errors()).'"<br />'; |
|||
} else { |
|||
$entry = ''; |
|||
} |
|||
$entry.='Offending command was: '.$query.'<br />'; |
|||
\OCP\Util::writeLog('setup.mssql', $entry, \OCP\Util::WARN); |
|||
} else { |
|||
$row = sqlsrv_fetch_array($result); |
|||
|
|||
if ($row === false) { |
|||
if ( ($errors = sqlsrv_errors() ) != null) { |
|||
$entry='DB Error: "'.print_r(sqlsrv_errors()).'"<br />'; |
|||
} else { |
|||
$entry = ''; |
|||
} |
|||
$entry.='Offending command was: '.$query.'<br />'; |
|||
\OCP\Util::writeLog('setup.mssql', $entry, \OCP\Util::WARN); |
|||
} else { |
|||
if ($row == null) { |
|||
$query = "USE [".$this->dbname."]; CREATE USER [".$this->dbuser."] FOR LOGIN [".$this->dbuser."];"; |
|||
$result = sqlsrv_query($connection, $query); |
|||
if (!$result || $result === false) { |
|||
if ( ($errors = sqlsrv_errors() ) != null) { |
|||
$entry = 'DB Error: "'.print_r(sqlsrv_errors()).'"<br />'; |
|||
} else { |
|||
$entry = ''; |
|||
} |
|||
$entry.='Offending command was: '.$query.'<br />'; |
|||
\OCP\Util::writeLog('setup.mssql', $entry, \OCP\Util::WARN); |
|||
} |
|||
} |
|||
|
|||
$query = "USE [".$this->dbname."]; EXEC sp_addrolemember 'db_owner', '".$this->dbuser."';"; |
|||
$result = sqlsrv_query($connection, $query); |
|||
if (!$result || $result === false) { |
|||
if ( ($errors = sqlsrv_errors() ) != null) { |
|||
$entry='DB Error: "'.print_r(sqlsrv_errors()).'"<br />'; |
|||
} else { |
|||
$entry = ''; |
|||
} |
|||
$entry.='Offending command was: '.$query.'<br />'; |
|||
\OCP\Util::writeLog('setup.mssql', $entry, \OCP\Util::WARN); |
|||
} |
|||
} |
|||
} |
|||
} |
|||
|
|||
private function createDatabase($connection) { |
|||
$query = "CREATE DATABASE [".$this->dbname."];"; |
|||
$result = sqlsrv_query($connection, $query); |
|||
if (!$result || $result === false) { |
|||
if ( ($errors = sqlsrv_errors() ) != null) { |
|||
$entry='DB Error: "'.print_r(sqlsrv_errors()).'"<br />'; |
|||
} else { |
|||
$entry = ''; |
|||
} |
|||
$entry.='Offending command was: '.$query.'<br />'; |
|||
\OCP\Util::writeLog('setup.mssql', $entry, \OCP\Util::WARN); |
|||
} |
|||
} |
|||
|
|||
private function createDatabaseStructure() { |
|||
$connectionInfo = array( "Database" => $this->dbname, "UID" => $this->dbuser, "PWD" => $this->dbpassword); |
|||
|
|||
$connection = @sqlsrv_connect($this->dbhost, $connectionInfo); |
|||
|
|||
//fill the database if needed
|
|||
$query = "SELECT * FROM INFORMATION_SCHEMA.TABLES" |
|||
." WHERE TABLE_SCHEMA = '".$this->dbname."'" |
|||
." AND TABLE_NAME = '".$this->tableprefix."users'"; |
|||
$result = sqlsrv_query($connection, $query); |
|||
if ($result === false) { |
|||
if ( ($errors = sqlsrv_errors() ) != null) { |
|||
$entry='DB Error: "'.print_r(sqlsrv_errors()).'"<br />'; |
|||
} else { |
|||
$entry = ''; |
|||
} |
|||
$entry.='Offending command was: '.$query.'<br />'; |
|||
\OCP\Util::writeLog('setup.mssql', $entry, \OCP\Util::WARN); |
|||
} else { |
|||
$row = sqlsrv_fetch_array($result); |
|||
|
|||
if ($row === false) { |
|||
if ( ($errors = sqlsrv_errors() ) != null) { |
|||
$entry='DB Error: "'.print_r(sqlsrv_errors()).'"<br />'; |
|||
} else { |
|||
$entry = ''; |
|||
} |
|||
$entry.='Offending command was: '.$query.'<br />'; |
|||
\OCP\Util::writeLog('setup.mssql', $entry, \OCP\Util::WARN); |
|||
} else { |
|||
if ($row == null) { |
|||
\OC_DB::createDbFromStructure($this->dbDefinitionFile); |
|||
} |
|||
} |
|||
} |
|||
|
|||
sqlsrv_close($connection); |
|||
} |
|||
} |
|||
Write
Preview
Loading…
Cancel
Save
Reference in new issue