OpenAuth.Net/OpenAuth.App/Form/DragForm.cs

using System;
using System.Linq;
using System.Text;
using Infrastructure;
using Newtonsoft.Json.Linq;
using OpenAuth.Repository;
using OpenAuth.Repository.Interface;
using OpenAuth.Repository.QueryObj;

namespace OpenAuth.App
{
    /// <summary>
    /// 拖动表单，根据表单字段创建数据库表
    /// </summary>
    public class DragForm: IForm
    {
        private IUnitWork<OpenAuthDBContext> _unitWork;

        public DragForm(IUnitWork<OpenAuthDBContext> unitWork)
        {
            _unitWork = unitWork;
        }

        /**
	     * 功能:  创建表单数据表格（基于sql server）
	     */
        public string GetSql(Repository.Domain.Form form, string dbType)
        {
            if (dbType == Define.DBTYPE_SQLSERVER) //Sql Server
            {
                // 获取字段并处理
                var jsonArray = JsonHelper.Instance.Deserialize<JObject>(form.ContentData)["list"];

                // 数据库名称
                string tableName = form.DbName;

                var exist = _unitWork.FromSql<QueryStringObj>($"select '1' as value from sysobjects where name = '{tableName}' and type = 'U'").SingleOrDefault();
                if (exist != null) return string.Empty;
                
                // 创建数据表
                StringBuilder sql = new StringBuilder($"CREATE TABLE {tableName} (   [Id] varchar(50) COLLATE Chinese_PRC_CI_AS NOT NULL,"); //主键

                string sqlDefault = "";

                foreach (var json in jsonArray)
                {
                    string type = json["type"].ToString();
                    string name = json["model"].ToString();
                    
                    sql.Append("[" + name + "] " + field_type_sql(type)); //字段拼接


                    if ("checkboxs" == type)
                        sqlDefault += field_type_sql_default(tableName, name, "0");
                    else
                        sqlDefault += field_type_sql_default(tableName, name, "''");
                }

                sql.Append(");");

                //设置主键
                sql.Append("ALTER TABLE " + tableName + " ADD CONSTRAINT [PK_" + form.DbName +
                           "] PRIMARY KEY NONCLUSTERED ([Id])");
                sql.Append(
                    "WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ");
                sql.Append("ON [PRIMARY];");

                //主键默认值
                sql.Append("ALTER TABLE " + tableName + " ADD   DEFAULT (newid()) FOR [Id];");

                return sql + sqlDefault;
            }
            else
            {
                // 获取字段并处理
                var jsonArray = JsonHelper.Instance.Deserialize<JObject>(form.ContentData)["list"];

                // 数据库名称
                string tableName = form.DbName;
                
                var exist = _unitWork.FromSql<QueryStringObj>($"select table_name as value from information_schema.tables where table_name ='{tableName}'").SingleOrDefault();
                if (exist != null) return string.Empty;
                
                // 创建数据表
                StringBuilder sql = new StringBuilder("create table if not exists `"
                                                      + tableName
                                                      + "` (   Id varchar(50) not null primary key,"); //主键

                foreach (var json in jsonArray)
                {
                    string type = json["type"].ToString();
                    string name = json["model"].ToString();

                    sql.Append("`" + name + "` " + field_type_mysql(type)); //字段拼接
                    
                }

                sql.Append(");");

                return sql.ToString();
            }
        }

        private string field_type_sql(string leipiplugins)
        {
            if ("textarea" == leipiplugins || "listctrl" == leipiplugins)
            {
                return " text  NULL ,";
            }
            else if ("checkboxs" == leipiplugins)
            {
                return " int NOT NULL ,";
            }
            else
            {
                return " varchar(255)  NULL ,";
            }
        }

        private string field_type_mysql(string leipiplugins)
        {
            if ("textarea" == leipiplugins || "listctrl" == leipiplugins)
            {
                return " varchar(255) null ,";
            }
            else if ("checkboxs" == leipiplugins)
            {
                return " tinyint not null ,";
            }
            else
            {
                return " varchar(255)  NULL ,";
            }
        }

        private string field_type_sql_default(string tablename, string field, string defaultValue)
        {
            return "ALTER TABLE " + tablename + " ADD  DEFAULT (" + defaultValue + ") FOR [" + field + "];";
        }
    }
}