ArrayList al = new ArrayList();
StreamReader sr = new StringReader("记事本文件位置");
string readMessage = sr.readLine();
while(!string.isNullOrEmpty(readMessage())
{
if(isSqlText(readMessage)){ //isSqlText(readMessage)这个函数很复杂,凭我暂时是根本没办法解决的
al.add(readMessage);
}
readMessage = sr.readLine();
}
sr.Close();
把每行sql取出来,然后就分别调用了啊。
好比取出一个string str
if(str.toLowerString().contains("select")){
exeSqlForDs(str);
}else{
executeSql(str);
}
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Data.SqlClient;
using System.Configuration;
namespace DomRemember
{
class DbUtil
{
public static SqlConnection getConn()
{
// string dbConStr = ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString;
string dbConStr = "server=127.0.0.1;uid=sa;pwd=@hl233211;database=hanl";
//string dbConStr = "data source=.\\SQLEXPRESS;Integrated Security=SSPI;AttachDBFilename=|DataDirectory|hanl.mdf;User Instance=true";
SqlConnection dbCon = new SqlConnection(dbConStr);
return dbCon;
}
public static DataSet exeSqlForDs(string sql)
{
SqlConnection conn = getConn();
try
{
conn.Open();
SqlDataAdapter oda = new SqlDataAdapter(sql, conn);
DataSet ds = new DataSet();
oda.Fill(ds);
return ds;
}
catch (System.Data.SqlClient.SqlException e)
{
throw new Exception(e.Message);
}
finally
{
conn.Close();
}
}
public static int executeSql(string strSQL)
{
SqlConnection myCn = getConn();
SqlCommand myCmd = new SqlCommand(strSQL, myCn);
try
{
myCn.Open();
myCmd.ExecuteNonQuery();
return 0;
}
catch (System.Data.SqlClient.SqlException e)
{
throw new Exception(e.Message);
}
finally
{
myCmd.Dispose();
myCn.Close();
myCn.Dispose();
}
}
}
}
温馨提示:内容为网友见解,仅供参考