|
@@ -17,119 +17,150 @@ namespace Vitorm
|
|
public partial class DataSource
|
|
public partial class DataSource
|
|
{
|
|
{
|
|
|
|
|
|
|
|
+
|
|
|
|
+ #region DataProvider
|
|
|
|
+
|
|
|
|
+ readonly ConcurrentDictionary<Type, IDataProvider> entityProviderMap = new();
|
|
|
|
+
|
|
|
|
+ readonly List<DataProviderCache> providerList = new();
|
|
|
|
+ DataProviderCache CreateDataProvider(Dictionary<string, object> dataProviderConfig)
|
|
|
|
+ {
|
|
|
|
+ /*
|
|
|
|
+ "provider": "Vitorm.Sqlite.DataProvider",
|
|
|
|
+ "assemblyName": "Vitorm.Sqlite",
|
|
|
|
+ "assemblyFile": "Vitorm.Sqlite.dll",
|
|
|
|
+ */
|
|
|
|
+
|
|
|
|
+ object temp;
|
|
|
|
+ string provider = dataProviderConfig.TryGetValue("provider", out temp) ? temp as string : null;
|
|
|
|
+ string assemblyName = dataProviderConfig.TryGetValue("assemblyName", out temp) ? temp as string : null;
|
|
|
|
+ string assemblyFile = dataProviderConfig.TryGetValue("assemblyFile", out temp) ? temp as string : null;
|
|
|
|
+
|
|
|
|
+ Type providerType;
|
|
|
|
+ IDataProvider dataProvider;
|
|
|
|
+
|
|
|
|
+ // #1 load
|
|
|
|
+ providerType = ObjectLoader.GetType(className: provider, assemblyName: assemblyName, assemblyFile: assemblyFile);
|
|
|
|
+ dataProvider = providerType?.GetConstructor(Type.EmptyTypes)?.Invoke(new object[] { }) as IDataProvider;
|
|
|
|
+
|
|
|
|
+ // #2 try load by database type (Sqlite/MySql/SqlServer)
|
|
|
|
+ if (dataProvider == null)
|
|
|
|
+ {
|
|
|
|
+ providerType = ObjectLoader.GetType(className: $"Vitorm.{provider}.DataProvider", assemblyName: $"Vitorm.{provider}", assemblyFile: $"Vitorm.{provider}.dll");
|
|
|
|
+ dataProvider = providerType?.GetConstructor(Type.EmptyTypes)?.Invoke(new object[] { }) as IDataProvider;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ if (dataProvider == null) return null;
|
|
|
|
+
|
|
|
|
+ dataProvider.Init(dataProviderConfig);
|
|
|
|
+ return new DataProviderCache(dataProvider, dataProviderConfig);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ #endregion
|
|
|
|
+
|
|
|
|
+ #region AddDataProvider
|
|
|
|
+
|
|
|
|
+
|
|
/// <summary>
|
|
/// <summary>
|
|
/// Data.Init("appsettings.Development.json")
|
|
/// Data.Init("appsettings.Development.json")
|
|
/// </summary>
|
|
/// </summary>
|
|
/// <param name="appsettingsFileName"></param>
|
|
/// <param name="appsettingsFileName"></param>
|
|
- public DataSource AddDataProviders(string appsettingsFileName)
|
|
|
|
|
|
+ public virtual DataSource AddDataProviders(string appsettingsFileName)
|
|
{
|
|
{
|
|
AddDataProviders(new JsonFile(appsettingsFileName));
|
|
AddDataProviders(new JsonFile(appsettingsFileName));
|
|
return this;
|
|
return this;
|
|
}
|
|
}
|
|
|
|
|
|
- public DataSource AddDataProviders(JsonFile json, string configPath = "Vitorm.Data")
|
|
|
|
|
|
+ public virtual int AddDataProviders(JsonFile json, string configPath = "Vitorm.Data")
|
|
{
|
|
{
|
|
var dataProviderConfigs = json.GetByPath<List<Dictionary<string, object>>>(configPath);
|
|
var dataProviderConfigs = json.GetByPath<List<Dictionary<string, object>>>(configPath);
|
|
- return LoadDataProviders(dataProviderConfigs);
|
|
|
|
|
|
+ return AddDataProviders(dataProviderConfigs);
|
|
}
|
|
}
|
|
- public DataSource LoadDataProviders(IEnumerable<Dictionary<string, object>> dataProviderConfigs)
|
|
|
|
|
|
+
|
|
|
|
+ public virtual int AddDataProviders(IEnumerable<Dictionary<string, object>> dataProviderConfigs)
|
|
{
|
|
{
|
|
var dataProviders = dataProviderConfigs?.Select(CreateDataProvider).NotNull().ToList();
|
|
var dataProviders = dataProviderConfigs?.Select(CreateDataProvider).NotNull().ToList();
|
|
|
|
|
|
- if (dataProviders?.Any() == true) providerCache.AddRange(dataProviders);
|
|
|
|
|
|
+ if (dataProviders?.Any() != true) return 0;
|
|
|
|
|
|
- providerMap.Clear();
|
|
|
|
|
|
+ providerList.AddRange(dataProviders);
|
|
|
|
|
|
- return this;
|
|
|
|
|
|
+ entityProviderMap.Clear();
|
|
|
|
+
|
|
|
|
+ return dataProviders.Count;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /// <summary>
|
|
|
|
+ /// insert to header of DataProvider list
|
|
|
|
+ /// </summary>
|
|
|
|
+ /// <param name="dataProviderConfig"></param>
|
|
|
|
+ /// <returns></returns>
|
|
|
|
+ public virtual bool InsertDataProvider(Dictionary<string, object> dataProviderConfig)
|
|
|
|
+ {
|
|
|
|
+ var provider = CreateDataProvider(dataProviderConfig);
|
|
|
|
+ if (provider == null) return false;
|
|
|
|
+
|
|
|
|
+ providerList.Insert(0, provider);
|
|
|
|
+ entityProviderMap.Clear();
|
|
|
|
+ return true;
|
|
}
|
|
}
|
|
|
|
|
|
- public bool AddDataProvider(Dictionary<string, object> dataProviderConfig)
|
|
|
|
|
|
+ /// <summary>
|
|
|
|
+ /// insert to tail of DataProvider list
|
|
|
|
+ /// </summary>
|
|
|
|
+ /// <param name="dataProviderConfig"></param>
|
|
|
|
+ /// <returns></returns>
|
|
|
|
+ public virtual bool AddDataProvider(Dictionary<string, object> dataProviderConfig)
|
|
{
|
|
{
|
|
var provider = CreateDataProvider(dataProviderConfig);
|
|
var provider = CreateDataProvider(dataProviderConfig);
|
|
if (provider == null) return false;
|
|
if (provider == null) return false;
|
|
|
|
|
|
- providerCache.Insert(0, provider);
|
|
|
|
- providerMap.Clear();
|
|
|
|
|
|
+ providerList.Add(provider);
|
|
|
|
+ entityProviderMap.Clear();
|
|
return true;
|
|
return true;
|
|
}
|
|
}
|
|
- public void ClearDataProviders(Predicate<DataProviderCache> predicate = null)
|
|
|
|
|
|
+
|
|
|
|
+ public virtual void ClearDataProviders(Predicate<DataProviderCache> predicate = null)
|
|
{
|
|
{
|
|
if (predicate != null)
|
|
if (predicate != null)
|
|
- providerCache.RemoveAll(predicate);
|
|
|
|
|
|
+ providerList.RemoveAll(predicate);
|
|
else
|
|
else
|
|
- providerCache.Clear();
|
|
|
|
|
|
+ providerList.Clear();
|
|
|
|
|
|
- providerMap.Clear();
|
|
|
|
|
|
+ entityProviderMap.Clear();
|
|
}
|
|
}
|
|
|
|
+ #endregion
|
|
|
|
|
|
|
|
|
|
- #region DataProvider
|
|
|
|
|
|
+ #region GetDataProvider
|
|
|
|
|
|
- public IDataProvider DataProvider<Entity>() => DataProvider(typeof(Entity));
|
|
|
|
- public IDataProvider DataProvider(Type entityType)
|
|
|
|
|
|
+ public virtual IDataProvider DataProvider<Entity>() => DataProvider(typeof(Entity));
|
|
|
|
+ public virtual IDataProvider DataProvider(Type entityType)
|
|
{
|
|
{
|
|
- return providerMap.GetOrAdd(entityType, GetDataProviderFromConfig);
|
|
|
|
-
|
|
|
|
- IDataProvider GetDataProviderFromConfig(Type entityType)
|
|
|
|
- {
|
|
|
|
- var classFullName = entityType.FullName;
|
|
|
|
- return providerCache.FirstOrDefault(cache => cache.Match(classFullName))?.dataProvider
|
|
|
|
- ?? throw new NotImplementedException("can not find config for type: " + classFullName);
|
|
|
|
- }
|
|
|
|
|
|
+ return entityProviderMap.GetOrAdd(entityType, GetDataProviderFromConfig);
|
|
|
|
+ }
|
|
|
|
+ private IDataProvider GetDataProviderFromConfig(Type entityType)
|
|
|
|
+ {
|
|
|
|
+ var classFullName = entityType.FullName;
|
|
|
|
+ return providerList.FirstOrDefault(cache => cache.Match(classFullName))?.dataProvider
|
|
|
|
+ ?? throw new NotImplementedException("can not find config for type: " + classFullName);
|
|
}
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// <summary>
|
|
- /// dataProviderName: dataProviderName or dataProviderNamespace
|
|
|
|
|
|
+ /// nameOrNamespace: dataProviderName or dataProviderNamespace
|
|
/// </summary>
|
|
/// </summary>
|
|
- /// <param name="dataProviderName"></param>
|
|
|
|
|
|
+ /// <param name="nameOrNamespace"></param>
|
|
/// <returns></returns>
|
|
/// <returns></returns>
|
|
- public IDataProvider DataProvider(string dataProviderName)
|
|
|
|
|
|
+ public virtual IDataProvider DataProvider(string nameOrNamespace)
|
|
{
|
|
{
|
|
- return providerCache.FirstOrDefault(cache => cache.name == dataProviderName || cache.@namespace == dataProviderName)?.dataProvider;
|
|
|
|
|
|
+ return providerList.FirstOrDefault(cache => cache.name == nameOrNamespace || cache.@namespace == nameOrNamespace || cache.Match(nameOrNamespace))?.dataProvider;
|
|
}
|
|
}
|
|
|
|
|
|
-
|
|
|
|
- readonly ConcurrentDictionary<Type, IDataProvider> providerMap = new();
|
|
|
|
-
|
|
|
|
- readonly List<DataProviderCache> providerCache = new();
|
|
|
|
-
|
|
|
|
-
|
|
|
|
- DataProviderCache CreateDataProvider(Dictionary<string, object> dataProviderConfig)
|
|
|
|
- {
|
|
|
|
- /*
|
|
|
|
- "provider": "Vitorm.Sqlite.DataProvider",
|
|
|
|
- "assemblyName": "Vitorm.Sqlite",
|
|
|
|
- "assemblyFile": "Vitorm.Sqlite.dll",
|
|
|
|
- */
|
|
|
|
-
|
|
|
|
- object temp;
|
|
|
|
- string provider = dataProviderConfig.TryGetValue("provider", out temp) ? temp as string : null;
|
|
|
|
- string assemblyName = dataProviderConfig.TryGetValue("assemblyName", out temp) ? temp as string : null;
|
|
|
|
- string assemblyFile = dataProviderConfig.TryGetValue("assemblyFile", out temp) ? temp as string : null;
|
|
|
|
-
|
|
|
|
- Type providerType;
|
|
|
|
- IDataProvider dataProvider;
|
|
|
|
-
|
|
|
|
- // #1 load
|
|
|
|
- providerType = ObjectLoader.GetType(className: provider, assemblyName: assemblyName, assemblyFile: assemblyFile);
|
|
|
|
- dataProvider = providerType?.GetConstructor(Type.EmptyTypes)?.Invoke(new object[] { }) as IDataProvider;
|
|
|
|
-
|
|
|
|
- // #2 try load by database type (Sqlite/MySql/SqlServer)
|
|
|
|
- if (dataProvider == null)
|
|
|
|
- {
|
|
|
|
- providerType = ObjectLoader.GetType(className: $"Vitorm.{provider}.DataProvider", assemblyName: $"Vitorm.{provider}", assemblyFile: $"Vitorm.{provider}.dll");
|
|
|
|
- dataProvider = providerType?.GetConstructor(Type.EmptyTypes)?.Invoke(new object[] { }) as IDataProvider;
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
-
|
|
|
|
- if (dataProvider == null) return null;
|
|
|
|
-
|
|
|
|
- dataProvider.Init(dataProviderConfig);
|
|
|
|
- return new DataProviderCache(dataProvider, dataProviderConfig);
|
|
|
|
- }
|
|
|
|
|
|
+ #endregion
|
|
|
|
|
|
|
|
|
|
- #endregion
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@@ -137,31 +168,31 @@ namespace Vitorm
|
|
#region CRUD Sync
|
|
#region CRUD Sync
|
|
|
|
|
|
// #0 Schema : TryCreateTable TryDropTable
|
|
// #0 Schema : TryCreateTable TryDropTable
|
|
- public void TryCreateTable<Entity>() => DataProvider<Entity>().TryCreateTable<Entity>();
|
|
|
|
- public void TryDropTable<Entity>() => DataProvider<Entity>().TryDropTable<Entity>();
|
|
|
|
- public void Truncate<Entity>() => DataProvider<Entity>().Truncate<Entity>();
|
|
|
|
|
|
+ public virtual void TryCreateTable<Entity>() => DataProvider<Entity>().TryCreateTable<Entity>();
|
|
|
|
+ public virtual void TryDropTable<Entity>() => DataProvider<Entity>().TryDropTable<Entity>();
|
|
|
|
+ public virtual void Truncate<Entity>() => DataProvider<Entity>().Truncate<Entity>();
|
|
|
|
|
|
|
|
|
|
// #1 Create : Add AddRange
|
|
// #1 Create : Add AddRange
|
|
- public Entity Add<Entity>(Entity entity) => DataProvider<Entity>().Add<Entity>(entity);
|
|
|
|
- public void AddRange<Entity>(IEnumerable<Entity> entities) => DataProvider<Entity>().AddRange<Entity>(entities);
|
|
|
|
|
|
+ public virtual Entity Add<Entity>(Entity entity) => DataProvider<Entity>().Add<Entity>(entity);
|
|
|
|
+ public virtual void AddRange<Entity>(IEnumerable<Entity> entities) => DataProvider<Entity>().AddRange<Entity>(entities);
|
|
|
|
|
|
// #2 Retrieve : Get Query
|
|
// #2 Retrieve : Get Query
|
|
- public Entity Get<Entity>(object keyValue) => DataProvider<Entity>().Get<Entity>(keyValue);
|
|
|
|
- public IQueryable<Entity> Query<Entity>() => DataProvider<Entity>().Query<Entity>();
|
|
|
|
|
|
+ public virtual Entity Get<Entity>(object keyValue) => DataProvider<Entity>().Get<Entity>(keyValue);
|
|
|
|
+ public virtual IQueryable<Entity> Query<Entity>() => DataProvider<Entity>().Query<Entity>();
|
|
|
|
|
|
|
|
|
|
// #3 Update: Update UpdateRange
|
|
// #3 Update: Update UpdateRange
|
|
- public int Update<Entity>(Entity entity) => DataProvider<Entity>().Update<Entity>(entity);
|
|
|
|
- public int UpdateRange<Entity>(IEnumerable<Entity> entities) => DataProvider<Entity>().UpdateRange<Entity>(entities);
|
|
|
|
|
|
+ public virtual int Update<Entity>(Entity entity) => DataProvider<Entity>().Update<Entity>(entity);
|
|
|
|
+ public virtual int UpdateRange<Entity>(IEnumerable<Entity> entities) => DataProvider<Entity>().UpdateRange<Entity>(entities);
|
|
|
|
|
|
|
|
|
|
// #4 Delete : Delete DeleteRange DeleteByKey DeleteByKeys
|
|
// #4 Delete : Delete DeleteRange DeleteByKey DeleteByKeys
|
|
- public int Delete<Entity>(Entity entity) => DataProvider<Entity>().Delete<Entity>(entity);
|
|
|
|
- public int DeleteRange<Entity>(IEnumerable<Entity> entities) => DataProvider<Entity>().DeleteRange<Entity>(entities);
|
|
|
|
|
|
+ public virtual int Delete<Entity>(Entity entity) => DataProvider<Entity>().Delete<Entity>(entity);
|
|
|
|
+ public virtual int DeleteRange<Entity>(IEnumerable<Entity> entities) => DataProvider<Entity>().DeleteRange<Entity>(entities);
|
|
|
|
|
|
- public int DeleteByKey<Entity>(object keyValue) => DataProvider<Entity>().DeleteByKey<Entity>(keyValue);
|
|
|
|
- public int DeleteByKeys<Entity, Key>(IEnumerable<Key> keys) => DataProvider<Entity>().DeleteByKeys<Entity, Key>(keys);
|
|
|
|
|
|
+ public virtual int DeleteByKey<Entity>(object keyValue) => DataProvider<Entity>().DeleteByKey<Entity>(keyValue);
|
|
|
|
+ public virtual int DeleteByKeys<Entity, Key>(IEnumerable<Key> keys) => DataProvider<Entity>().DeleteByKeys<Entity, Key>(keys);
|
|
|
|
|
|
#endregion
|
|
#endregion
|
|
|
|
|
|
@@ -170,30 +201,30 @@ namespace Vitorm
|
|
#region CRUD Async
|
|
#region CRUD Async
|
|
|
|
|
|
// #0 Schema : TryCreateTable TryDropTable
|
|
// #0 Schema : TryCreateTable TryDropTable
|
|
- public Task TryCreateTableAsync<Entity>() => DataProvider<Entity>().TryCreateTableAsync<Entity>();
|
|
|
|
- public Task TryDropTableAsync<Entity>() => DataProvider<Entity>().TryDropTableAsync<Entity>();
|
|
|
|
- public Task TruncateAsync<Entity>() => DataProvider<Entity>().TruncateAsync<Entity>();
|
|
|
|
|
|
+ public virtual Task TryCreateTableAsync<Entity>() => DataProvider<Entity>().TryCreateTableAsync<Entity>();
|
|
|
|
+ public virtual Task TryDropTableAsync<Entity>() => DataProvider<Entity>().TryDropTableAsync<Entity>();
|
|
|
|
+ public virtual Task TruncateAsync<Entity>() => DataProvider<Entity>().TruncateAsync<Entity>();
|
|
|
|
|
|
|
|
|
|
// #1 Create : Add AddRange
|
|
// #1 Create : Add AddRange
|
|
- public Task<Entity> AddAsync<Entity>(Entity entity) => DataProvider<Entity>().AddAsync<Entity>(entity);
|
|
|
|
- public Task AddRangeAsync<Entity>(IEnumerable<Entity> entities) => DataProvider<Entity>().AddRangeAsync<Entity>(entities);
|
|
|
|
|
|
+ public virtual Task<Entity> AddAsync<Entity>(Entity entity) => DataProvider<Entity>().AddAsync<Entity>(entity);
|
|
|
|
+ public virtual Task AddRangeAsync<Entity>(IEnumerable<Entity> entities) => DataProvider<Entity>().AddRangeAsync<Entity>(entities);
|
|
|
|
|
|
// #2 Retrieve : Get Query
|
|
// #2 Retrieve : Get Query
|
|
- public Task<Entity> GetAsync<Entity>(object keyValue) => DataProvider<Entity>().GetAsync<Entity>(keyValue);
|
|
|
|
|
|
+ public virtual Task<Entity> GetAsync<Entity>(object keyValue) => DataProvider<Entity>().GetAsync<Entity>(keyValue);
|
|
|
|
|
|
|
|
|
|
// #3 Update: Update UpdateRange
|
|
// #3 Update: Update UpdateRange
|
|
- public Task<int> UpdateAsync<Entity>(Entity entity) => DataProvider<Entity>().UpdateAsync<Entity>(entity);
|
|
|
|
- public Task<int> UpdateRangeAsync<Entity>(IEnumerable<Entity> entities) => DataProvider<Entity>().UpdateRangeAsync<Entity>(entities);
|
|
|
|
|
|
+ public virtual Task<int> UpdateAsync<Entity>(Entity entity) => DataProvider<Entity>().UpdateAsync<Entity>(entity);
|
|
|
|
+ public virtual Task<int> UpdateRangeAsync<Entity>(IEnumerable<Entity> entities) => DataProvider<Entity>().UpdateRangeAsync<Entity>(entities);
|
|
|
|
|
|
|
|
|
|
// #4 Delete : Delete DeleteRange DeleteByKey DeleteByKeys
|
|
// #4 Delete : Delete DeleteRange DeleteByKey DeleteByKeys
|
|
- public Task<int> DeleteAsync<Entity>(Entity entity) => DataProvider<Entity>().DeleteAsync<Entity>(entity);
|
|
|
|
- public Task<int> DeleteRangeAsync<Entity>(IEnumerable<Entity> entities) => DataProvider<Entity>().DeleteRangeAsync<Entity>(entities);
|
|
|
|
|
|
+ public virtual Task<int> DeleteAsync<Entity>(Entity entity) => DataProvider<Entity>().DeleteAsync<Entity>(entity);
|
|
|
|
+ public virtual Task<int> DeleteRangeAsync<Entity>(IEnumerable<Entity> entities) => DataProvider<Entity>().DeleteRangeAsync<Entity>(entities);
|
|
|
|
|
|
- public Task<int> DeleteByKeyAsync<Entity>(object keyValue) => DataProvider<Entity>().DeleteByKeyAsync<Entity>(keyValue);
|
|
|
|
- public Task<int> DeleteByKeysAsync<Entity, Key>(IEnumerable<Key> keys) => DataProvider<Entity>().DeleteByKeysAsync<Entity, Key>(keys);
|
|
|
|
|
|
+ public virtual Task<int> DeleteByKeyAsync<Entity>(object keyValue) => DataProvider<Entity>().DeleteByKeyAsync<Entity>(keyValue);
|
|
|
|
+ public virtual Task<int> DeleteByKeysAsync<Entity, Key>(IEnumerable<Key> keys) => DataProvider<Entity>().DeleteByKeysAsync<Entity, Key>(keys);
|
|
|
|
|
|
#endregion
|
|
#endregion
|
|
|
|
|