Develop secret api. v7

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