diff options
Diffstat (limited to 'docker/crupest-api')
3 files changed, 77 insertions, 25 deletions
diff --git a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/CrudService.cs b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/CrudService.cs index af6a8d5..9400a7b 100644 --- a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/CrudService.cs +++ b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/CrudService.cs @@ -63,7 +63,7 @@ public class CrudService<TEntity> : IDisposable where TEntity : class // Return the key. public object Insert(TEntity entity) { - return _table.Insert(_dbConnection, _table.GenerateInsertClauseFromEntity(entity)); + return _table.Insert(_dbConnection, ); } public int Update(IUpdateClause updateClause, IWhereClause? filter) diff --git a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/README.md b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/README.md new file mode 100644 index 0000000..c30ea90 --- /dev/null +++ b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/README.md @@ -0,0 +1,27 @@ +# CRUD Technic Notes + +## Database Pipeline + +### Select + +1. Create select `what`, where clause, order clause, `Offset` and `Limit`. +2. Check clauses' related columns are valid. Then generate sql string and param list. +3. Convert param list to `Dapper` dynamic params. Execute sql and get `dynamic`s. +4. Run hook `AfterSelect` for every column. +5. Convert `dynamic`s to `TEntity`s. + +TODO: Continue here. + +### Insert + +1. Create insert clause consisting of insert items. +2. Check clauses' related columns are valid. Then generate sql string and param list. +3. Run hook `BeforeInsert` for every column. +4. Convert param list to `Dapper` dynamic params. Execute sql and return `KeyColumn` value. + +### Update + +1. Create update clause consisting of update items, where clause. +2. Check clauses' related columns are valid. Then generate sql string and param list. +3. Run hook `BeforeUpdate` for every column. +4. Convert param list to `Dapper` dynamic params. Execute sql and get count of affected rows. diff --git a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/TableInfo.cs b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/TableInfo.cs index 61cd04f..089ff8a 100644 --- a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/TableInfo.cs +++ b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/TableInfo.cs @@ -239,7 +239,7 @@ CREATE TABLE {tableName}( /// <summary> /// If you call this manually, it's your duty to call hooks. /// </summary> - /// <seealso cref="Select"/> + /// <seealso cref="SelectDynamic"/> public (string sql, ParamList parameters) GenerateSelectSql(string? selectWhat, IWhereClause? whereClause, IOrderByClause? orderByClause = null, int? skip = null, int? limit = null, string? dbProviderId = null) { CheckRelatedColumns(whereClause); @@ -389,30 +389,16 @@ CREATE TABLE {tableName}( return result; } - public virtual int SelectCount(IDbConnection dbConnection, IWhereClause? where = null, IOrderByClause? orderBy = null, int? skip = null, int? limit = null) - { - var (sql, parameters) = GenerateSelectSql("COUNT(*)", where, orderBy, skip, limit); - return dbConnection.QuerySingle<int>(sql, parameters); - - } - - public virtual IEnumerable<object?> Select(IDbConnection dbConnection, IWhereClause? where = null, IOrderByClause? orderBy = null, int? skip = null, int? limit = null) - { - return Select<IEnumerable<object?>>(dbConnection, null, where, orderBy, skip, limit); - } - /// <summary> - /// Select and call hooks. + /// ConvertParameters. Select. Call hooks. /// </summary> - public virtual IEnumerable<TResult> Select<TResult>(IDbConnection dbConnection, string? what, IWhereClause? where = null, IOrderByClause? orderBy = null, int? skip = null, int? limit = null) + public virtual List<dynamic> SelectDynamic(IDbConnection dbConnection, string? what, IWhereClause? where = null, IOrderByClause? orderBy = null, int? skip = null, int? limit = null) { var (sql, parameters) = GenerateSelectSql(what, where, orderBy, skip, limit); - return dbConnection.Query<dynamic>(sql, parameters).Select(d => + var queryResult = dbConnection.Query<dynamic>(sql, ConvertParameters(parameters)); + return queryResult.Select(d => { Type dynamicType = d.GetType(); - - var result = Activator.CreateInstance<TResult>(); - foreach (var column in ColumnInfos) { object? value = null; @@ -428,17 +414,56 @@ CREATE TABLE {tableName}( value = column.ColumnType.ConvertFromDatabase(value); column.Hooks.AfterSelect(column, ref value, true); } - var propertyInfo = column.PropertyInfo; - if (propertyInfo is not null) + + if (dynamicProperty is not null) { - propertyInfo.SetValue(result, value); + dynamicProperty.SetValue(d, value); } } - return result; - }); + return d; + }).ToList(); + } + + public virtual int SelectCount(IDbConnection dbConnection, IWhereClause? where = null, IOrderByClause? orderBy = null, int? skip = null, int? limit = null) + { + var (sql, parameters) = GenerateSelectSql("COUNT(*)", where, orderBy, skip, limit); + return dbConnection.QuerySingle<int>(sql, parameters); + + } + + public virtual TResult MapDynamicTo<TResult>(dynamic d) + { + var result = Activator.CreateInstance<TResult>(); + + Type dynamicType = d.GetType(); + Type resultType = typeof(TResult); + + foreach (var column in ColumnInfos) + { + var dynamicProperty = dynamicType.GetProperty(column.ColumnName); + // TODO: Maybe we can do better to get result property in case ColumnName is set to another value. + var resultProperty = resultType.GetProperty(column.ColumnName); + if (dynamicProperty is not null && resultProperty is not null) + { + resultProperty.SetValue(result, dynamicProperty.GetValue(d)); + } + } + + return result; + } + + /// <summary> + /// Select and call hooks. + /// </summary> + public virtual List<TResult> Select<TResult>(IDbConnection dbConnection, string? what, IWhereClause? where = null, IOrderByClause? orderBy = null, int? skip = null, int? limit = null) + { + List<dynamic> queryResult = SelectDynamic(dbConnection, what, where, orderBy, skip, limit).ToList(); + + return queryResult.Select(MapDynamicTo<TResult>).ToList(); } + // TODO: Continue here. /// <summary> /// Insert a entity and call hooks. /// </summary> |