tonyair/silverstripe-mssql
1
0
Fork 0
mirror of https://github.com/silverstripe/silverstripe-mssql synced 2024-10-22 08:05:53 +02:00
Code Issues Projects Releases Wiki Activity

ENCHANCEMENT: Added fullTextEnabled property to MSSQLDatabase object, to let developers completely disabled all fulltext functionality.

Browse Source
This commit is contained in:
Sam Minnee 2009-05-08 03:37:31 +00:00
parent 3fbf62c4cd
commit 87760aa5b3
1 changed files with 59 additions and 48 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

107
code/MSSQLDatabase.php
View File

@ -29,6 +29,11 @@ class MSSQLDatabase extends Database {
*/ */
private $database; private $database;
/**
* Does this database have full-text index supprt
*/
protected $fullTextEnabled = false;
/** /**
* Connect to a MS SQL database. * Connect to a MS SQL database.
* @param array $parameters An map of parameters, which should include: * @param array $parameters An map of parameters, which should include:
@ -65,9 +70,11 @@ class MSSQLDatabase extends Database {
* TODO: VERY IMPORTANT: move this so it only gets called upon a dev/build action * TODO: VERY IMPORTANT: move this so it only gets called upon a dev/build action
*/ */
function createFullTextCatalog(){ function createFullTextCatalog(){
$this->query("exec sp_fulltext_database 'enable';"); if($this->fullTextEnabled) {
$result = $this->query("SELECT name FROM sys.fulltext_catalogs WHERE name = 'ftCatalog';")->value(); $this->query("exec sp_fulltext_database 'enable';");
if(!$result) $this->query("CREATE FULLTEXT CATALOG ftCatalog AS DEFAULT;"); $result = $this->query("SELECT name FROM sys.fulltext_catalogs WHERE name = 'ftCatalog';")->value();
if(!$result) $this->query("CREATE FULLTEXT CATALOG ftCatalog AS DEFAULT;");
}
} }
/** /**
* Not implemented, needed for PDO * Not implemented, needed for PDO
@ -244,9 +251,8 @@ class MSSQLDatabase extends Database {
//we need to generate indexes like this: CREATE INDEX IX_vault_to_export ON vault (to_export); //we need to generate indexes like this: CREATE INDEX IX_vault_to_export ON vault (to_export);
//This needs to be done AFTER the table creation, so we can set up the fulltext indexes correctly //This needs to be done AFTER the table creation, so we can set up the fulltext indexes correctly
if($indexes) foreach($indexes as $k => $v) $indexSchemas .= $this->getIndexSqlDefinition($tableName, $k, $v) . "\n"; if($indexes) foreach($indexes as $k => $v) $indexSchemas .= $this->getIndexSqlDefinition($tableName, $k, $v) . "\n";
$this->query($indexSchemas); $this->query($indexSchemas);
} }
/** /**
@ -305,9 +311,9 @@ class MSSQLDatabase extends Database {
} }
} }
foreach($alterIndexList as $alteration) foreach($alterIndexList as $alteration) {
if($alteration!='') if($alteration!='') $this->query($alteration);
$this->query($alteration); }
} }
/* /*
@ -520,20 +526,22 @@ class MSSQLDatabase extends Database {
} else { } else {
//create a type-specific index //create a type-specific index
if($indexSpec['type']=='fulltext'){ if($indexSpec['type']=='fulltext'){
//Enable full text search. if($this->fullTextEnabled) {
$this->createFullTextCatalog(); //Enable full text search.
$this->createFullTextCatalog();
$primary_key=$this->getPrimaryKey($tableName); $primary_key=$this->getPrimaryKey($tableName);
//First, we need to see if a full text search already exists: //First, we need to see if a full text search already exists:
$result=$this->query("SELECT object_id FROM sys.fulltext_indexes WHERE object_id=object_id('$tableName');")->first(); $result=$this->query("SELECT object_id FROM sys.fulltext_indexes WHERE object_id=object_id('$tableName');")->first();
$drop=''; $drop='';
if($result) if($result)
$drop="DROP FULLTEXT INDEX ON \"" . $tableName . "\";"; $drop="DROP FULLTEXT INDEX ON \"" . $tableName . "\";";
return $drop . "CREATE FULLTEXT INDEX ON \"$tableName\" ({$indexSpec['value']}) " . return $drop . "CREATE FULLTEXT INDEX ON \"$tableName\" ({$indexSpec['value']}) " .
"KEY INDEX $primary_key WITH CHANGE_TRACKING AUTO;"; "KEY INDEX $primary_key WITH CHANGE_TRACKING AUTO;";
}
} }
@ -592,20 +600,22 @@ class MSSQLDatabase extends Database {
} }
//Now we need to check to see if we have any fulltext indexes attached to this table: //Now we need to check to see if we have any fulltext indexes attached to this table:
$result=DB::query('EXEC sp_help_fulltext_columns;'); if($this->fullTextEnabled) {
$columns=''; $result=DB::query('EXEC sp_help_fulltext_columns;');
foreach($result as $row){ $columns='';
foreach($result as $row){
if($row['TABLE_NAME']==$table) if($row['TABLE_NAME']==$table)
$columns.=$row['FULLTEXT_COLUMN_NAME'] . ','; $columns.=$row['FULLTEXT_COLUMN_NAME'] . ',';
} }
if($columns!=''){ if($columns!=''){
$columns=trim($columns, ','); $columns=trim($columns, ',');
$indexList['SearchFields']['indexname']='SearchFields'; $indexList['SearchFields']['indexname']='SearchFields';
$indexList['SearchFields']['spec']='fulltext (' . $columns . ')'; $indexList['SearchFields']['spec']='fulltext (' . $columns . ')';
} }
}
return isset($indexList) ? $indexList : null; return isset($indexList) ? $indexList : null;
@ -1002,29 +1012,30 @@ class MSSQLDatabase extends Database {
* @param string $keywords Keywords as a string. * @param string $keywords Keywords as a string.
*/ */
public function searchEngine($classesToSearch, $keywords, $pageLength = null, $sortBy = "Relevance DESC", $extraFilter = "", $booleanSearch = false, $alternativeFileFilter = "", $invertedMatch = false) { public function searchEngine($classesToSearch, $keywords, $pageLength = null, $sortBy = "Relevance DESC", $extraFilter = "", $booleanSearch = false, $alternativeFileFilter = "", $invertedMatch = false) {
if($this->fullTextEnabled) {
$result=DB::query('EXEC sp_help_fulltext_columns;');
$result=DB::query('EXEC sp_help_fulltext_columns;'); //Get a list of all the tables and columns we'll be searching on:
$tables=Array();
foreach($result as $row){
if(substr($row['TABLE_NAME'], -5)!='_Live' && substr($row['TABLE_NAME'], -9)!='_versions')
$tables[]="SELECT ID, '{$row['TABLE_NAME']}' AS Source FROM \"{$row['TABLE_NAME']}\" WHERE CONTAINS(\"{$row['FULLTEXT_COLUMN_NAME']}\", N'$keywords')";
}
//Get a list of all the tables and columns we'll be searching on: //We'll do a union query on all of these tables... it's easeier!
$tables=Array(); $query=implode(' UNION ', $tables);
foreach($result as $row){
if(substr($row['TABLE_NAME'], -5)!='_Live' && substr($row['TABLE_NAME'], -9)!='_versions') $result=DB::query($query);
$tables[]="SELECT ID, '{$row['TABLE_NAME']}' AS Source FROM \"{$row['TABLE_NAME']}\" WHERE CONTAINS(\"{$row['FULLTEXT_COLUMN_NAME']}\", N'$keywords')";
$searchResults=new DataObjectSet();
foreach($result as $row){
$row_result=DataObject::get_by_id($row['Source'], $row['ID']);
$searchResults->push($row_result);
}
$searchResults->setPageLimits($start, $pageLength, $totalCount);
} }
//We'll do a union query on all of these tables... it's easeier!
$query=implode(' UNION ', $tables);
$result=DB::query($query);
$searchResults=new DataObjectSet();
foreach($result as $row){
$row_result=DataObject::get_by_id($row['Source'], $row['ID']);
$searchResults->push($row_result);
}
$searchResults->setPageLimits($start, $pageLength, $totalCount);
return $searchResults; return $searchResults;
} }