FluentData，它是一个轻量级框架，关注性能和易用性。

http://www.cnblogs.com/zengxiangzhan/p/3250105.html

FluentData，它是一个轻量级框架，关注性能和易用性。

利用T4模板，【MultipleOutputHelper.ttinclude】批量生成多文件

基本语法：

1. 初始化：获取MultipleOutputHelper.ttinclude文件模板在T4模板导入

  //导入MultipleOutputHelper.ttinclude文件 路径

      <#@include file="$(SolutionDir)\ORM.Model\T4\MultipleOutputHelper.ttinclude"#>

  //初始化Manager对象

      var manager = Manager.Create(Host, GenerationEnvironment);

2.文件块：使用代码标识区分生成的代码块的范围
          manager.StartNewFile(tb_name+".cs");
         //代码块
         manager.EndBlock();

3.编译执行：使用Process方法，进行文件分割

 manager.Process(true);

实践：

FluentData，它是一个轻量级框架，关注性能和易用性。

1.批量生成实体类

<#@ template debug="false" hostspecific="true" language="C#" #>

<#@ assembly name="System.Data" #>

<#@ assembly name="System.xml" #>

<#@ import namespace="System.Collections.Generic" #>

<#@ import namespace="System.Data.SqlClient" #>

<#@ import namespace="System.Data" #>

<#@ assembly name="System.Core" #>

<#@ import namespace="System.Linq" #>

//  导入MultipleOutputHelper.ttinclude文件

<#@include file="$(SolutionDir)\My.Model\T4\MultipleOutputHelper.ttinclude"#> 

<#

        string connectionString= "server=qq;database=db;uid=sa;pwd=sa;";

        SqlConnection conn = new SqlConnection(connectionString);

        conn.Open();

        string selectQuery ="SET FMTONLY ON; select * from @tableName; SET FMTONLY OFF;";

        SqlCommand command = new SqlCommand(selectQuery,conn);

        SqlDataAdapter ad = new SqlDataAdapter(command);

        System.Data.DataSet ds = new DataSet(); 

        var manager = Manager.Create(Host, GenerationEnvironment);  

        System.Data.DataTable schema = conn.GetSchema("Tables");

        foreach(System.Data.DataRow row in schema.Rows)

        {

            ds.Tables.Clear();

            string tb_name= row["TABLE_NAME"].ToString();

            command.CommandText = selectQuery.Replace("@tableName",row["TABLE_NAME"].ToString());

            ad.FillSchema(ds, SchemaType.Mapped,tb_name);

            manager.StartNewFile(tb_name+".cs");#>

using FluentData;

using System;

using System.Collections.Generic;

namespace My.Model

{

    /// <summary>

    /// 实体-<#=tb_name#>

    /// </summary>

    public partial class <#=tb_name#>

    {

        <#

        PushIndent("          ");

        foreach (DataColumn dc in ds.Tables[0].Columns)

        {

            WriteLine("public " + dc.DataType.Name+ (dc.AllowDBNull && dc.DataType.Name.ToLower() != "string" ? "? ": " ") + dc.ColumnName + " { get; set; }");

        }

        PopIndent();

        #>

    }

}

<#

        manager.EndBlock();

         }

        conn.Close();

       manager.Process(true);

        #>

2.批量生成基础业务逻辑

<#@ template debug="false" hostspecific="true" language="C#" #>

<#@ assembly name="System.Data" #>

<#@ assembly name="System.xml" #>

<#@ import namespace="System.Collections.Generic" #>

<#@ import namespace="System.Data.SqlClient" #>

<#@ import namespace="System.Data" #>

<#@ assembly name="System.Core" #>

<#@ import namespace="System.Linq" #>

//  导入MultipleOutputHelper.ttinclude文件

<#@include file="$(SolutionDir)\MY.Model\T4\MultipleOutputHelper.ttinclude"#> 

<#

        string connectionString= "server=QQ;database=DB;uid=sa;pwd=sa;";

        SqlConnection conn = new SqlConnection(connectionString);

        conn.Open();

        string selectQuery ="SET FMTONLY ON; select * from @tableName; SET FMTONLY OFF;";

        SqlCommand command = new SqlCommand(selectQuery,conn);

        SqlDataAdapter ad = new SqlDataAdapter(command);

        System.Data.DataSet ds = new DataSet(); 

        var manager = Manager.Create(Host, GenerationEnvironment);  

        System.Data.DataTable schema = conn.GetSchema("Tables");

        foreach(System.Data.DataRow row in schema.Rows)

        {

            ds.Tables.Clear();

            string tb_name= row["TABLE_NAME"].ToString();

            command.CommandText = selectQuery.Replace("@tableName",row["TABLE_NAME"].ToString());

            ad.FillSchema(ds, SchemaType.Mapped,tb_name);

            manager.StartNewFile(tb_name+"Action.cs");#>

using System;

using System.Collections.Generic;

using MY.Model;

using FluentData;

namespace MY.BLL

{    

    /// <summary>

    /// <#=tb_name#> 操作类

    /// </summary>

    public partial class <#=tb_name#>Action

    {<#

        string fkQuery = " SELECT f.name AS ForeignKey,";

        fkQuery += " OBJECT_NAME(f.parent_object_id) AS TableName, ";

        fkQuery += " COL_NAME(fc.parent_object_id, fc.parent_column_id) AS ColumnName, ";

        fkQuery += " OBJECT_NAME (f.referenced_object_id) AS ReferenceTableName, ";

        fkQuery += " COL_NAME(fc.referenced_object_id, fc.referenced_column_id) AS ReferenceColumnName ";

        fkQuery += " FROM ";

        fkQuery += " sys.foreign_keys AS f ";

        fkQuery += " INNER JOIN sys.foreign_key_columns AS fc ON f.OBJECT_ID = fc.constraint_object_id ";

        fkQuery += " where OBJECT_NAME(f.parent_object_id) = '" +tb_name +"'";

        List<string> fkColumnNames = new List<string>();

        Dictionary<string, string> parentTables = new Dictionary<string, string>();

        SqlCommand command2 = new SqlCommand(fkQuery,conn);

        using(var dr = command2.ExecuteReader())

        {

            while(dr.Read())

            {

                fkColumnNames.Add(dr["ColumnName"].ToString());

                parentTables.Add(dr["ColumnName"].ToString(), dr["ReferenceTableName"].ToString());

            }

            dr.Close();

        }

        List<DataColumn> fkColumns = new List<DataColumn>();

        foreach(string fkColumnName in fkColumnNames)

        {

            foreach (DataColumn dc in ds.Tables[0].Columns)

            {

                if(dc.ColumnName == fkColumnName)

                    fkColumns.Add(dc);

            }

        }

        List<string> primaryKeyParamsWithTypes = new List<string>();

        List<string> primaryKeyParams = new List<string>();

        List<string> whereItems = new List<string>();

        List<string> automapItems = new List<string>();

        foreach(DataColumn pk in ds.Tables[0].PrimaryKey)

        {

            primaryKeyParamsWithTypes.Add(string.Format("{0} {1}", pk.DataType.Name, this.ToCamelCase(pk.ColumnName)));

            primaryKeyParams.Add(pk.ColumnName);

            whereItems.Add(string.Format("{0} = @{1}", pk.ColumnName, pk.ColumnName.ToLower()));

            automapItems.Add(string.Format("x.{0}", pk.ColumnName));

        }

        string updateAutomap = string.Empty;

    if(automapItems.Count > 0){

        if(automapItems.Count > 1)

            updateAutomap = "new { " + string.Join(", ", automapItems.ToArray()) + " }";

        else

            updateAutomap = automapItems[0];

            }

        #>

        public static <#=tb_name#> Select(<#=string.Join(", ", primaryKeyParamsWithTypes.ToArray())#>)

        {

            using(var context = db.Context())

            {

                return context.Sql(" SELECT * FROM <#=tb_name#> WHERE <#=string.Join(" AND ", whereItems.ToArray())#> ")

                    <#foreach(string pkp in primaryKeyParams)

                    {

                        WriteLine(".Parameter(\"" + pkp.ToLower() + "\", " + this.ToCamelCase(pkp) + ")");

                    }

                    #>

                    .QuerySingle<<#=tb_name#>>();

            }

        }

        public static List<<#=tb_name#>> SelectAll()

        {

            return SelectAll(string.Empty);

        }

        public static List<<#=tb_name#>> SelectAll(string sortExpression)

        {

            return SelectAll(0, 0, sortExpression);

        }

        public static List<<#=tb_name#>> SelectAll(int startRowIndex, int maximumRows, string sortExpression)

        {

            using (var context = db.Context())

            {

                var select = context.Select<<#=tb_name#>>(" * ")

                    .From(" <#=tb_name#> ");

                if (maximumRows > 0)

                {

                    if (startRowIndex == 0)

                        startRowIndex = 1;

                    select.Paging(startRowIndex, maximumRows);

                }

                if (!string.IsNullOrEmpty(sortExpression))

                    select.OrderBy(sortExpression);

                return select.QueryMany();

            }

        }

        public static int CountAll()

        {

            using (var context = db.Context())

            {

                return context.Sql(" SELECT COUNT(*) FROM <#=tb_name#> ")

                    .QuerySingle<int>();

            }

        }

        <#

        foreach(DataColumn dc in fkColumns)

        {

        #>

        public static List<<#=tb_name#>> SelectBy<#=parentTables[dc.ColumnName]#>(<#=dc.DataType.Name#> <#=this.ToCamelCase(dc.ColumnName)#>)

        {

            return SelectBy<#=parentTables[dc.ColumnName]#>(<#=this.ToCamelCase(dc.ColumnName)#>, string.Empty);

        }

        public static List<<#=tb_name#>> SelectBy<#=parentTables[dc.ColumnName]#>(<#=dc.DataType.Name#> <#=this.ToCamelCase(dc.ColumnName)#>, string sortExpression)

        {

            return SelectBy<#=parentTables[dc.ColumnName]#>(<#=this.ToCamelCase(dc.ColumnName)#>, 0, 0, sortExpression);

        }

        public static List<<#=tb_name#>> SelectBy<#=parentTables[dc.ColumnName]#>(<#=dc.DataType.Name#> <#=this.ToCamelCase(dc.ColumnName)#>, int startRowIndex, int maximumRows, string sortExpression)

        {

            using (var context = db.Context())

            {

                var select = context.Select<<#=tb_name#>>(" * ")

                    .From(" <#=tb_name#> ")

                    .Where(" <#=dc.ColumnName#> = @<#=dc.ColumnName.ToLower()#> ")

                    .Parameter("<#=dc.ColumnName.ToLower()#>", <#=this.ToCamelCase(dc.ColumnName)#>);

                if (maximumRows > 0)

                {

                    if (startRowIndex == 0)

                        startRowIndex = 1;

                    select.Paging(startRowIndex, maximumRows);

                }

                if (!string.IsNullOrEmpty(sortExpression))

                    select.OrderBy(sortExpression);

                return select.QueryMany();

            }

        }

        public static int CountBy<#=parentTables[dc.ColumnName]#>(<#=dc.DataType.Name#> <#=this.ToCamelCase(dc.ColumnName)#>)

        {

            using (var context = db.Context())

            {

                return context.Sql(" SELECT COUNT(*) FROM <#=tb_name#> WHERE <#=dc.ColumnName#> = @<#=dc.ColumnName.ToLower()#>")

                    .Parameter("<#=dc.ColumnName.ToLower()#>", <#=this.ToCamelCase(dc.ColumnName)#>)

                    .QuerySingle<int>();

            }

        }

        <#}#>

<#if(ds.Tables[0].PrimaryKey != null && ds.Tables[0].PrimaryKey.Length == 1 && ds.Tables[0].PrimaryKey[0].AutoIncrement) {#>

        public static bool Insert(<#=tb_name#> <#=this.ToCamelCase(tb_name)#>)

        {

            using (var context = db.Context())

            {

                int id = context.Insert<<#=tb_name#>>("<#=tb_name#>", <#=this.ToCamelCase(tb_name)#>)

                    .AutoMap(x => x.<#=primaryKeyParams[0]#>)

                    .ExecuteReturnLastId<int>();

                <#=this.ToCamelCase(tb_name)#>.<#=primaryKeyParams[0]#> = id;

                return id > 0;

            }

        }

<#

}

else

{

#>

        public static bool Insert(<#=tb_name#> <#=this.ToCamelCase(tb_name)#>)

        {

            using (var context =db.Context())

            {

                return context.Insert<<#=tb_name#>>("<#=tb_name#>", <#=this.ToCamelCase(tb_name)#>)

                    .Execute() > 0;

            }

        }

<#}#>

        public static bool Update(<#=tb_name#> <#=this.ToCamelCase(tb_name)#>)

        {

            using (var context = db.Context())

            {

                return context.Update<<#=tb_name#>>("<#=tb_name#>", <#=this.ToCamelCase(tb_name)#>)

                    .AutoMap(x => <#=updateAutomap#>)

                    <#foreach(string pkp in primaryKeyParams){#>

                    .Where("<#=pkp#>", <#=this.ToCamelCase(tb_name)#>.<#=pkp#>)

                    <#}#>

                    .Execute() > 0;

            }

        }

        public static bool Delete(<#=tb_name#> <#=this.ToCamelCase(tb_name)#>)

        {

            return Delete(<#=string.Join(", ", primaryKeyParams.Select(x=> this.ToCamelCase(tb_name) + "." + x).ToArray())#>);

        }

        public static bool Delete(<#=string.Join(", ", primaryKeyParamsWithTypes.ToArray())#>)

        {

            using (var context = db.Context())

            {

                return context.Sql(" DELETE FROM Product WHERE <#=string.Join(" AND ", whereItems.ToArray())#> ")

                    <#foreach(string pkp in primaryKeyParams) {

                        WriteLine(".Parameter(\"" + pkp.ToLower() + "\", " + this.ToCamelCase(pkp) + ")");

                    }#>

                    .Execute() > 0;

            }

        }

    }

}

<#

        manager.EndBlock();

         }

        conn.Close();

       manager.Process(true);

        #> 

<#+

    public string ToCamelCase(string value)

    {

        if(string.IsNullOrEmpty(value))

            return string.Empty;

        string firstLetter = value.Substring(0, 1);

        string rest = value.Substring(1, value.Length - 1);

        return firstLetter.ToLower() + rest;

    }

#>

CTRL+S 自动生成

下载地址：FlunenData.Model

完成！即可快速开发了！

FluentData，它是一个轻量级框架，关注性能和易用性。的更多相关文章

如何评价一个RPC框架的性能
协议:数据传输的格式,通信双方的契约. 传输:使用何种传输通道传输数据. 线程:接收到数据,如何分发数据进行处理.
FluentData，一个轻量级开源的&period;NET ORM数据持久化框架
FluentData:一种使用Fluent API的新型轻量级ORM模型 FluentData 是微型 ORM(micro-ORM)家族的一名新成员,旨在比大型 ORM(full ORM)更加易用. ...
初步了解学习flask轻量级框架,
关于flask我有话说 flask作为一个轻量级框架,它里面有好多扩展包需要下载,比较麻烦,而且有的时候flask需要在虚拟环境下运行,但是他的优点还是有滴 ,只要是用过Django的人,都会觉得fl ...
一个轻量级分布式RPC框架--NettyRpc
1.背景最近在搜索Netty和Zookeeper方面的文章时,看到了这篇文章<轻量级分布式 RPC 框架>,作者用Zookeeper.Netty和Spring写了一个轻量级的分布式RPC ...
C++11实现一个轻量级的AOP框架
AOP介绍 AOP(Aspect-Oriented Programming,面向方面编程),可以解决面向对象编程中的一些问题,是OOP的一种有益补充.面向对象编程中的继承是一种从上而下的关系,不适合定 ...
一个轻量级分布式 RPC 框架 — NettyRpc
原文出处: 阿凡卢 1.背景最近在搜索Netty和Zookeeper方面的文章时,看到了这篇文章<轻量级分布式 RPC 框架>,作者用Zookeeper.Netty和Spring写了一个 ...
如何在Java生态圈选择一个轻量级的RESTful框架？
在微服务流行的今天,我们会从纵向和横向分解代码的逻辑,将一些独立的无状态的代码单元实现为微服务,可以将它们发布到一些分布式计算单元或者Docker中,并在性能需要的时候及时地创建更多的服务单元.微服务 ...
基于Netty和SpringBoot实现一个轻量级RPC框架-Server篇
前提前置文章: Github Page:<基于Netty和SpringBoot实现一个轻量级RPC框架-协议篇> Coding Page:<基于Netty和SpringBoot实现 ...
Objection, 一个轻量级的Objective-C依赖注入框架
简介项目主页:https://github.com/atomicobject/objection 实例下载: https://github.com/ios122/ios122 Objection 是 ...

随机推荐

工厂方法（Factory Method)，思考
最近看见一个关于如何通过工厂方法来重构代码的提问,发现这方面,自己还没有想得特别明白,所以,稍作总结. 只要有构造的地方,就有是用工厂方法的可能. 如果考虑到单元测试和实现的扩展,就有是用工厂方法的必 ...
各种AJAX方法的使用比较
转:http://www.cnblogs.com/fish-li/archive/2013/01/13/2858599.html#_label6 AJAX技术经过这么多年的发展,出现了一些框架或类库用 ...
netstat&lowbar;&lowbar;stat
1."man netstat" 查看命令"netstat"的参数和打印信息的含义 2."netstat -awp" --> ZC: ...
Spring MVC+JSP实现三级联动
jsp代码 <script type="text/javascript"> $(function() { initProvinces(); }); /** * 获取省列 ...
优秀代码要求（转自http&colon;//www&period;cnblogs&period;com/brishenzhou/p/6284188&period;html）
一段优秀的代码,它一般需要满足以下几个条件: #统一规范# 所有的代码,第一前提必须是统一规范,而常见的统一规范主要包括有以下内容: 1)统一编辑器规范在团队开发中,我们并不对各个开发人员使用的编辑 ...
vue&period;cli项目中src目录每个文件夹和文件的用法
assets文件夹是放静态资源:components是放组件:router是定义路由相关的配置:view视图:app.vue是一个应用主组件:main.js是入口文件:
Spring Boot 揭秘与实战（五）服务器篇 - Tomcat 启用 HTTPS
文章目录 1. 生成证书 2. 配置 HTTPS 支持 3. 启动与测试 4. 源代码 Spring Boot 内嵌的 Tomcat 服务器可以启用 HTTPS 支持. 生成证书使用第三方 CA 证 ...
(原)关于sdl在部分机器上做视频显示，改变显示窗口大小会崩溃
今天测试人员反应,之前做的视频绘图显示,会在她机器上,会出现崩溃现象,最后我在她机器上对代码进行跟踪,发现在某种情况,确实会崩溃. 最主要的原因是,视频显示窗口变成非活动窗口的时候,sdl内部会循环消 ...
Redis的介绍
REmote DIctionary Server(Redis) 是一个由Salvatore Sanfilippo写的key-value存储系统. Redis是一个开源的使用ANSI C语言编写.遵守B ...
使用base64&colon;url 来定义背景图片url
普通的背景图片css是这样的: background-image:url(http://www.zhangxinxu.com/wordpress/wp-content/themes/default/i ...