C#和Java中执行SQL文件脚本的代码(非常有用)_.NET_编程开发_程序员俱乐部

中国优秀的程序员网站程序员频道CXYCLUB技术地图
热搜:
更多>>
 
您所在的位置: 程序员俱乐部 > 编程开发 > .NET > C#和Java中执行SQL文件脚本的代码(非常有用)

C#和Java中执行SQL文件脚本的代码(非常有用)

 2014/4/14 16:06:42  GC2013  博客园  我要评论(0)
  • 摘要:我们在做程序的时候有事后会涉及到利用sql文件直接执行,可是在sql文件中有很多注释,我们要一句一句的执行首先必须的得把sql文件解析去除其中的注释,还有把每一句sql语句取出来,然后再利用各个平台中的数据库相关执行它。接下来放代码!java版本的001packagecom.zz;002003importjava.io.*;004importjava.util.ArrayList;005importjava.util.Enumeration;006importjava.util.List
  • 标签:

我们在做程序的时候有事后会涉及到利用sql文件 直接执行,可是在sql文件中有很多注释,我们要一句一句的执行首先必须的得把sql文件解析

去除其中的注释,还有把每一句sql语句取出来,然后再利用各个平台中的数据库相关执行它。

 

接下来放代码!

java版本

001 class="keyword">package com.zz; 002   003 import java.io.*; 004 import java.util.ArrayList; 005 import java.util.Enumeration; 006 import java.util.List; 007 import java.util.Vector; 008   009 /* 010  * 作者 祝君 011  * 时间 2014年1月16号 012  * java执行数据库脚本代码 013  */ 014 public class SqlHelper { 015   016     /** 017      * @param args 018      */ 019     public static void main(String[] args) { 020           021         String path=new String("d:\\zzadmin.sql"); 022         String sql=GetText(path); 023         String[] arr=getsql(sql); 024         for(int i=0;i<arr.length;i++) 025             System.out.println("第"+i+"句:"+arr[i]); 026   027     } 028     public static String GetText(String path){ 029         File file=new File(path); 030         if(!file.exists()||file.isDirectory()) 031             return null; 032         StringBuffer sb=new StringBuffer(); 033         try 034         { 035             FileInputStream fis = new FileInputStream(path); 036             InputStreamReader isr = new InputStreamReader(fis, "UTF-8"); 037             BufferedReader br = new BufferedReader(isr); 038             String temp=null; 039             temp=br.readLine(); 040             while(temp!=null){ 041             sb.append(temp+"\r\n"); 042             temp=br.readLine(); 043             } 044         } catch (Exception e) { 045             e.printStackTrace(); 046         } 047         return sb.toString(); 048     } 049   050     /** 051      * 获取sql文件中的sql语句数组 052      * @param sql 053      * @return 数组 054      */ 055     public static String[] getsql(String sql) 056     { 057         String s=sql; 058         s=s.replace("\r\n","\r"); 059         s=s.replace("\r", "\n"); 060         String[] ret=new String[1000]; 061         String[] sqlarray=s.split(";\n"); 062         sqlarray=filter(sqlarray); 063         int num=0; 064         for (String item : sqlarray) 065         { 066             String ret_item = ""; 067             String[] querys = item.trim().split("\n"); 068             querys = filter(querys);//去空 069             for (String query : querys) 070             { 071                 String str1 = query.substring(0, 1); 072                 String str2 = query.substring(0, 2); 073                 if (str1.equals("#") || str2.equals("--") || str2.equals("/*") || str2.equals("//"))//去除注释的关键步奏 074                 { 075                     continue; 076                 } 077                 ret_item += query; 078             } 079             ret[num] = ret_item; 080             num++; 081         } 082         return filter(ret); 083     } 084     /// <summary> 085     /// 去除空值数组 086     /// </summary> 087     /// <param name="ss">数组</param> 088     /// <returns></returns> 089     public static String[] filter(String[] ss) 090     { 091         List<String> strs = new ArrayList<String>(); 092         for (String s : ss) { 093              if (s != null && !s.equals("")) 094                  strs.add(s); 095         } 096          097         String[] result=new String[strs.size()]; 098         for(int i=0;i<strs.size();i++) 099         { 100             result[i]=strs.get(i).toString(); 101         } 102         return result; 103     } 104       105     //删除注释 106     public void deletezs(String fileStr) 107     { 108       try{ 109       Vector<String> vec=new Vector<String>(); 110       String str="",tm="",mm=""; 111       BufferedReader br = new BufferedReader( new FileReader(fileStr)); 112       boolean bol=false; 113       while( null != (str = br.readLine() ) ) 114       { 115         if ((str.indexOf("/*")>=0)&&((bol==false))) 116         { 117           if (str.indexOf("*/")>0) 118           { 119             bol=false; 120             vec.addElement(str.substring(0,str.indexOf("/*"))+str.substring(str.indexOf("*/")+2,str.length())); 121           } 122           else 123           { 124              bol=true; 125              mm=str.substring(0,str.indexOf("/*")); 126              if (!(mm.trim().equals(""))) 127                  vec.addElement(mm); 128           } 129         } 130         else if (bol==true) 131         { 132             if (str.indexOf("*/")>=0) 133             { 134                 bol=false; 135                 mm=str.substring(str.indexOf("*/")+2,str.length()); 136                 if (!mm.trim().equals("")) 137                    vec.addElement(mm); 138             } 139         } 140         else if (str.indexOf("//")>=0) 141         { 142                      tm=str.substring(0,str.indexOf("//")); 143                      if (!tm.trim().equals("")) 144                         vec.addElement(tm); 145         } 146         else 147         { 148             vec.addElement(str); 149         } 150         } 151       br.close(); 152       File fName=new File(fileStr); 153       FileWriter in=new  FileWriter(fName); 154       String ssss=""; 155       Enumeration<String> ew=vec.elements(); 156   157              while (ew.hasMoreElements()) { 158                ssss= ew.nextElement().toString(); 159                in.write(ssss+"\n"); 160              } 161   162       in.close(); 163       vec.clear(); 164   165       }catch(Exception ee){ 166           ee.printStackTrace(); 167       } 168   169     } 170   171   172 }

调用GetText就可以返回一个装满了sql语句的数组,循环执行其中的sql语句吧

 

c#版本的

001 //-------------------------第一种------------------------------------- 002        /// <summary> 003        /// 获取sql文件中的sql语句数组 第一种方法 004        /// </summary> 005        /// <param name="sql"></param> 006        /// <returns></returns> 007        public static string[] sql_split(string sql) 008        { 009            string s = sql; 010            Regex reg = newRegex("/TYPE=(InnoDB|MyISAM|MEMORY)( DEFAULT CHARSET=[^; ]+)?/"); 011            reg.Replace(sql, "ENGINE=\\1 DEFAULT CHARSET=utf8"); 012            s = s.Replace('\r''\n'); 013            string[] ret = new string[10000]; 014            string[] sqlarray = StringSplit(s, ";\n"); 015            int num = 0; 016            foreach (string item in sqlarray) 017            { 018                ret[num] = ""; 019                string[] queries = item.Split('\n'); 020                queries = filter(queries); 021                foreach (string query in queries) 022                { 023                    string str1 = query.Substring(0, 1); 024                    string str2 = query.Substring(0, 2); 025                    if (str1 != "#" && str2 != "--" && str2 != "/*"&& str2 != "//")//去除注释的关键步奏 026                    { 027                        ret[num] += query; 028                    } 029                } 030                num++; 031            } 032            ret = filter(ret); 033            return ret; 034        } 035   036        /// <summary> 037        /// 去除空值数组 038        /// </summary> 039        /// <param name="ss"></param> 040        /// <returns></returns> 041        public static string[] filter(string[] ss) 042        { 043            List<string> strs = new List<string>(); 044            foreach (string in ss) 045            { 046                if (!string.IsNullOrEmpty(s)) strs.Add(s); 047            } 048            string[] result = strs.ToArray(); 049            return result; 050        } 051        /// <summary> 052        /// 将字符串分割成数组 053        /// </summary> 054        /// <param name="strSource"></param> 055        /// <param name="strSplit"></param> 056        /// <returns></returns> 057        public static string[] StringSplit(string strSource, string strSplit) 058        { 059            string[] strtmp = new string[1]; 060            int index = strSource.IndexOf(strSplit, 0); 061            if (index < 0) 062            { 063                strtmp[0] = strSource; 064                return strtmp; 065            } 066            else 067            { 068                strtmp[0] = strSource.Substring(0, index); 069                returnStringSplit(strSource.Substring(index + strSplit.Length), strSplit, strtmp); 070            } 071        } 072   073        /// <summary> 074        /// 采用递归将字符串分割成数组 075        /// </summary> 076        /// <param name="strSource"></param> 077        /// <param name="strSplit"></param> 078        /// <param name="attachArray"></param> 079        /// <returns></returns> 080        private static string[] StringSplit(string strSource, stringstrSplit, string[] attachArray) 081        { 082            string[] strtmp = new string[attachArray.Length + 1]; 083            attachArray.CopyTo(strtmp, 0); 084   085            int index = strSource.IndexOf(strSplit, 0); 086            if (index < 0) 087            { 088                strtmp[attachArray.Length] = strSource; 089                return strtmp; 090            } 091            else 092            { 093                strtmp[attachArray.Length] = strSource.Substring(0, index); 094                returnStringSplit(strSource.Substring(index + strSplit.Length), strSplit, strtmp); 095            } 096        } 097   098        //----------------------------------------------------- 099   100        //-----------------------第二种------------------------------ 101        /// <summary> 102        /// 获取sql文件中的sql语句数组 第二种 103        /// </summary> 104        /// <param name="sql"></param> 105        /// <returns></returns> 106        public string[] getsqls(string sql) 107        { 108            string s = sql; 109            s = s.Replace("\r\n""\n"); 110            s = s.Replace("\r","\n").Trim(); 111            string[] ret = new string[1000]; 112   113            string[] sqlarray= StringSplit(s, ";\n"); 114            sqlarray = filter(sqlarray);//去空 115   116            int num=0; 117            foreach (string item in sqlarray) 118            { 119                string ret_item = ""; 120                string[] querys = item.Trim().Split('\n'); 121                querys = filter(querys);//去空 122   123                foreach (string query in querys) 124                { 125                    string str1 = query.Substring(0, 1); 126                    string str2 = query.Substring(0, 2); 127                    if (str1 == "#" || str2 == "--" || str2 == "/*"|| str2 == "//")//去除注释的关键步奏 128                    { 129                        continue; 130                    } 131                    ret_item += query; 132                } 133                ret[num] = ret_item; 134                num++; 135            } 136            return filter(ret); 137        }


c#两个方法对sql文件解析都是一样的

上一篇: c#中变量的作用域 下一篇: 没有下一篇了!
  • 相关文章
发表评论
用户名: 匿名