zoukankan      html  css  js  c++  java
  • C# 执行SQL脚本文件

    本文转载:http://www.cnblogs.com/anjou/archive/2010/08/10/1796563.html

    代码 
    public static int ExecuteSqlScript(string sqlFile)
    {
        int returnValue = -1;
        int sqlCount = 0, errorCount = 0;
        if (!File.Exists(sqlFile))
        {
            Log.WriteLog(string.Format("sql file not exists!", sqlFile));
            return -1;
        }
        using (StreamReader sr = new StreamReader(sqlFile))
        {
            string line = string.Empty;
            char spaceChar = ' ';
            string newLIne = "\r\n", semicolon = ";";
            string sprit = "/", whiffletree = "-";               
            string sql = string.Empty;
            do
            {
                line = sr.ReadLine();
                // 文件结束
                if (line == nullbreak;
                // 跳过注释行
                if (line.StartsWith(sprit) || line.StartsWith(whiffletree)) continue;
                // 去除右边空格
                line = line.TrimEnd(spaceChar);
                sql += line;
                // 以分号(;)结尾,则执行SQL
                if (sql.EndsWith(semicolon))
                {
                    try
                    {
                        sqlCount++;
                        SqlHelper.ExecuteNonQuery(sql, null);
                    }
                    catch (Exception ex)
                    {
                        errorCount++;
                        Log.WriteLog(sql +  newLIne + ex.Message);  
                    }                        
                    sql = string.Empty;
                }
                else
                {
                    // 添加换行符
                    if(sql.Length > 0) sql += newLIne;
                }
            } while (true);
        }
        if (sqlCount > 0 && errorCount == 0)
            returnValue = 1;
        if (sqlCount == 0 && errorCount == 0)
            returnValue = 0;
        else if (sqlCount > errorCount && errorCount > 0)
            returnValue = -1;
        else if (sqlCount == errorCount)
            returnValue = -2;
        return returnValue;
    }
  • 相关阅读:
    kafka 重启consumer 重复消费问题
    预约系统(十) 预约页面--首页
    预约系统(九) 管理页面--部门管理
    预约系统(八) 管理页面--会议室管理
    预约系统(七) 管理页面--用户管理页面
    预约系统(六) 管理页面首页
    预约系统(五) 管理页面框架 密码修改和用户信息功能
    重读C# -- 1.net体系结构
    预约系统(四) 管理页面框架搭建easyUI
    预约系统(三) 登录功能和验证码
  • 原文地址:https://www.cnblogs.com/51net/p/2537950.html
Copyright © 2011-2022 走看看