diff options
Diffstat (limited to 'docker/crupest-api/CrupestApi/CrupestApi.Commons')
4 files changed, 179 insertions, 8 deletions
diff --git a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/ColumnInfo.cs b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/ColumnInfo.cs new file mode 100644 index 0000000..8b4607d --- /dev/null +++ b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/ColumnInfo.cs @@ -0,0 +1,69 @@ +using System.Reflection; + +namespace CrupestApi.Commons.Crud; + +public class ColumnInfo +{ + private Type ExtractRealTypeFromNullable(Type type) + { + if (type.IsGenericType && type.GetGenericTypeDefinition() == typeof(Nullable<>)) + { + return type.GetGenericArguments()[0]; + } + + return type; + } + + // A column with no property. + public ColumnInfo(Type entityType, string sqlColumnName, bool isPrimaryKey, bool isAutoIncrement, IColumnTypeInfo typeInfo) + { + EntityType = entityType; + PropertyName = null; + PropertyType = typeof(int); + PropertyRealType = typeof(int); + SqlColumnName = sqlColumnName; + ColumnTypeInfo = typeInfo; + Nullable = false; + IsPrimaryKey = isPrimaryKey; + IsAutoIncrement = isAutoIncrement; + } + + public ColumnInfo(Type entityType, string entityPropertyName) + { + EntityType = entityType; + PropertyName = entityPropertyName; + + var property = entityType.GetProperty(entityPropertyName); + + if (property is null) + throw new Exception("Public property with given name does not exist."); + + PropertyType = property.PropertyType; + PropertyRealType = ExtractRealTypeFromNullable(PropertyType); + + var columnAttribute = property.GetCustomAttribute<ColumnAttribute>(); + if (columnAttribute is null) + { + SqlColumnName = PropertyName; + Nullable = true; + } + else + { + SqlColumnName = columnAttribute.DatabaseName ?? PropertyName; + Nullable = !columnAttribute.NonNullable; + } + ColumnTypeInfo = ColumnTypeInfoRegistry.Singleton.GetRequiredByDataType(PropertyRealType); + + } + + public Type EntityType { get; } + // If null, there is no corresponding property. + public string? PropertyName { get; } + public Type PropertyType { get; } + public Type PropertyRealType { get; } + public string SqlColumnName { get; } + public IColumnTypeInfo ColumnTypeInfo { get; } + public bool Nullable { get; } + public bool IsPrimaryKey { get; } + public bool IsAutoIncrement { get; } +}
\ No newline at end of file diff --git a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/ColumnMetadata.cs b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/ColumnMetadata.cs new file mode 100644 index 0000000..cbf38f7 --- /dev/null +++ b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/ColumnMetadata.cs @@ -0,0 +1,21 @@ +namespace CrupestApi.Commons.Crud; + +public interface IColumnMetadata +{ + +} + +[AttributeUsage(AttributeTargets.Property, AllowMultiple = false)] +public class ColumnAttribute : Attribute, IColumnMetadata +{ + // if null, use the property name. + public string? DatabaseName { get; set; } + + // default false. + public bool NonNullable { get; set; } + + // default false + public bool IsPrimaryKey { get; set; } + + public bool IsAutoIncrement { get; set; } +} diff --git a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/ColumnTypeInfo.cs b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/ColumnTypeInfo.cs index 02848f3..1bdc9c0 100644 --- a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/ColumnTypeInfo.cs +++ b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/ColumnTypeInfo.cs @@ -1,6 +1,6 @@ using System.Diagnostics; -namespace CrupestApi.Commons; +namespace CrupestApi.Commons.Crud; public interface IColumnTypeInfo { @@ -15,7 +15,7 @@ public interface IColumnTypeInfo IColumnTypeInfo current = this; - while (!typeof(BuiltinColumnTypeInfo<>).IsInstanceOfType(current)) + while (current is not IBuiltinColumnTypeInfo) { var dataType = GetDataType(); @@ -86,7 +86,12 @@ public class BuiltinColumnTypeInfo<T> : IBuiltinColumnTypeInfo } } -public abstract class CustomColumnTypeInfo<TDataType, TDatabaseType> : IColumnTypeInfo +public interface ICustomColumnTypeInfo : IColumnTypeInfo +{ + +} + +public abstract class CustomColumnTypeInfo<TDataType, TDatabaseType> : ICustomColumnTypeInfo where TDataType : notnull where TDatabaseType : notnull { @@ -105,13 +110,13 @@ public abstract class CustomColumnTypeInfo<TDataType, TDatabaseType> : IColumnTy object IColumnTypeInfo.ConvertToDatabase(object data) { - Debug.Assert(typeof(TDataType).IsInstanceOfType(data)); + Debug.Assert(data is TDataType); return ConvertToDatabase((TDataType)data); } object IColumnTypeInfo.ConvertFromDatabase(object databaseData) { - Debug.Assert(typeof(TDatabaseType).IsInstanceOfType(databaseData)); + Debug.Assert(databaseData is TDatabaseType); return ConvertFromDatabase((TDatabaseType)databaseData); } } @@ -155,8 +160,6 @@ public class ColumnTypeInfoRegistry Singleton.Validate(); } - - private readonly List<IColumnTypeInfo> _list; private readonly Dictionary<Type, IColumnTypeInfo> _map; private bool _dirty = false; @@ -180,6 +183,11 @@ public class ColumnTypeInfoRegistry return _map.GetValueOrDefault(type); } + public IColumnTypeInfo GetRequiredByDataType(Type type) + { + return GetByDataType(type) ?? throw new Exception("Unsupported type."); + } + public string GetSqlType(Type type) { EnsureValidity(); @@ -190,7 +198,7 @@ public class ColumnTypeInfoRegistry throw new Exception("Unsupported type for sql."); } - while (!typeof(IBuiltinColumnTypeInfo).IsInstanceOfType(current)) + while (current is not IBuiltinColumnTypeInfo) { current = GetByDataType(current.GetDatabaseType()); Debug.Assert(current is not null); diff --git a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/TableInfo.cs b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/TableInfo.cs new file mode 100644 index 0000000..fb9e1ad --- /dev/null +++ b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/TableInfo.cs @@ -0,0 +1,73 @@ +namespace CrupestApi.Commons.Crud; + +public class TableInfo +{ + public TableInfo(Type entityType) + { + EntityType = entityType; + + var properties = entityType.GetProperties(); + + var columnInfos = new List<ColumnInfo>(); + + bool hasPrimaryKey = false; + bool hasId = false; + + foreach (var property in properties) + { + var columnInfo = new ColumnInfo(entityType, property.Name); + columnInfos.Add(columnInfo); + if (columnInfo.IsPrimaryKey) + hasPrimaryKey = true; + if (columnInfo.SqlColumnName.Equals("id", StringComparison.OrdinalIgnoreCase)) + { + hasId = true; + } + } + + if (!hasPrimaryKey) + { + if (hasId) throw new Exception("A column named id already exists but is not primary key."); + var columnInfo = new ColumnInfo(entityType, "id", true, true, ColumnTypeInfoRegistry.Singleton.GetRequiredByDataType(typeof(int))); + columnInfos.Add(columnInfo); + } + + ColumnInfos = columnInfos; + + CheckValidity(); + } + + public Type EntityType { get; } + public IReadOnlyList<ColumnInfo> ColumnInfos { get; } + + public void CheckValidity() + { + // Check if there is only one primary key. + bool hasPrimaryKey = false; + foreach (var column in ColumnInfos) + { + if (column.IsPrimaryKey) + { + if (hasPrimaryKey) throw new Exception("Two columns are primary key."); + hasPrimaryKey = true; + } + } + + if (!hasPrimaryKey) throw new Exception("No column is primary key."); + + // Check two columns have the same sql name. + HashSet<string> sqlNameSet = new HashSet<string>(); + + foreach (var column in ColumnInfos) + { + if (sqlNameSet.Contains(column.SqlColumnName)) + throw new Exception($"Two columns have the same sql name '{column.SqlColumnName}'."); + sqlNameSet.Add(column.SqlColumnName); + } + } + + public string GenerateCreateTableSql() + { + throw new NotImplementedException(); + } +}
\ No newline at end of file |