跨数据库服务器执行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);

//登录链接服务器

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 into Stager.cmsdb.dbo.IncreasedChannelInfo(url)

select url from cmsposting where url is not null

上面的sql语句将数据库表cmsposting中满足条件的记录插入到链接服务器Stager的数据库实例cmsdb中的表IncreasedChannelInfo。

注：在建立链接服务器前需要判断链接服务器是否已经存在，如果已经存在，就直接操作就可以了。