.cs文件
using System;
using System.Xml;
using System.Data;
using System.IO;
using System.Collections;
using System.Data.SqlClient;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();
}
}
}
}
using System;
using System.Xml;
using System.Data;
using System.IO;
using System.Collections;
using System.Data.SqlClient;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();
}
}
}
}
解决方案 »
- ajax的基础问题
- ASP.NET MVC 3.0 Razor中呈现多个实体对象
- asp.net预防浏览器缓存问题?高手请进
- 100分求解决问题: SQL contains的用法
- 其实很不理解很多人的做法!既然有 FileUpload1.SaveAs
- 关于无限级分类~
- The remote name could not be resolved: 'www.baidu.com'
- 没办法又来了,分不多了,我不是菜鸟,想请高手看看这个问题!
- 关于设置服务器的问题
- 多个dropdownlist回车处理问题
- Forms身份验证的怪问题
- 分页,想阿里吧吧里的静态分页技术是怎么实现的!!!!!!!!!!!!!
<ServerConfig>
<ServerName>localhost</ServerName>
<DataBase>tttttt</DataBase>
<UserId>sa</UserId>
<PassWord>sa</PassWord>
</ServerConfig>
drop table [dbo].[Forum_Users_Class]
GOif exists (select * from dbo.sysobjects where id = object_id(N'[dbo].[Forum_Users_Config]') and OBJECTPROPERTY(id, N'IsUserTable') = 1)
drop table [dbo].[Forum_Users_Config]
GOCREATE TABLE [dbo].[Address] (
[ip1] [float] NULL ,
[ip2] [float] NULL ,
[country] [nvarchar] (50) COLLATE Chinese_PRC_CI_AS NULL ,
[city] [nvarchar] (50) COLLATE Chinese_PRC_CI_AS NULL
) ON [PRIMARY]
GOCREATE TABLE [dbo].[Forum_Admin] (
[Forum_Admin_Id] [int] NOT NULL ,
[Forum_Admin_Name] [nvarchar] (255) COLLATE Chinese_PRC_CI_AS NULL ,
[Forum_Admin_Pwd] [nvarchar] (255) COLLATE Chinese_PRC_CI_AS NULL ,
[Isdel] [nvarchar] (1) COLLATE Chinese_PRC_CI_AS NULL
) ON [PRIMARY]
GO.....
可导入结构
你说的那个当然是可以的,问题在于要做什么用处,在cmd里面输入osql回车,方法列的很详细,如果我要在一台没有安装SqlServer的机器上进行一些操作呢?
那是你的顺序不对导致的问题
没有表呢
怎么创建视图和存储过程