谢谢
解决方案 »
- 在C#中,string str = null 与 string str = " "有何区别?
- C# 怎么 获取openFileDialog1 打开的文件的地址?
- 如何做一个倒计时器?
- serialport的readline怎么用??
- c#在服务器端处理图像大小(size)
- 未处理的“System.Data.OleDb.OleDbException”类型的异常出现在 system.data.dll 中。
- 有关 Dev Express 的 BarManager 控件, 有经验的请进来做答
- 请帮我看以下的语句是哪里错啦?
- 如果指定把一个应用程序放在所有程序的最前面
- 我的分哪里去了??(关于CSDN中专家分的疑惑)
- 请教高手,ArrayList填充DataSet的问题。我放分一向大方...
- 关于静态方法的问题。
{
string mySelectQuery = "SELECT OrderID, CustomerID FROM Orders";
OleDbConnection myConnection = new OleDbConnection(myConnString);
OleDbCommand myCommand = new OleDbCommand(mySelectQuery,myConnection);
myConnection.Open();
OleDbDataReader myReader = myCommand.ExecuteReader();
try
{
while (myReader.Read())
{
Console.WriteLine(myReader.GetInt32(0) + ", " + myReader.GetString(1));
}
}
finally
{
// always call Close when done reading.
myReader.Close();
// always call Close when done reading.
myConnection.Close();
}
}
如下:
using System;
using System.Xml;
using System.Data;
using System.IO;
using System.Collections;
using System.Data.SqlClient;如何在C#里面执行.SQL脚本namespace ExecuteSqlFile
{
/// <summary>
/// DBAccess 的摘要说明。
/// </summary>
public class DBAccess
{
public DBAccess()
{
} #region 属性 private static string ConStr = ""; private static string ConString
{
get
{
if(ConStr == "")
{
try
{
XmlDocument doc = new XmlDocument();
doc.Load("ServerConfig.xml");
string userid = doc.SelectSingleNode("ServerConfig/UserId").InnerText;
string password = doc.SelectSingleNode("ServerConfig/PassWord").InnerText;
string servername = doc.SelectSingleNode("ServerConfig/ServerName").InnerText;
string database = doc.SelectSingleNode("ServerConfig/DataBase").InnerText;
ConStr = "server = " + servername + ";uid = "
+ userid + ";pwd = " + password + ";database = " + database;
}
catch(Exception ex)
{
throw ex;
}
} return ConStr;
}
} private static SqlConnection Con;
public static SqlConnection MyConnection
{
get
{
if(Con == null)
{
Con = new SqlConnection(ConString);
}
return Con;
}
}
#endregion
/// <summary>
/// 执行Sql文件
/// </summary>
/// <param name="varFileName"></param>
/// <returns></returns>
public static bool ExecuteSqlFile(string varFileName)
{
if(!File.Exists(varFileName))
{
return false;
} StreamReader sr = File.OpenText(varFileName);
ArrayList alSql = new ArrayList(); string commandText = ""; string varLine = ""; while(sr.Peek() > -1)
{
varLine = sr.ReadLine();
if(varLine == "")
{
continue;
}
if(varLine != "GO")
{
commandText += varLine;
commandText += "\r\n";
}
else
{
alSql.Add(commandText);
commandText = "";
}
}
sr.Close(); try
{
ExecuteCommand(alSql);
}
catch
{
return false;
} return true;
}
private static void ExecuteCommand(ArrayList varSqlList)
{
MyConnection.Open();
SqlTransaction varTrans = MyConnection.BeginTransaction(); SqlCommand command = new SqlCommand();
command.Connection = MyConnection;
command.Transaction = varTrans; try
{
foreach(string varcommandText in varSqlList)
{
command.CommandText = varcommandText;
command.ExecuteNonQuery();
}
varTrans.Commit();
}
catch(Exception ex)
{
varTrans.Rollback();
throw ex;
}
finally
{
MyConnection.Close();
}
}
}
}
http://blog.csdn.net/zhzuo/archive/2004/12/25/229006.aspx
命令行来执行sql脚本