文档章节

简单代码生成器原理剖析(二)

 木宛城主
发布于 2015/03/02 19:38
字数 974
阅读 1
收藏 0

上篇《简单代码生成器原理剖析(一)》分析了代码生成器的原理,查询数据库系统视图: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());
}
详细代码可参考:

© 著作权归作者所有

共有 人打赏支持
粉丝 2
博文 222
码字总数 199010
作品 0
黄浦
私信 提问
JavaScript 异步编程

前言 自己着手准备写这篇文章的初衷是觉得如果想要更深入的理解 JS,异步编程则是必须要跨过的一道坎。由于这里面涉及到的东西很多也很广,在初学 JS 的时候可能无法完整的理解这一概念,即使...

RetroAstro
10/22
0
0
Python中的yield

一、迭代器(iterator) 在Python中,for循环可以用于Python中的任何类型,包括列表、元祖等等,实际上,for循环可用于任何“可迭代对象”,这其实就是迭代器 迭代器是一个实现了迭代器协议的对...

翼动动空
2016/05/09
765
0
如何基于yeoman快速编写脚手架工具(系列:使用篇上)

如何基于yeoman快速编写脚手架工具(系列:使用篇上) 由于关于yeoman编写脚手架的文章太少,所以推出此文,注意本文介绍的yoeman generator-generator是基于 0.8.0以前的版本,0.1.0以后的版...

刘学炜
2016/01/23
515
0
TensorFlow实现seq2seq

前言 前面在《深度学习的seq2seq模型》文章中已经介绍了seq2seq结构及其原理,接下去这篇文章将尝试使用TensorFlow来实现一个seq2seq网络结构,该例子能通过训练给定的训练集实现输入某个序列...

sea-boat
2017/09/14
0
0
Mybatis-plus 1.2.2 发布,MyBatis 增强工具包

mybatis-plus 1.2.2 发布了。MyBatis 增强工具包,简化 CURD 操作。 启动加载 XML 配置时注入单表 SQL 操作 ,为简化开发工作、提高生产率而生。 mybatis-plus 实践及架构原理 与其他工具包区...

青苗
2016/03/14
8.4K
9

没有更多内容

加载失败,请刷新页面

加载更多

基于vue2定义自己的图表echart组件

先安装echarts cnpm i echarts -S,然后定义父组件 <template> <div> <echarts :option="echartOpion"></echarts> </div></template><script> import echarts from './e......

莫沫达
8分钟前
0
0
详解CSS的Flex布局

本文由云+社区发表 Flex是Flexible Box 的缩写,意为"弹性布局",是CSS3的一种布局模式。通过Flex布局,可以很优雅地解决很多CSS布局的问题。下面会分别介绍容器的6个属性和项目的6个属性。每...

腾讯云加社区
20分钟前
0
0
一些感想

人生的意义是什么 不知不觉已人到中年,其实上学的时候经常会思考这些问题————大概是因为闲,大学毕业参加工作经历的事情越来越多,反而不会去想这些缥缈的事情了,也许是因为最近看了一...

looqy
21分钟前
0
0
迭代器模式 Iterator 行为型 设计模式(二十)

  在计算机中,Iterator意为迭代器,迭代有重复的含义,在程序中,更有“遍历”的含义      如果给定一个数组,我们可以通过for循环来遍历这个数组,这种遍历就叫做迭代      对于...

SEOwhywhy
29分钟前
2
0
【 58沈剑 架构师之路】InnoDB,5项最佳实践,知其所以然

缓存讲了一个月《缓存架构,一篇足够》。今天,开始写数据库。 第一篇,说说MySQL两个最常用的存储引擎,MyISAM和InnoDB。照自己的理解,把一些知识点总结出来,不只说知识点,多讲“为什么”...

张锦飞
31分钟前
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部