此文主要方便自己查找
<#@ template language="C#" hostspecific="True" debug="false"#>
<#@include file="../Manager.ttinclude"#>
<#@ assembly name="System" #>
<#@ assembly name="System.Core" #>
<#@ assembly name="System.Data" #>
<#@ assembly name="System.Data.DataSetExtensions" #>
<#@ import namespace="System" #>
<#@ import namespace="System.Data" #>
<#@ import namespace="System.Data.SqlClient" #>
<# var manager = Manager.Create(Host, GenerationEnvironment); #>
<#
//你的当前model的命名空间
string ModelNameSpace="Zobo.Entity";
//你的数据库连接字符串
string ConnectStr = "";
SqlConnection MySqlConnection = new SqlConnection(ConnectStr);
//此sql语句找到你指定数据库下的所有表
string SelectYourTableNameStr = "SELECT * FROM sys.sysobjects WHERE TYPE='U'";
SqlDataAdapter MySqlDataAdapter = new SqlDataAdapter(SelectYourTableNameStr, MySqlConnection);
DataSet MyDataSet = new DataSet();
MySqlDataAdapter.Fill(MyDataSet, "cacheTable");
//得到table表
DataTable MyDataTable = MyDataSet.Tables["cacheTable"];
int MyDataTableRowsCount = MyDataTable.Rows.Count;
for (int i = 0; i < MyDataTableRowsCount; i++)
{
//表名
//MyDataTable.Rows[i]["name"].ToString();
//此sql语句找到你当前表下的所有键值，属性，是否为null，长度。
string SelectYourKeyStr = "SELECT [col].[COLUMN_NAME] AS keyname,"+
" [col].[DATA_TYPE] AS keyproperty,"+
" [col].[CHARACTER_OCTET_LENGTH] AS [length],"+
" CASE [col].[IS_NULLABLE]"+
" WHEN 'YES' THEN"+
" 1"+
" ELSE"+
" 0"+
" END AS isnullable,"+
" CASE"+
" WHEN [ccu].[CONSTRAINT_NAME] IS NOT NULL THEN"+
" 1"+
" ELSE"+
" 0"+
" END AS IsPrimaryKey,"+
" COLUMNPROPERTY(OBJECT_ID('"+ MyDataTable.Rows[i]["name"].ToString() + "'), [col].[COLUMN_NAME], 'IsIdentity') AS IsIdentity"+
" FROM [INFORMATION_SCHEMA].[COLUMNS] col"+
" LEFT JOIN [INFORMATION_SCHEMA].[CONSTRAINT_COLUMN_USAGE] ccu"+
" ON [ccu].[TABLE_NAME] = [col].[TABLE_NAME]"+
" AND [ccu].[COLUMN_NAME] = [col].[COLUMN_NAME]"+
" AND [ccu].[CONSTRAINT_NAME] LIKE 'PK_%'"+
" WHERE [col].[TABLE_NAME] = '"+ MyDataTable.Rows[i]["name"].ToString() + "'";
MySqlDataAdapter = new SqlDataAdapter(SelectYourKeyStr, MySqlConnection);
MyDataSet = new DataSet();
MySqlDataAdapter.Fill(MyDataSet, "cacheTable");
//得到key表
DataTable MyKeyTable = MyDataSet.Tables["cacheTable"];
//tt模板输出文件
manager.StartNewFile(MyDataTable.Rows[i]["name"].ToString() +".cs");
#>
using System;
using SqlSugar;
namespace <#=ModelNameSpace#>
{
[SugarTable("<#=MyDataTable.Rows[i]["name"].ToString()#>")]
public class <#=MyDataTable.Rows[i]["name"].ToString()#>
{
<# for (int keyi = 0; keyi < MyKeyTable.Rows.Count; keyi++)
{
string keypropertyOutput = string.Empty;
string isKey=string.Empty;
if(MyKeyTable.Rows[keyi]["IsPrimaryKey"].ToString()=="1" && MyKeyTable.Rows[keyi]["IsIdentity"].ToString()=="1"){
isKey=", IsPrimaryKey = true, IsIdentity = true";
}else if(MyKeyTable.Rows[keyi]["IsPrimaryKey"].ToString()=="1"){
isKey=", IsPrimaryKey = true";
}
switch (MyKeyTable.Rows[keyi]["keyproperty"].ToString().ToLower())
{
case "smallint":
keypropertyOutput = "short";
break;
case "int":
keypropertyOutput = "int";
break;
case "bigint":
keypropertyOutput = "long";
break;
case "real":
keypropertyOutput = "float";
break;
case "float":
keypropertyOutput = "double";
break;
case "money":
keypropertyOutput = "decimal";
break;
case "datetime":
keypropertyOutput = "DateTime";
break;
case "uniqueidentifier":
keypropertyOutput = "Guid";
break;
case "bit":
keypropertyOutput = "bool";
break;
case "tinyint":
keypropertyOutput = "byte";
break;
case "image":
keypropertyOutput = "byte[]";
break;
case "binary":
keypropertyOutput = "byte[]";
break;
default:
keypropertyOutput = "string";
break;
}
//可为null且不是string（就是值类型）可以加?
if (MyKeyTable.Rows[keyi]["isnullable"].ToString()=="1"&& keypropertyOutput!="string")
{
if (keypropertyOutput == "byte[]")
{
keypropertyOutput = "byte?[]";
}
else
{
keypropertyOutput = keypropertyOutput + "?";
}
}
#>
[SugarColumn(ColumnName="<#=MyKeyTable.Rows[keyi]["keyname"].ToString()#>" <#=isKey#> )]
public <#=keypropertyOutput#> <#=MyKeyTable.Rows[keyi]["keyname"].ToString()#> { get; set; }
<#
}
#>
}
}
<# //代码结束
manager.EndBlock();
MySqlConnection.Close();
}
#>
<# manager.Process(true); #>
Manager.ttinclude
<#@ assembly name="System.Core"#>
<#@ assembly name="System.Data.Linq"#>
<#@ assembly name="EnvDTE"#>
<#@ assembly name="System.Xml"#>
<#@ assembly name="System.Xml.Linq"#>
<#@ import namespace="System"#>
<#@ import namespace="System.CodeDom"#>
<#@ import namespace="System.CodeDom.Compiler"#>
<#@ import namespace="System.Collections.Generic"#>
<#@ import namespace="System.Data.Linq"#>
<#@ import namespace="System.Data.Linq.Mapping"#>
<#@ import namespace="System.IO"#>
<#@ import namespace="System.Linq"#>
<#@ import namespace="System.Reflection"#>
<#@ import namespace="System.Text"#>
<#@ import namespace="System.Xml.Linq"#>
<#@ import namespace="Microsoft.VisualStudio.TextTemplating"#>
<#+
// Manager class records the various blocks so it can split them up
class Manager {
private class Block {
public String Name;
public int Start, Length;
}
private Block currentBlock;
private List<Block> files = new List<Block>();
private Block footer = new Block();
private Block header = new Block();
private ITextTemplatingEngineHost host;
private StringBuilder template;
protected List<String> generatedFileNames = new List<String>();
public static Manager Create(ITextTemplatingEngineHost host, StringBuilder template) {
return (host is IServiceProvider) ? new VSManager(host, template) : new Manager(host, template);
}
public void StartNewFile(String name) {
if (name == null)
throw new ArgumentNullException("name");
CurrentBlock = new Block { Name = name };
}
public void StartFooter() {
CurrentBlock = footer;
}
public void StartHeader() {
CurrentBlock = header;
}
public void EndBlock() {
if (CurrentBlock == null)
return;
CurrentBlock.Length = template.Length - CurrentBlock.Start;
if (CurrentBlock != header && CurrentBlock != footer)
files.Add(CurrentBlock);
currentBlock = null;
}
public virtual void Process(bool split) {
if (split) {
EndBlock();
String headerText = template.ToString(header.Start, header.Length);
String footerText = template.ToString(footer.Start, footer.Length);
String outputPath = Path.GetDirectoryName(host.TemplateFile);
files.Reverse();
foreach(Block block in files) {
String fileName = Path.Combine(outputPath, block.Name);
String content = headerText + template.ToString(block.Start, block.Length) + footerText;
generatedFileNames.Add(fileName);
CreateFile(fileName, content);
template.Remove(block.Start, block.Length);
}
}
}
protected virtual void CreateFile(String fileName, String content) {
if (IsFileContentDifferent(fileName, content))
File.WriteAllText(fileName, content);
}
public virtual String GetCustomToolNamespace(String fileName) {
return null;
}
public virtual String DefaultProjectNamespace {
get { return null; }
}
protected bool IsFileContentDifferent(String fileName, String newContent) {
return !(File.Exists(fileName) && File.ReadAllText(fileName) == newContent);
}
private Manager(ITextTemplatingEngineHost host, StringBuilder template) {
this.host = host;
this.template = template;
}
private Block CurrentBlock {
get { return currentBlock; }
set {
if (CurrentBlock != null)
EndBlock();
if (value != null)
value.Start = template.Length;
currentBlock = value;
}
}
private class VSManager: Manager {
private EnvDTE.ProjectItem templateProjectItem;
private EnvDTE.DTE dte;
private Action<String> checkOutAction;
private Action<IEnumerable<String>> projectSyncAction;
public override String DefaultProjectNamespace {
get {
return templateProjectItem.ContainingProject.Properties.Item("DefaultNamespace").Value.ToString();
}
}
public override String GetCustomToolNamespace(string fileName) {
return dte.Solution.FindProjectItem(fileName).Properties.Item("CustomToolNamespace").Value.ToString();
}
public override void Process(bool split) {
if (templateProjectItem.ProjectItems == null)
return;
base.Process(split);
projectSyncAction.EndInvoke(projectSyncAction.BeginInvoke(generatedFileNames, null, null));
}
protected override void CreateFile(String fileName, String content) {
if (IsFileContentDifferent(fileName, content)) {
CheckoutFileIfRequired(fileName);
File.WriteAllText(fileName, content);
}
}
internal VSManager(ITextTemplatingEngineHost host, StringBuilder template)
: base(host, template) {
var hostServiceProvider = (IServiceProvider) host;
if (hostServiceProvider == null)
throw new ArgumentNullException("Could not obtain IServiceProvider");
dte = (EnvDTE.DTE) hostServiceProvider.GetService(typeof(EnvDTE.DTE));
if (dte == null)
throw new ArgumentNullException("Could not obtain DTE from host");
templateProjectItem = dte.Solution.FindProjectItem(host.TemplateFile);
checkOutAction = (String fileName) => dte.SourceControl.CheckOutItem(fileName);
projectSyncAction = (IEnumerable<String> keepFileNames) => ProjectSync(templateProjectItem, keepFileNames);
}
private static void ProjectSync(EnvDTE.ProjectItem templateProjectItem, IEnumerable<String> keepFileNames) {
var keepFileNameSet = new HashSet<String>(keepFileNames);
var projectFiles = new Dictionary<String, EnvDTE.ProjectItem>();
var originalFilePrefix = Path.GetFileNameWithoutExtension(templateProjectItem.get_FileNames(0)) + ".";
foreach(EnvDTE.ProjectItem projectItem in templateProjectItem.ProjectItems)
projectFiles.Add(projectItem.get_FileNames(0), projectItem);
// Remove unused items from the project
foreach(var pair in projectFiles)
if (!keepFileNames.Contains(pair.Key) && !(Path.GetFileNameWithoutExtension(pair.Key) + ".").StartsWith(originalFilePrefix))
pair.Value.Delete();
// Add missing files to the project
foreach(String fileName in keepFileNameSet)
if (!projectFiles.ContainsKey(fileName))
templateProjectItem.ProjectItems.AddFromFile(fileName);
}
private void CheckoutFileIfRequired(String fileName) {
var sc = dte.SourceControl;
if (sc != null && sc.IsItemUnderSCC(fileName) && !sc.IsItemCheckedOut(fileName))
checkOutAction.EndInvoke(checkOutAction.BeginInvoke(fileName, null, null));
}
}
} #>
