备案控制台
开发者社区 数据库 文章 正文

简单代码生成器原理剖析（二）

2016-10-31 781
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

上篇《简单代码生成器原理剖析（一）》分析了代码生成器的原理，查询数据库系统视图：INFORMATION_SCHEMA.TABLES、 INFORMATION_SCHEMA.COLUMNS  可以获得数据库中表、列的相关信息，再运用StringBuilder类的其AppendLine方法追加字符串，最后早运用File.WriteAllText方法将字符串写入文件。

第二版代码生成器在第一版的基础上扩展了以下功能：

  • 使用了部分类（partial）：当使用大项目或自动生成的代码（如由 Windows 窗体设计器提供的代码）时，将一个类、结构或接口类型拆分到多个文件中的做法就很有用。 分部类型可能包含分部方法。
  •  使用可空类型：由于数据库中表中数据很有可能是NULL，可空类型使得数据从表中读取出来赋值给值类型更加兼容。
  • 增加了ToModel方法：将数据库表中一行数据封装成Model类的对象返回。
 
Model的实现：
复制代码 
        /// <summary>
/// Model
/// </summary>
        public static void CreateModel(CodeBuilderArgs args,string tableName)

{

DataTable dt = ExecuteDataTable(args.ConnectionString, "select * from INFORMATION_SCHEMA.COLUMNS where TABLE_NAME=@TABLE_NAME"

,new SqlParameter("TABLE_NAME",tableName));

StringBuilder sb = new StringBuilder();

sb.AppendLine("using System;");

sb.AppendLine("using System.Collections.Generic;");

sb.AppendLine("using System.Linq;");

sb.AppendLine("using System.Text;");

sb.AppendLine("namespace " + args .Namespace+ ".Model");

sb.AppendLine("{");

sb.AppendLine("partial class " + tableName);

sb.AppendLine("{");
foreach (DataRow row in dt.Rows)

{
string colName = Convert.ToString(row["COLUMN_NAME"]);
string colType = Convert.ToString(row["DATA_TYPE"]);


Type netType = GetTypeByDBType(colType);
string netTypeName;
if (netType.IsValueType)

{

netTypeName = netType + "?";

}
else

{

netTypeName = netType.ToString();

}

sb.AppendLine("public " +netTypeName +" "+ colName + " { get; set; }");

}

sb.AppendLine(" }");

sb.AppendLine(" }");
string modelDir = Path.Combine(args.OutputDir, "Model");
string modelFile = Path.Combine(modelDir, tableName+".cs");

Directory.CreateDirectory(modelDir);

File.WriteAllText(modelFile, sb.ToString());

}
复制代码
DAL（数据访问层）的实现：
 
复制代码 
        /// <summary>
///DAL
/// </summary>
/// <param name="args"></param>
/// <param name="tableName"></param>
        public static void CreateDAL(CodeBuilderArgs args, string tableName)

{

StringBuilder sb = new StringBuilder();

DataTable dt = ExecuteDataTable(args.ConnectionString, "select * from INFORMATION_SCHEMA.COLUMNS where TABLE_NAME=@TABLE_NAME"

, new SqlParameter("TABLE_NAME", tableName));

sb.AppendLine("using System;");

sb.AppendLine("using System.Collections.Generic;");

sb.AppendLine("using System.Linq;");

sb.AppendLine("using System.Text;");

sb.AppendLine("using "+args.Namespace+".Model;");

sb.AppendLine("using System.Data.SqlClient;");

sb.AppendLine("using System.Data;");

sb.AppendLine("namespace "+args.Namespace+".DAL");

sb.AppendLine("{");

sb.AppendLine("partial class "+tableName+"DAL");

sb.AppendLine("{");

sb.AppendLine("public int AddNew("+tableName+" model)");

sb.AppendLine("{");

string[] cols = GetColsWithoutId(GetCols(dt, new List<string>())).ToArray();
var colsParameters=from e in cols select"@"+ e;

sb.AppendLine("string sql = \"insert into " + tableName + "(" + string.Join(",", cols) + ") output inserted.id values(" + string.Join(",", colsParameters.ToArray()) + ")\";");

sb.AppendLine("int id = (int)SqlHelper.ExecuteScalar(sql");

foreach (DataRow row in dt.Rows)

{
string colName = Convert.ToString(row["COLUMN_NAME"]);
if(!(colName.ToLower()=="id"))

{

sb.AppendLine(", new SqlParameter(\""+colName+"\", model."+colName+")");   

}


}

sb.AppendLine(");");

sb.AppendLine("return id;");

sb.AppendLine("}");

var par=from e in cols select e+"="+"@"+e;

sb.AppendLine("public bool Update("+tableName+" model)");

sb.AppendLine("{");

sb.AppendLine("string sql = \"update "+tableName+" set "+string.Join(",",par.ToArray())+" where id=@id\";");

sb.AppendLine("int rows = SqlHelper.ExecuteNonQuery(sql");
foreach (DataRow row in dt.Rows)

{
string colName = Convert.ToString(row["COLUMN_NAME"]);

sb.AppendLine(", new SqlParameter(\"" + colName + "\", model." + colName + ")");   

}

sb.AppendLine(");");

sb.AppendLine("return rows>0;");

sb.AppendLine("}");



sb.AppendLine("public bool Delete(int id)");

sb.AppendLine("{");

sb.AppendLine("int rows = SqlHelper.ExecuteNonQuery(\"delete from "+tableName+" where id=@id\",");

sb.AppendLine("new SqlParameter(\"id\", id));");

sb.AppendLine("return rows > 0;");

sb.AppendLine("}");


sb.AppendLine("private static "+tableName+" ToModel(DataRow row)");

sb.AppendLine("{");

sb.AppendLine(""+tableName+" model = new "+tableName+"();");
foreach (DataRow row in dt.Rows)

{
string colName = Convert.ToString(row["COLUMN_NAME"]);
string colType = Convert.ToString(row["DATA_TYPE"]);


Type netType = GetTypeByDBType(colType);
string netTypeName;
if (netType.IsValueType)

{

netTypeName = netType + "?";

}
else

{

netTypeName = netType.ToString();

}

sb.AppendLine("model."+colName+" = row.IsNull(\""+colName+"\") ? null : "+"("+netTypeName+")"+"row[\""+colName+"\"];");

}

sb.AppendLine("return model;");

sb.AppendLine("}");



//
            sb.AppendLine("public "+tableName+" Get(int id)");

sb.AppendLine("{");

sb.AppendLine("DataTable dt = SqlHelper.ExecuteDataTable(\"select * from "+tableName+"  where id=@id\",");

sb.AppendLine("new SqlParameter(\"id\", id));");

sb.AppendLine("if(dt.Rows.Count > 1)");

sb.AppendLine("{");

sb.AppendLine("throw new Exception(\"more than 1 row was found\");");

sb.AppendLine("}");

sb.AppendLine("if(dt.Rows.Count <= 0)");

sb.AppendLine("{");

sb.AppendLine("return null; ");

sb.AppendLine("}");

sb.AppendLine("DataRow row = dt.Rows[0];");

sb.AppendLine(""+tableName+" model = ToModel(row);");

sb.AppendLine("return model;");

sb.AppendLine("}");


sb.AppendLine("public IEnumerable<"+tableName+">ListAll()");

sb.AppendLine("{");

sb.AppendLine("List<"+tableName+"> list = new List<"+tableName+">();");

sb.AppendLine("DataTable dt = SqlHelper.ExecuteDataTable(\"select * from "+tableName+"\");");

sb.AppendLine("foreach (DataRow row in dt.Rows)");

sb.AppendLine("{");

sb.AppendLine("list.Add(ToModel(row));");

sb.AppendLine("}");

sb.AppendLine("return list;");

sb.AppendLine("}");

sb.AppendLine("}");

sb.AppendLine("}");

string DALlDir = Path.Combine(args.OutputDir,"DAL");
string DALFile = Path.Combine(DALlDir,tableName+"DAL.cs");

Directory.CreateDirectory(DALlDir);

File.WriteAllText(DALFile,sb.ToString());

}
private static IEnumerable<string> GetColsWithoutId(List<string> cols)

{
var colArray = from col in cols where col.ToLower() != "id" select col;
return colArray;

}
private static List<string> GetCols(DataTable dt, List<string> cols)

{
foreach (DataRow row in dt.Rows)

{
string colName = Convert.ToString(row["COLUMN_NAME"]);

cols.Add(colName);

}
return cols;

}
复制代码
BLL的实现：
复制代码 
        /// <summary>
/// BLL
/// </summary>
/// <param name="args"></param>
/// <param name="tableName"></param>
        public static void CreateBLL(CodeBuilderArgs args,string tableName)

{

StringBuilder sb = new StringBuilder();

sb.AppendLine("using System;");

sb.AppendLine("using System.Collections.Generic;");

sb.AppendLine("using System.Linq;");

sb.AppendLine("using System.Text;");

sb.AppendLine("using "+args.Namespace+".Model;");

sb.AppendLine("using "+args.Namespace+".DAL;");

sb.AppendLine("namespace "+args.Namespace+".BLL");

sb.AppendLine("{");

sb.AppendLine("partial class "+tableName+"BLL");

sb.AppendLine("{");

sb.AppendLine("public int AddNew("+tableName+" model)");

sb.AppendLine("{");

sb.AppendLine("return new "+tableName+"DAL().AddNew(model);");

sb.AppendLine("}");

sb.AppendLine("public bool Delete(int id)");

sb.AppendLine("{");

sb.AppendLine("return new "+tableName+"DAL().Delete(id);");

sb.AppendLine("}");

sb.AppendLine("public bool Update("+tableName+" model)");

sb.AppendLine("{");

sb.AppendLine("return new "+tableName+"DAL().Update(model);");

sb.AppendLine("}");

sb.AppendLine("public "+tableName+" Get(int id)");

sb.AppendLine("{");

sb.AppendLine("return new "+tableName+"DAL().Get(id);");

sb.AppendLine("}");

sb.AppendLine("public IEnumerable<"+tableName+"> ListAll()");

sb.AppendLine("{");

sb.AppendLine("return new "+tableName+"DAL().ListAll();");

sb.AppendLine("}");

sb.AppendLine("}");

sb.AppendLine("}");
string BLLDir = Path.Combine(args.OutputDir,"BLL");
string BLLFile = Path.Combine(BLLDir,tableName+"BLL.cs");

Directory.CreateDirectory(BLLDir);

File.WriteAllText(BLLFile,sb.ToString());

}
复制代码
详细代码可参考：
88x31.png
本博客为 木宛城主原创，基于 Creative Commons Attribution 2.5 China Mainland License发布，欢迎转载，演绎或用于商业目的，但是必须保留本文的署名 木宛城主（包含链接）。如您有任何疑问或者授权方面的协商，请给我留言。
分类: 架构思想

本文转自木宛城主博客园博客，原文链接：http://www.cnblogs.com/OceanEyes/archive/2012/03/08/codebuilder.html，如需转载请自行联系原作者
文章标签：
SQL
数据库
Windows
长征6号
目录
相关文章
赵广陆
|
8月前
|
SQL Java 数据库连接
MyBatis原理分析手写持久层框架1
MyBatis原理分析手写持久层框架1
赵广陆
65 0
薛伟同学
|
1月前
|
SQL Java 数据库连接
深入源码：解密MyBatis数据源设计的精妙机制
深入源码：解密MyBatis数据源设计的精妙机制
薛伟同学
33 1
深入源码：解密MyBatis数据源设计的精妙机制
风水道人
|
1月前
|
SQL 资源调度 Java
mybatis-plus代码生成器的UI界面使用非常方便
mybatis-plus代码生成器的UI界面使用非常方便
风水道人
37 0
飞翔的佩奇
|
4月前
|
SQL Java 关系型数据库
一文彻底搞懂Mybatis系列（五）之手写Mybatis框架简单探索版(含源代码)
一文彻底搞懂Mybatis系列（五）之手写Mybatis框架简单探索版(含源代码)
飞翔的佩奇
47 0
岁岁种桃花儿
|
5月前
|
设计模式 SQL Java
Mybatis源码分析系列之第四篇：Mybatis中代理设计模型源码详解
Mybatis源码分析系列之第四篇：Mybatis中代理设计模型源码详解
岁岁种桃花儿
33 0
赵广陆
|
8月前
|
Java 数据库连接 数据库
MyBatis原理分析手写持久层框架2
MyBatis原理分析手写持久层框架2
赵广陆
58 0
Tom弹架构
|
9月前
|
设计模式 Java Spring
用300行代码手写1个Spring框架，麻雀虽小五脏俱全
为了解析方便，我们用application.properties来代替application.xml文件，具体配置内容如下：
Tom弹架构
28 0
我是廖志伟
|
SQL Oracle Java
MyBatis框架：第六章：mybatis的核心配置
MyBatis框架：第六章：mybatis的核心配置
我是廖志伟
158 0
MyBatis框架：第六章：mybatis的核心配置
蛋先生DX
五分钟开发属于你自己的代码生成器
本文很短，却诚意满满 用不了 2 分钟你就能看完 然后大概率你就会惊叹 原来开发属于自己的代码生成器，是这么滴简单
蛋先生DX
220 0
五分钟开发属于你自己的代码生成器
西魏陶渊明
|
SQL 设计模式 Java
第10篇:Mybatis的插件设计分析
Mybatis 中的插件都是通过代理方式来实现的,通过拦截执行器中指定的方法来达到改变核心执行代码的方式。举一个列子,查询方法核心都是通过 Executor来进行sql执行的。那么我们就可以通过拦截下面的方法来改变核心代码。基本原理就是这样,下面我们在来看 Mybatis 是如何处理插件。
西魏陶渊明
94 0
第10篇:Mybatis的插件设计分析

热门文章

最新文章

  • 1
    【SSL】OV、DV和EV证书的区别
  • 2
    大数据上手实战！《Elasticsearch 实战进阶营》第二季限时免费报名啦
  • 3
    逆天：蘑菇街下单平台演进，从PHP到Java
  • 4
    使用 google_breakpad 分析 Electron 崩溃日志文件
  • 5
    谈谈MYSQL索引是如何提高查询效率的
  • 6
    通过bmc setup修改Netapp autosuport邮箱地址
  • 7
    日本350MW太阳能项目被GSSG投资公司收购
  • 8
    好书推荐—《大话存储》
  • 9
    如何让Pl/Sql查出的某个值可编辑？
  • 10
    【DataGuard】传递归档日志是遇到ORA-12514
  • 1
    【机器学习】在使用K-means聚类算法时，如何选择K的值？
    63
  • 2
    【机器学习】为什么K-means算法使用欧式距离度量？
    62
  • 3
    【机器学习】描述K-means算法的步骤
    60
  • 4
    【机器学习】K-means聚类的停止标准是什么？
    62
  • 5
    【机器学习】解释什么是K-means聚类？
    43
  • 6
    【机器学习】K-means和KNN算法有什么区别？
    46
  • 7
    【机器学习】K-means聚类有哪些应用？
    45
  • 8
    【机器学习】贝叶斯统计中，“先验概率”和“后验概率”的区别？
    41
  • 9
    SQL脚本把多行SQL数据变成一条多列数据
    48
  • 10
    Go语言学习12-数据的使用
    32

    • 相关课程

    更多
  • MyBatis持久层框架入门
  • SpringMVC框架入门
  • Java Web开发系列课程 - Spring框架入门
  • Go语言核心编程 - 面向对象、文件、单元测试、反射、TCP编程
  • SpringBoot快速掌握 - 高级应用
  • PHP进阶教程 - 由浅入深掌握面向对象开发 - 第二阶段

    • 相关电子书

    更多
  • Spring框架入门
  • Java Spring Boot开发实战系列课程【第6讲】：Spring Boot 2.0实战MyBatis与优化(Java面试题)
  • 用RxSwift写易维护易读的愉悦代码
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）