跨数据库服务器执⾏sql语句
在某些场合中。需要涉及到跨数据库服务器的两个数据库实例间进⾏数据操作，在这种场合下，可以使
⽤sp_addlinkedserver和sp_addlinkedsrvlogin这两个SQL SERVER⾃带的存储过程在某⼀台SQL SERVER数据库服务器上建⽴链接服务器。建⽴好链接服务器，对另⼀个SQL SERVER的操作就和操作本地数据库⼀样，待使⽤完后，⽤存储过程sp_dropserver释放链接服务器即可。
1.建⽴链接服务器和登录链接服务器。
///<summary>
///建⽴和登录链接服务器
///</summary>
private static void CreateLinkedServer()
{
string server = "数据库服务器主机名";
string user = "登录数据库⽤⽤户名";
string pwd = "登录数据库⽤密码";
//建⽴链接服务器
IParam[] paras = new DBParam[4];
for (int i = 0; i < paras.Length; i++)
{
paras[i] = new DBParam();
}
paras[0].ParameterName = "server";
paras[0].Value = "Stager";
paras[1].ParameterName = "srvproduct";
paras[1].Value = "";
paras[2].ParameterName = "provider";
paras[2].Value = "SQLOLEDB";
paras[3].ParameterName = "datasrc";
paras[3].Value = server;
string sql = @"sp_addlinkedserver";
mcmsDao.ExecuteNonCmd(sql, CommandType.StoredProcedure, paras);
//登录链接服务器sql存储过程实例
IParam[] paras2 = new DBParam[5];
for (int i = 0; i < paras2.Length; i++)
{
paras2[i] = new DBParam();
}
paras2[0].ParameterName = "rmtsrvname";
paras2[0].Value = "Stager";
paras2[1].ParameterName = "useself";
paras2[1].Value = "false";
paras2[2].ParameterName = "locallogin";
paras2[2].Value = null;
paras2[3].ParameterName = "rmtuser";
paras2[3].Value = user;
paras2[4].ParameterName = "rmtpassword";
paras2[4].Value = pwd;
string sql2 = @"sp_addlinkedsrvlogin";
mcmsDao.ExecuteNonCmd(sql2, CommandType.StoredProcedure, paras2);
}
2.释放链接服务器。
///<summary>
///删除链接服务器
///</summary>
private static void DropLinkedServer()
{
//删除链接服务器
IParam[] paras = new DBParam[2];
for (int i = 0; i < paras.Length; i++)
{
paras[i] = new DBParam();
}
paras[0].ParameterName = "server";
paras[0].Value = "Stager";
paras[1].ParameterName = "droplogins";
paras[1].Value = "droplogins";
string sql = @"sp_dropserver";
mcmsDao.ExecuteNonCmd(sql, CommandType.StoredProcedure, paras);
}
3.判断链接服务器是否存在
///<summary>
///判断链接服务器是否存在
///</summary>
///<returns></returns>
private static bool HasLinkedServerExists()
{
string sql = "select * from master.dbo.sysservers where srvname = 'Stager'";
object num = mcmsDao.ExecuteScalar(sql, CommandType.Text);
if (num == null)
{
return false;
}
return true;
}
4.使⽤⽅法。
insert sdb.dbo.IncreasedChannelInfo(url)
select url from cmsposting where url is not null
上⾯的sql语句将数据库表cmsposting中满⾜条件的记录插⼊到链接服务器Stager的数据库实例cmsdb中的表IncreasedChannelInfo。
注：在建⽴链接服务器前需要判断链接服务器是否已经存在，如果已经存在，就直接操作就可以了。

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。