=========
Based on Net Frame 8.Now including basic ORM frame support (including EF Core and Data Annotation Support).This may be most simplify code to intergrate ORM ability， Support Logic Delete Attribute and dao datasource Aspect defined Stream Reader/Writer for Excel and word. Customer Ioc Support to support AutoWire Service and support recursive AutoWired. United FileSystem and Data File Reader and Write,Support CSV/XML/JSON/AVRO/PARQUET/ORC File Format Add Serverless Function for dynamic load and unload DLL at runtime Customer MVC Frame to easy develop WebApi Bigdate Support for Nosql ElasticSearch/Cassandra/MongoDb/Hbase
- Core SubModule
- Customer Annotation MappingEntity MappingField
- Global DAOFactory Manager Datasource;
- Single JdbcDao per DataSource;
- Service Layer BaseRepository，with basic CRUD operator,can enhace or override;
- Mybatis xml query ability,with js script enabled;
- Intergarte with propluar Database system;
- Support EF core Annotation
- DataSource Configration
dataSource:
core:
host: localhost
port: 3316
dbType: Mysql
userName: root
password: root
maxSize: 10- DAO/Repository initialize Each Dao present as ADO Provider for one datasource
DAOFactory f = DAOFactory.init("f:/1.yaml");
//Construct Repository
BaseRepository<TestModel,long> repository = new Builder<TestModel,long>().build();- Customer IDbContext Thread safe DbContext,SaveChanges operation separate with ManagedThreadId,can switch dataSource with dsName at runtime.
IDbContext context = new DbContext();
DbContextFactory.Register(context);- Customer Ioc Support
RegServiceContext.ScanServices(typeof(ServiceAttribute));Auto register Class with Attribute ServiceAttribute and recusive AutoWrie service with Attribute ResourceAttribute
- CRUD Operator
DAOFactory f = DAOFactory.init("f:/1.yaml");
BaseRepository<TestModel,long> repository = new Builder<TestModel,long>().build();
TestModel model = new TestModel();
...
//New Entity
repository.SaveEntity(model);
//
TestModel model=repository.GetById(1);
//return models with single column Query
IList<TestModel> list=repository.QueryModelsByField("name", Constants.SqlOperator.LIKE, new object[] { "t" });
//Update
repository.UpdateEntity(model);
//Delete
repository.RemoveEntity(new long[] { 1 }.ToArray());- Batch Insert
DAOFactory f = DAOFactory.init("f:/1.yaml");
BaseRepository<TestModel,long> repository = new Builder<TestModel,long>().build();
IList<TestSimple> list = new List<TestSimple>();
for (int i = 0; i < 1000; i++)
{
TestSimple simple = new TestSimple();
simple.name = "col" + Convert.ToString(i);
simple.tValue = i;
simple.dTime = DateTime.Now;
list.Add(simple);
}
return repository.InsertBatch(list);- Mybatis like Query
DAOFactory f = DAOFactory.init("f:/1.yaml");
BaseRepository<TestModel,long> repository = new Builder<TestModel,long>().build();
PageQuery query = new PageQuery(4);
query.Parameters.Add("Name", "t%");
query.NameSpace = "Frameset.Test";
query.QueryId = "select1";
PageDTO<TestVO> list = repository.QueryPage<TestVO>(query);
TestVO vo = new TestVO();
vo.Name = "test";
vo.Description = "test";
vo.CsId = 50;
repository.ExecuteMapper("Frameset.Test", "insert1", vo);- Mybatis config xml (compatiable with Mybatis，support js script)
<?xml version="1.0" encoding="UTF-8"?>
<mapper namespace="Frameset.Test">
<resultMap id="rsMap1" type="Frametest.Dao.TestVO">
<id property="Id" column="id" />
<result property="Name" column="name" />
<result property="CsId" column="cs_id" />
<result property="CreateTime" column="create_time" />
<result property="Description" column="code_desc" />
</resultMap>
<sql id="sqlpart1">
id,name,code_desc,cs_id,create_time
</sql>
...
</mapper>-
Common SubModule
-
Read/Write File format(CSV/XML/JSON/AVRO/PARQUET) using FileSystem(Local/FTP/SFTP/WebHDFS/AmazonS3) Read From FileSystem
DataCollectionBuilder builder = DataCollectionBuilder.NewBuilder();
//using FileSystem Local
builder.Path("e:/1.parquet").FsType(Constants.FileSystemType.LOCAL);
using (AbstractDataIterator<Dictionary<string, object>> iterator = DataFileImporter.GetDataReader<Dictionary<string,object>>(builder.Build()))
{
while (iterator.MoveNext())
{
Dictionary<string, object> valueMap = iterator.Current;
Log.Information("{valueMap}", valueMap);
}
}Write to target FileSystem
DataCollectionBuilder builder = DataCollectionBuilder.NewBuilder();
//assign Path and column metadata define
builder.Path("e:/1.parquet").AddColumnDefine("id", Constants.MetaType.BIGINT).AddColumnDefine("name", Constants.MetaType.STRING)
.AddColumnDefine("time", Constants.MetaType.TIMESTAMP).AddColumnDefine("amount", Constants.MetaType.INTEGER).AddColumnDefine("price", Constants.MetaType.DOUBLE);
Dictionary<string, object> cachedMap = new Dictionary<string, object>();
Random random = new Random(1231313);
long startTs = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() - 3600 * 24 * 1000;
DateTime dateTime = new DateTime(1970, 1, 1, 0, 0, 0, 0);
using (AbstractDataWriter<Dictionary<string, object>> writer = DataFileExporter.GetDataWriter<Dictionary<string, object>>(builder.Build()))
{
for (int i = 0; i < 1000; i++)
{
cachedMap.Clear();
cachedMap.TryAdd("name", StringUtils.GenerateRandomChar(random, 12));
cachedMap.TryAdd("time", dateTime.AddMilliseconds(startTs + i * 1000));
cachedMap.TryAdd("amount", random.Next(1000) + 1);
cachedMap.TryAdd("price", random.NextDouble() * 1000);
cachedMap.TryAdd("id", Convert.ToInt64(i));
writer.WriteRecord(cachedMap);
}
}- Serverless Dynamic Dll support
1.With webapi project add in appsetting.json,serverlessPrefix Parameter
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft.AspNetCore": "Warning"
}
},
"AllowedHosts": "*",
"serverlessPrefix": "/serverless",
}Add Class with Method with Attribute ServerlessFunc,and pack to DLL
public class TestService
{
[ServerlessFunc]
public static object GetRole(HttpRequest request, HttpResponse response, long id, IBaseRepository<SysRole, long> repository)
{then use DynamicFunctionLoader RegisterFunction to register at runtime you can call through /serverless/{functionName} to call DLL function dynamic