@ -8,8 +8,8 @@ using System.Linq;
using System.Reflection ;
using System.Threading ;
using System.Threading.Tasks ;
using GBase.Api ;
using GBase.Attributes ;
using GBase.Exceptions ;
using GBase.Factories ;
using GBase.FileHandling.Factories ;
using GBase.Helpers ;
@ -66,6 +66,18 @@ namespace GBase
/// </summary>
public List < T > Entries { get ; }
private int CurrentLastKey
{
get
{
T lastEntry = Entries . LastOrDefault ( ) ;
if ( lastEntry = = null )
return - 1 ;
return lastEntry . Key ;
}
}
/// <summary>
/// Initialize this <see cref="IGBase"/>
@ -75,7 +87,7 @@ namespace GBase
/// <param name="folderName"></param>
/// <param name="cancellationToken">A <see cref="CancellationToken"/> to cancel the asynchronous operation</param>
/// <returns>True if successful, false if not</returns>
public async Task < bool > Init ( Type type , string databasePath , string folderName , CancellationToken cancellationToken ) //TODO: Remove bool return value?
public async Task Init ( Type type , string databasePath , string folderName , CancellationToken cancellationToken )
{
Type = type ;
FolderName = folderName ;
@ -83,17 +95,19 @@ namespace GBase
//TODO: Init columns list depending on GBaseColumnAttributes set for this GBaseTable
foreach ( var property in type . GetProperties ( ) )
{
GBaseColumnAttribute gBaseColumnAttribute = property . GetCustomAttribute < GBaseColumnAttribute > ( ) ;
GBaseColumnAttribute gBaseColumnAttribute = property . GetCustomAttribute < GBaseColumnAttribute > ( ) ? ?
property . GetAttributeFromInheritedInterfaces < GBaseColumnAttribute > ( ) ;
if ( gBaseColumnAttribute = = null )
continue ;
IGBaseColumn gBaseColumn = _ gBaseColumnFactory . Create ( property . Name , property . PropertyType ) ;
IGBaseColumn gBaseColumn = _ gBaseColumnFactory . Create ( property . Name , property . PropertyType , gBaseColumnAttribute . IsKey ) ;
AddColumn ( gBaseColumn ) ;
}
List < IGBaseFile > files = _f ileHandler . Init ( databasePath , FolderName , cancellationToken ) ;
if ( files = = null )
return true ;
return ;
foreach ( var file in files ) //create entries for existing files
{
@ -102,25 +116,33 @@ namespace GBase
T entry = new T ( ) ;
List < object > parameters = new List < object > ( ) ;
foreach ( var column in Columns )
foreach ( var column in Columns . Where ( c = > ! c . IsKey ) )
{
IDataHandler dataHandler = await _d ataHandlerPool . RequestDataHandler ( this , false , cancellationToken ) ;
using IPoolItem < IDataHandler > dataHandlerItem = await _d ataHandlerPool . RequestDataHandler ( this , false , cancellationToken ) ;
parameters . Add ( await GenericMethodCaller . CallAsync ( dataHandler ,
parameters . Add ( await GenericMethodCaller . CallAsync ( dataHandlerItem . Use ( ) ,
nameof ( IDataHandler . GetValue ) ,
BindingFlags . Public | BindingFlags . Instance ,
typeof ( T ) , column . Type ,
file . File , column . Name , cancellationToken ) ) ;
}
entry . Initialize ( parameters ) ;
IGBaseColumn keyColumn = Columns . FirstOrDefault ( c = > c . IsKey ) ;
if ( keyColumn = = null )
throw new MissingKeyColumnException < T > ( ) ;
GBaseKey key = new GBaseKey ( ) ;
using ( IPoolItem < IDataHandler > dataHandlerItem = await _d ataHandlerPool . RequestDataHandler ( this , false , cancellationToken ) )
{
key . Key = await dataHandlerItem . Use ( ) . GetValue < T , int > ( file . File , keyColumn . Name , cancellationToken ) ;
}
entry . Initialize ( key , parameters ) ;
file . Entry = entry ;
Entries . Add ( entry ) ;
}
}
return true ;
}
/// <summary>
@ -151,26 +173,35 @@ namespace GBase
}
/// <summary>
/// Add an entry that implements <see cref="INotifyGBaseEntryChanged "/> to this <see cref="IGBaseTable"/>
/// Add an entry that implements <see cref="IGBaseObject "/> to this <see cref="IGBaseTable"/>
/// </summary>
/// <param name="entry">The entry implementing <see cref="INotifyGBaseEntryChanged "/></param>
/// <param name="entry">The entry implementing <see cref="IGBaseObject "/></param>
/// <param name="cancellationToken"></param>
/// <returns>True if successful, false if not</returns>
public async Task < bool > AddEntry ( T entry , CancellationToken cancellationToken )
{
entry . Key ? ? = new GBaseKey ( ) ;
if ( entry . Key ! = - 1 )
throw new InvalidKeyException ( "Key of entry is already set. Make sure it is -1 when initializing." ) ;
entry . Key . Key = CurrentLastKey + 1 ; //set next possible key
Entries . Add ( entry ) ;
using IGBaseFile file = _f ileHandler . CreateEntryFile ( entry , this ) ;
IDataHandler dataHandler = await _d ataHandlerPool . RequestDataHandler ( this , false , cancellationToken ) ;
await dataHandler . AddEntry ( entry , this , file . File , cancellationToken ) ;
using IPoolItem < IDataHandler > dataHandlerItem = await _d ataHandlerPool . RequestDataHandler ( this , false , cancellationToken ) ;
await dataHandlerItem . Use ( ) . AddEntry ( entry , this , file . File , cancellationToken ) ;
return true ;
}
public T GetEntryForKey ( int key ) = > Entries . FirstOrDefault ( e = > e . Key = = key ) ;
/// <summary>
/// Remove an entry that implements <see cref="INotifyGBaseEntryChanged"/> from this <see cref="IGBaseTable"/>
/// Remove an entry that implements <see cref="IGBaseObject "/> from this <see cref="IGBaseTable"/>
/// </summary>
/// <param name="entry">The entry implementing <see cref="INotifyGBaseEntryChanged "/></param>
/// <param name="entry">The entry implementing <see cref="IGBaseObject "/></param>
/// <returns>True if successful, false if not</returns>
public async Task < bool > RemoveEntry ( T entry )
{
@ -185,22 +216,22 @@ namespace GBase
public async Task SetValue < TProperty > ( T entry , string propertyName , TProperty value , CancellationToken cancellationToken )
{
using IGBaseFile file = await _f ileHandler . RequestEntryFile ( entry ) ;
IDataHandler dataHandler = await _d ataHandlerPool . RequestDataHandler ( this , false , cancellationToken ) ;
await dataHandler . SetValue < T , TProperty > ( file . File , propertyName , value , cancellationToken ) ;
using IPoolItem < IDataHandler > dataHandlerItem = await _d ataHandlerPool . RequestDataHandler ( this , false , cancellationToken ) ;
await dataHandlerItem . Use ( ) . SetValue < T , TProperty > ( file . File , propertyName , value , cancellationToken ) ;
}
public async Task < TProperty > GetValue < TProperty > ( T entry , string propertyName , CancellationToken cancellationToken )
{
using IGBaseFile file = await _f ileHandler . RequestEntryFile ( entry ) ;
IDataHandler dataHandler = await _d ataHandlerPool . RequestDataHandler ( this , false , cancellationToken ) ;
return await dataHandler . GetValue < T , TProperty > ( file . File , propertyName , cancellationToken ) ;
using IPoolItem < IDataHandler > dataHandlerItem = await _d ataHandlerPool . RequestDataHandler ( this , false , cancellationToken ) ;
return await dataHandlerItem . Use ( ) . GetValue < T , TProperty > ( file . File , propertyName , cancellationToken ) ;
}
public async Task < IEnumerable < TProperty > > GetValues < TProperty > ( T entry , string propertyName , CancellationToken cancellationToken )
{
using IGBaseFile file = await _f ileHandler . RequestEntryFile ( entry ) ;
IDataHandler dataHandler = await _d ataHandlerPool . RequestDataHandler ( this , false , cancellationToken ) ;
return await dataHandler . GetValues < T , TProperty > ( file . File , propertyName , cancellationToken ) ;
using IPoolItem < IDataHandler > dataHandlerItem = await _d ataHandlerPool . RequestDataHandler ( this , false , cancellationToken ) ;
return await dataHandlerItem . Use ( ) . GetValues < T , TProperty > ( file . File , propertyName , cancellationToken ) ;
}
/// <summary>
