Refactoring syntax providers for db creation.

Adding tests for sql, sql ce and mysql to ensure the creaion of tables and their dependencies/references.
This commit is contained in:
sitereactor
2012-10-19 19:07:17 -02:00
parent c1909eccf5
commit b3d8b4c53c
43 changed files with 947 additions and 688 deletions

View File

@@ -1,4 +1,7 @@
using Umbraco.Core.Persistence.SqlSyntax.ModelDefinitions;
using System.Collections.Generic;
using System.Text;
using Umbraco.Core.Persistence.DatabaseAnnotations;
using Umbraco.Core.Persistence.SqlSyntax.ModelDefinitions;
namespace Umbraco.Core.Persistence.SqlSyntax
{
@@ -13,13 +16,16 @@ namespace Umbraco.Core.Persistence.SqlSyntax
private MySqlSyntaxProvider()
{
DefaultStringLength = 255;
StringLengthColumnDefinitionFormat = StringLengthUnicodeColumnDefinitionFormat;
StringColumnDefinition = string.Format(StringLengthColumnDefinitionFormat, DefaultStringLength);
AutoIncrementDefinition = "AUTO_INCREMENT";
IntColumnDefinition = "int(11)";
BoolColumnDefinition = "tinyint(1)";
TimeColumnDefinition = "time";
DecimalColumnDefinition = "decimal(38,6)";
GuidColumnDefinition = "char(32)";
DefaultStringLength = 255;
InitColumnTypeMap();
@@ -41,6 +47,115 @@ namespace Umbraco.Core.Persistence.SqlSyntax
return string.Format("`{0}`", name);
}
public override string GetSpecialDbType(SpecialDbTypes dbTypes)
{
if (dbTypes == SpecialDbTypes.NCHAR)
{
return "CHAR";
}
else if (dbTypes == SpecialDbTypes.NTEXT)
return "LONGTEXT";
return "NVARCHAR";
}
public override string GetConstraintDefinition(ColumnDefinition column, string tableName)
{
var sql = new StringBuilder();
if (column.ConstraintDefaultValue.Equals("getdate()"))
{
sql.Append(" DEFAULT CURRENT_TIMESTAMP");
}
else
{
sql.AppendFormat(DefaultValueFormat, column.ConstraintDefaultValue);
}
/*sql.AppendFormat(DefaultValueFormat,
column.ConstraintDefaultValue.Equals("getdate()")
? "CURRENT_TIMESTAMP"
: column.ConstraintDefaultValue);*/
return sql.ToString();
}
public override string GetColumnDefinition(ColumnDefinition column, string tableName)
{
string dbTypeDefinition;
if (column.HasSpecialDbType)
{
if (column.DbTypeLength.HasValue)
{
dbTypeDefinition = string.Format("{0}({1})",
GetSpecialDbType(column.DbType),
column.DbTypeLength.Value);
}
else
{
dbTypeDefinition = GetSpecialDbType(column.DbType);
}
}
else if (column.PropertyType == typeof(string))
{
dbTypeDefinition = string.Format(StringLengthColumnDefinitionFormat, column.DbTypeLength.GetValueOrDefault(DefaultStringLength));
}
else
{
if (!DbTypeMap.ColumnTypeMap.TryGetValue(column.PropertyType, out dbTypeDefinition))
{
dbTypeDefinition = "";
}
}
var sql = new StringBuilder();
sql.AppendFormat("{0} {1}", GetQuotedColumnName(column.ColumnName), dbTypeDefinition);
if (column.IsPrimaryKeyIdentityColumn)
{
sql.Append(" NOT NULL PRIMARY KEY ").Append(AutoIncrementDefinition);
}
else
{
sql.Append(column.IsNullable ? " NULL" : " NOT NULL");
}
if (column.HasConstraint)
{
sql.Append(GetConstraintDefinition(column, tableName));
sql = sql.Replace("DATETIME", "TIMESTAMP");
}
return sql.ToString();
}
public override string GetPrimaryKeyStatement(ColumnDefinition column, string tableName)
{
return string.Empty;
}
public override List<string> ToCreateIndexStatements(TableDefinition table)
{
var indexes = new List<string>();
foreach (var index in table.IndexDefinitions)
{
string name = string.IsNullOrEmpty(index.IndexName)
? string.Format("IX_{0}_{1}", table.TableName, index.IndexForColumn)
: index.IndexName;
string columns = string.IsNullOrEmpty(index.ColumnNames)
? GetQuotedColumnName(index.IndexForColumn)
: index.ColumnNames;
indexes.Add(string.Format("CREATE INDEX {0} ON {1} ({2}); \n",
GetQuotedName(name),
GetQuotedTableName(table.TableName),
columns));
}
return indexes;
}
public override bool DoesTableExist(Database db, string tableName)
{
var result =