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

    代码
    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;
    }
  • 相关阅读:
    Zabbix poller processes more than 75% busy
    标签无效 "/zabbix_export/date": "YYYY-MM-DDThh:mm:ssZ" 预计。
    Received empty response from Zabbix Agent at[172.16.1.51]. Assuming that agent dropped connection because of access permissions
    ERROR 1045 (28000): Access denied for user 'root'@'localhost' (using password: NO)
    Received empty response from Zabbix Agent at [172.16.1.7]...
    Too many open files
    Object.defineProperty之observe实现
    深拷贝 deepAssign
    提交操作自动遮蔽实现之ajax
    js检测输入域的值是否变化
  • 原文地址:https://www.cnblogs.com/anjou/p/1796563.html
Copyright © 2011-2022 走看看