动态批量新建SQL数据库中的表

简介: 动态批量新建SQL数据库中的表

引言


在项目中需要用到动态在数据库中动态的创建新表的需求,所以需要我们在代码中完成建表的功能,这个需求对于自己来说是比较新鲜的,原先自己接触的东西都是在已有的数据库的基础上进行操作的,没有用到过动态建表的功能,所以对这一块的代码是比较感兴趣的,下面和大家分享这一块的知识;


调用代码

<span style="font-size:18px;"> List<string> listNewTableName = new List<string>();
                for (int i = 0; i < listCourseQuestionType.Count(); i++)
                {
                    listNewTableName.Add(listCourseQuestionType[i].AnswerRecordMappingTableName.ToString());
                }
                //拿到我们新建表中的字段
                List<Dictionary<string, string>> listFields = AnswerRecordFields(listCourseQuestionType.Count());
                dynamicCreationBLL.CreateDataTable("ITOOExam", listNewTableName, listFields, "ITOOExamEntities");  //QuestionEntities</span>


创建多个表 的表结构 及其数据类型

<span style="font-size:18px;"> /// <summary>
        /// 创建多个表  的表结构 及其数据类型
        /// </summary>
        /// <param name="DictionaryCount"></param>
        /// <returns></returns>
        public List<Dictionary<string, string>> AnswerRecordFields(int DictionaryCount)
        {
            List<Dictionary<string, string>> listDictionary = new List<Dictionary<string, string>>();
            for (int i = 0; i < DictionaryCount; i++)
            {
                listDictionary.Add(AnswerRecordField());
            }
            return listDictionary;
        }</span>

创建一个答题记录表的字段及其数据类型

<span style="font-size:18px;">  /// <summary>
        /// 创建一个答题记录表 的  字段及其数据类型
        /// </summary>
        /// <returns></returns>
        public Dictionary<string, string> AnswerRecordField()
        {
            Dictionary<string, string> field = new Dictionary<string, string>();
            field.Add("answerRecordId", "varchar(40)");
            field.Add("examineeId", "varchar(40)");
            field.Add("rightAnswer", "varchar(max)");
            field.Add("examineeAnswer", "varchar(max)");
            field.Add("finalScore", "decimal(5,2)");
            field.Add("examineeIsJudgment", "int");
            field.Add("questionId", "varchar(40)");
            field.Add("questionNoOrder", "varchar(10)");
            field.Add("optionNoOrder", "varchar(10)");
            field.Add("userId", "varchar(40)");
            field.Add("timeStamp", "DateTime default getdate() ");
            field.Add("reUserId", "varchar(40)");
            field.Add("isReJudge", "int");
            field.Add("reJudgeScore", "decimal(5,2)");
            field.Add("preScore", "decimal(5,2)");
            field.Add("IsDeleteAnswerRecord", "int");
            field.Add("ExamId", "varchar(40)");
            field.Add("CollegeId", "varchar(40)"); //学院ID
            field.Add("OnClassId", "varchar(40)");//上课班ID
            field.Add("OnClassName", "varchar(40)");//上课班name
            field.Add("CollegeName", "varchar(40)");//学院name
            return field;
        }</span>

建表方法

<span style="font-size:18px;"> /// <summary>
        ///  在指定的数据库中,创建数据表
        /// </summary>
        /// <param name="db">指定的数据库</param>
        /// <param name="listDt">要创建的数据表集合</param>
        /// <param name="dic">数据表中的字段及其数据类型  Dictionary集合</param>
        /// <param name="connKey">数据库的连接Key</param>
        public void CreateDataTable(string db, List<string> listDt, List<Dictionary<string, string>> dic, string connKey)
        {
            SQLHelper helper = new SQLHelper(connKey);
            string connToMaster = ConfigurationManager.ConnectionStrings[connKey].ToString();
            //判断数据库是否存在
            if (IsDBExist(db, connKey) == false)
            {
                throw new Exception("数据库不存在!");
            }
            for (int i = 0; i < listDt.Count(); i++)
            {
                //如果数据库表存在,则抛出错误
                if (IsTableExist(db, listDt[i], connKey) == true)
                {
                    //如果数据库表已经存在,则跳过该表
                    continue;
                }
                else//数据表不存在,创建数据表
                {
                    //其后判断数据表是否存在,然后创建数据表
                    string createTableStr = PinjieSql(db, listDt[i], dic[i]);
                    helper.ExecuteNonQuery(createTableStr, CommandType.Text);
                }
            }
        }</span>

判断数据库是否存在和数据库中表是否存在的方法,见上一篇博客拼接创建数据库表的Sql语句

<span style="font-size:18px;">    /// <summary>
        /// 拼接创建数据库表的Sql语句
        /// </summary>
        /// <param name="db">指定的数据库</param>
        /// <param name="dt">要创建的数据表</param>
        /// <param name="dic">数据表中的字段及其数据类型</param>
        /// <returns>拼接完的字符串</returns>
        public string PinjieSql(string db, string dt, Dictionary<string, string> dic)
        {
            //拼接字符串,(该串为创建内容)
            string content = "serial int identity(1,1) primary key ";
            //取出dic中的内容,进行拼接
            List<string> test = new List<string>(dic.Keys);
            for (int i = 0; i < dic.Count(); i++)
            {
                content = content + " , " + test[i] + " " + dic[test[i]];
            }
            //其后判断数据表是否存在,然后创建数据表
            string createTableStr = "use " + db + " create table " + dt + " (" + content + ")";
            return createTableStr;
        }</span>


小结


在接触到大项目之后发现自己知道的东西真的是太少了,有很多的东西都没有接触过,自己认为不能实现的东西在别人哪已经非常成熟的实现了,所以当我们遇到难题的时候需要多看一些资料,多和别人交流,多看别人的代码。这

样也许会给我一些灵感,让我们在迷茫中找到方向,所以我们需要在项目中继续学习!!


目录
相关文章
|
17天前
|
SQL Oracle 数据库
使用访问指导(SQL Access Advisor)优化数据库业务负载
本文介绍了Oracle的SQL访问指导(SQL Access Advisor)的应用场景及其使用方法。访问指导通过分析给定的工作负载,提供索引、物化视图和分区等方面的优化建议,帮助DBA提升数据库性能。具体步骤包括创建访问指导任务、创建工作负载、连接工作负载至访问指导、设置任务参数、运行访问指导、查看和应用优化建议。访问指导不仅针对单条SQL语句,还能综合考虑多条SQL语句的优化效果,为DBA提供全面的决策支持。
44 11
|
2月前
|
SQL 缓存 监控
大厂面试高频:4 大性能优化策略(数据库、SQL、JVM等)
本文详细解析了数据库、缓存、异步处理和Web性能优化四大策略,系统性能优化必知必备,大厂面试高频。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
大厂面试高频:4 大性能优化策略(数据库、SQL、JVM等)
|
1月前
|
SQL 关系型数据库 MySQL
MySQL导入.sql文件后数据库乱码问题
本文分析了导入.sql文件后数据库备注出现乱码的原因,包括字符集不匹配、备注内容编码问题及MySQL版本或配置问题,并提供了详细的解决步骤,如检查和统一字符集设置、修改客户端连接方式、检查MySQL配置等,确保导入过程顺利。
|
30天前
|
SQL 监控 安全
SQL Servers审核提高数据库安全性
SQL Server审核是一种追踪和审查SQL Server上所有活动的机制,旨在检测潜在威胁和漏洞,监控服务器设置的更改。审核日志记录安全问题和数据泄露的详细信息,帮助管理员追踪数据库中的特定活动,确保数据安全和合规性。SQL Server审核分为服务器级和数据库级,涵盖登录、配置变更和数据操作等事件。审核工具如EventLog Analyzer提供实时监控和即时告警,帮助快速响应安全事件。
|
2月前
|
SQL 关系型数据库 MySQL
体验使用DAS实现数据库SQL优化,完成任务可得羊羔绒加厚坐垫!
本实验介绍如何通过数据库自治服务DAS对RDS MySQL高可用实例进行SQL优化,包含购买RDS实例并创建数据库、数据导入、生成并优化慢SQL、执行优化后的SQL语句等实验步骤。完成任务,即可领取羊羔绒加厚坐垫,限量500个,先到先得。
177 12
|
2月前
|
SQL 存储 BI
gbase 8a 数据库 SQL合并类优化——不同数据统计周期合并为一条SQL语句
gbase 8a 数据库 SQL合并类优化——不同数据统计周期合并为一条SQL语句
|
2月前
|
SQL 数据库
gbase 8a 数据库 SQL优化案例-关联顺序优化
gbase 8a 数据库 SQL优化案例-关联顺序优化
|
2月前
|
SQL 存储 Linux
从配置源到数据库初始化一步步教你在CentOS 7.9上安装SQL Server 2019
【11月更文挑战第16天】本文介绍了在 CentOS 7.9 上安装 SQL Server 2019 的详细步骤,包括配置系统源、安装 SQL Server 2019 软件包以及数据库初始化,确保 SQL Server 正常运行。
|
2月前
|
SQL 存储 Linux
从配置源到数据库初始化一步步教你在CentOS 7.9上安装SQL Server 2019
【11月更文挑战第8天】本文介绍了在 CentOS 7.9 上安装 SQL Server 2019 的详细步骤,包括系统准备、配置安装源、安装 SQL Server 软件包、运行安装程序、初始化数据库以及配置远程连接。通过这些步骤,您可以顺利地在 CentOS 系统上部署和使用 SQL Server 2019。
|
2月前
|
SQL 存储 Linux
从配置源到数据库初始化一步步教你在CentOS 7.9上安装SQL Server 2019
【11月更文挑战第7天】本文介绍了在 CentOS 7.9 上安装 SQL Server 2019 的详细步骤,包括系统要求检查与准备、配置安装源、安装 SQL Server 2019、配置 SQL Server 以及数据库初始化(可选)。通过这些步骤,你可以成功安装并初步配置 SQL Server 2019,进行简单的数据库操作。