原文:
SQL Server編程系列(2):SMO常用對象的有關操作
上圖是一個完整的涉及到各種關系的結構圖。不過它們之間的層次結構關系周公已經在上一篇做了簡單概述。
在本篇中周公還是在上一篇的基礎上再做稍微深入一點的介紹,在本篇中主要講述如何獲取數據庫常見對象信息,并且如何利用SMO來進行一些日常操作:如創建Login,創建數據庫、備份數據庫和還原數據庫。執行上面這些操作的SQL語句也許我們已經寫過,下面我們來看看利用SMO來操作的代碼將如何寫。為了便于理解,在代碼中的注釋比較詳盡,所以本篇中代碼之外的講解就不多了。 另外,需要注意的是SMO的dll的版本隨著升級變化比較大,這一點不同.NET Framework,沒有考慮向下兼容。
代碼如下:
2012-05-23
周公
在上一篇周公簡單講述了SMO的一些基本概念,實際上SMO體系結構遠不止周公在上一篇中講述的那么簡單,下圖是MSDN上給出的一個完整的結構圖:
|
|
|
|
在本篇中周公還是在上一篇的基礎上再做稍微深入一點的介紹,在本篇中主要講述如何獲取數據庫常見對象信息,并且如何利用SMO來進行一些日常操作:如創建Login,創建數據庫、備份數據庫和還原數據庫。執行上面這些操作的SQL語句也許我們已經寫過,下面我們來看看利用SMO來操作的代碼將如何寫。為了便于理解,在代碼中的注釋比較詳盡,所以本篇中代碼之外的講解就不多了。 另外,需要注意的是SMO的dll的版本隨著升級變化比較大,這一點不同.NET Framework,沒有考慮向下兼容。
代碼如下:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Microsoft.SqlServer.Management.Smo.RegisteredServers;//在microsoft.sqlserver.smo.dll中
using Microsoft.SqlServer.Management.Smo;//需添加microsoft.sqlserver.smo.dll的引用
using Microsoft.SqlServer.Management.Common;//需添加microsoft.sqlserver.connectioninfo.dll的引用
namespace SSISStudy
{
/// <summary>
/// SQL Server編程些列文章(2):SMO常用對象的有關操作
/// 作者:周公
/// 創建日期:2012-05-23
/// 博客地址:http://blog.csdn.net/zhoufoxcn http://zhoufoxcn.blog.51cto.com
/// 新浪微博地址:http://weibo.com/zhoufoxcn
class SMODemo02
{
/// <summary>
/// 顯示數據庫常見對象信息示例,本方法中的代碼只針對9.0版本的SMO dll(SQL2005附帶程序集)
/// </summary>
public static void ShowSMOObjects()
{
Console.WriteLine("Server Group Information");
foreach (ServerGroup serverGroup in SmoApplication.SqlServerRegistrations.ServerGroups)
{
Console.WriteLine("Group Name:{0},Path:{1},ServerType:{2},State:{3},Urn:{4}", serverGroup.Name, serverGroup.Path, serverGroup.ServerType, serverGroup.State, serverGroup.Urn);
}
Console.WriteLine("Registered Server Information");
foreach (RegisteredServer regServer in SmoApplication.SqlServerRegistrations.RegisteredServers)
{
Console.WriteLine("Server Name:{0},Login:{1},State:{2},Urn:{3}", regServer.Name, regServer.Login, regServer.State, regServer.Urn);
}
//創建ServerConnection的實例
ServerConnection connection = new ServerConnection();
//指定連接字符串
connection.ConnectionString = "Data Source=goodapp;Initial Catalog=master;User ID=sa;Password=root;";
//實例化Server
Server server = new Server(connection);
Console.WriteLine("ActiveDirectory:{0},InstanceName:{1}", server.ActiveDirectory, server.InstanceName);
//下面列出每個數據庫的具體信息
foreach (Database db in server.Databases)
{
Console.WriteLine("Database Name:{0},ActiveDirectory:{1},ActiveConnections:{2},DataSpaceUsage:{3},PrimaryFilePath:{4}", db.Name, db.ActiveDirectory, db.ActiveConnections, db.DataSpaceUsage, db.PrimaryFilePath);
//列出數據庫的數據文件文件組信息
foreach (FileGroup fileGroup in db.FileGroups)
{
Console.WriteLine("\tFileGroup Name:{0},Size:{1},State:{2},Urn:{3}", fileGroup.Name, fileGroup.Size, fileGroup.State, fileGroup.Urn);
//列出每個文件組中的數據文件信息
foreach (DataFile dataFile in fileGroup.Files)
{
Console.WriteLine("\t\tDataFile Name:{0},Size:{1},State:{2},Urn:{3},FileName:{4}", dataFile.Name, dataFile.Size, dataFile.State, dataFile.Urn, dataFile.FileName);
}
}
//列出數據庫日志文件信息
foreach (LogFile logFile in db.LogFiles)
{
Console.WriteLine("\tLogFile Name:{0},Size:{1},State:{2},Urn:{3},FileName:{4}", logFile.Name, logFile.Size, logFile.State,logFile.Urn,logFile.FileName);
}
}
}
/// <summary>
/// 利用SMO創建SQL登錄
/// </summary>
public static void CreateLogin()
{
string loginName = "zhoufoxcn";//要創建的數據庫登錄名
string loginPassword = "C#.NET";//登錄密碼
//創建ServerConnection的實例
ServerConnection connection = new ServerConnection();
//指定連接字符串
connection.ConnectionString = "Data Source=goodapp;Initial Catalog=master;User ID=sa;Password=root;";
//實例化Server
Server server = new Server(connection);
#region [創建數據庫登錄對象]
//檢查在數據庫是否已經存在該登錄名
var queryLogin = from Login temp in server.Logins
where string.Equals(temp.Name, loginName, StringComparison.CurrentCultureIgnoreCase)
select temp;
Login login = queryLogin.FirstOrDefault<Login>();
//如果存在就刪除
if (login != null)
{
login.Drop();
}
login = new Login(server, loginName);
login.LoginType = LoginType.SqlLogin;//指定登錄方式為SQL認證
login.PasswordPolicyEnforced = true;
login.DefaultDatabase = "master";//默認數據庫
login.Create(loginPassword);
#endregion
}
/// <summary>
/// 利用SMO創建數據庫
/// </summary>
public static void CreateDatabase()
{
string databaseName = "SMODemo";
//創建ServerConnection的實例
ServerConnection connection = new ServerConnection();
//指定連接字符串
connection.ConnectionString = "Data Source=goodapp;Initial Catalog=master;User ID=sa;Password=root;";
//實例化Server
Server server = new Server(connection);
#region [創建數據庫對象]
//檢查在數據庫是否已經存在該數據庫
var queryDatabase = from Database temp in server.Databases
where string.Equals(temp.Name, databaseName, StringComparison.CurrentCultureIgnoreCase)
select temp;
Database database = queryDatabase.FirstOrDefault<Database>();
//如果存在就刪除
if (database != null)
{
database.Drop();
}
database = new Database(server, databaseName);
//指定數據庫數據文件細節
FileGroup fileGroup = new FileGroup { Name = "PRIMARY", Parent = database, IsDefault = true };
DataFile dataFile = new DataFile
{
Name = databaseName + "_data",
Parent = fileGroup,
FileName = @"F:\SQLData2005\" + databaseName + ".mdf"
};
fileGroup.Files.Add(dataFile);
//指定數據庫日志文件細節
LogFile logFile = new LogFile
{
Name = databaseName + "_log",
Parent = database,
FileName = @"F:\SQLData2005\" + databaseName + ".ldf"
};
database.FileGroups.Add(fileGroup);
database.LogFiles.Add(logFile);
database.Create();
#endregion
}
/// <summary>
/// 利用SMO備份數據庫
/// </summary>
public static void BackupDatabase()
{
string databaseName = "msdb";//備份的數據庫名
string bkPath = @"C:\";//存放備份后的數據的文件夾
//創建ServerConnection的實例
ServerConnection connection = new ServerConnection();
//指定連接字符串
connection.ConnectionString = "Data Source=goodapp;Initial Catalog=master;User ID=sa;Password=root;";
//實例化Server
Server server = new Server(connection);
#region [創建數據庫備份對象]
Backup backup = new Backup();
backup.Action = BackupActionType.Database;//完全備份
backup.Database = databaseName;
backup.BackupSetDescription = "Full backup of master";
backup.BackupSetName = "master Backup";
//創建備份設備
BackupDeviceItem bkDeviceItem = new BackupDeviceItem();
bkDeviceItem.DeviceType = DeviceType.File;
bkDeviceItem.Name = bkPath+databaseName+".bak";
backup.Devices.Add(bkDeviceItem);
backup.Incremental = false;
backup.LogTruncation = BackupTruncateLogType.Truncate;
backup.SqlBackup(server);
#endregion
}
/// <summary>
/// 備份數據庫
/// </summary>
public static void RestoreDatabase()
{
string databaseName = "SMODemo";//備份的數據庫名
string bkPath = @"C:\";//存放備份后的數據的文件夾
//創建ServerConnection的實例
ServerConnection connection = new ServerConnection();
//指定連接字符串
connection.ConnectionString = "Data Source=goodapp;Initial Catalog=master;User ID=sa;Password=root;";
//實例化Server
Server server = new Server(connection);
Restore restore = new Restore();
restore.NoRecovery = false;
restore.NoRewind = false;
restore.Action = RestoreActionType.Database;
restore.Database = databaseName;
//創建備份設備
BackupDeviceItem bkDeviceItem = new BackupDeviceItem();
bkDeviceItem.DeviceType = DeviceType.File;
bkDeviceItem.Name = bkPath + databaseName + ".bak";
//如果需要重新制定Restore后的數據庫的物理文件位置,需要知道數據庫文件的邏輯文件名
//可以RESTORE FILELISTONLY 來列出邏輯文件名,如果覆蓋已有數據庫可以通過SMO來獲取
//因本處使用的是剛剛備份的msdb數據庫來Restore,所以其分別為"MSDBData"和"MSDBLog"
//如果不指定Restore路徑則默認恢復到數據庫服務器存放數據的文件夾下
RelocateFile relocateDataFile = new RelocateFile { LogicalFileName = "MSDBData", PhysicalFileName = bkPath + databaseName + ".mdf" };//(databaseName + "_data", bkPath + databaseName + ".mdf");
RelocateFile relocateLogFile = new RelocateFile { LogicalFileName = "MSDBLog", PhysicalFileName = bkPath + databaseName + ".ldf" };//(databaseName + "_log", bkPath + databaseName + ".ldf");
restore.Devices.Add(bkDeviceItem);
restore.RelocateFiles.Add(relocateDataFile);
restore.RelocateFiles.Add(relocateLogFile);
restore.SqlRestore(server);
}
}
}
執行結果在這里就不貼圖了,反正是是在周公家里的中文環境和辦公室英文環境中測試通過。預先透漏一下,下一篇將講述如何獲取SQL Server的對象的創建SQL語句,比如表、存儲過程、函數等。
2012-05-23
周公
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索:z360901061
微信掃一掃加我為好友
QQ號聯系: 360901061
您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對您有幫助就好】元

