SqlServer调用外部程序实现数据同步
首先创建两个数据库：SyncA是数据源，SyncB是对SyncA进行同步的数据库。 在SyncA和SyncB中分别创建Source表和Target表，实际业务中，两张表的结构大多不相同。 然后创建一个类库的项目：MySync（注意项目的版本，Sql08不支持的.net 4.0及更高版本） 下面是同
首先创建两个数据库：SyncA是数据源，SyncB是对SyncA进行同步的数据库。
在SyncA和SyncB中分别创建Source表和Target表，实际业务中，两张表的结构大多不相同。
然后创建一个类库的项目：MySync（注意项目的版本，Sql08不支持的.net 4.0及更高版本）
下面是同步程序代码：
<span>using</span><span> System;
</span><span>using</span><span> System.Data;
</span><span>using</span><span> System.Data.Sql;
</span><span>using</span><span> Microsoft.SqlServer.Server;
</span><span>using</span><span> System.Data.SqlClient;
</span><span>using</span><span> System.Data.SqlTypes;
</span><span>namespace</span><span> MySync
{
</span><span>public</span> <span>class</span><span> SyncDataBase
{<br> [SqlFunction(SystemDataAccess = SystemDataAccessKind.Read, DataAccess = DataAccessKind.Read)]
</span><span>public</span> <span>static</span> <span>string</span> Sync(<span>string</span><span> strSql)
{
</span><span>string</span> result = <span>"</span><span>true</span><span>"</span><span>;
</span><span>string</span> strConn = <span>@"</span><span>Data Source=localhost;Initial Catalog=SyncB;User ID=sa;Password=123@abc;</span><span>"</span><span>;
</span><span>try</span><span>
{
</span><span>using</span> (SqlConnection connection = <span>new</span><span> SqlConnection(strConn))
{
connection.Open();
SqlCommand command </span>= <span>new</span><span> SqlCommand(strSql, connection);
command.CommandType </span>=<span> CommandType.Text;
command.ExecuteNonQuery();
connection.Close();
}
}
</span><span>catch</span><span> (Exception ex)
{
result </span>= <span>"</span><span>false:</span><span>"</span> +<span> ex.ToString();
}
</span><span>return</span><span> result;
}
}
}</span>接下来要对类库项目进行签名，签名后编译【项目】：
启用CLR功能：默认情况下，Sql Server中的CLR是关闭的，所以我们要执行如下命令打开SyncA数据库的CLR。
<span>exec</span> sp_configure <span>'</span><span>clr enabled</span><span>'</span>,<span>1</span> <span>reconfigure</span> <span>go</span>
注册DLL：
为了调用我们写的那个方法，需要在SQL Server中注册我们刚刚编译好的那个DLL。在此之前，要知道在这个项目中如果要访问服务器之外的资源是要配置权限的。如果不配置，后面操作中会出现类似下面的错误。我找到的关于授权配置的内容：连接。
创建登录名和密钥，如果程序集有变更，要删除密钥和登录名重新创建：
<span>USE</span><span> master; </span><span>GO</span> <span>CREATE</span> ASYMMETRIC <span>KEY</span> SQLCLRSyncKey <span>FROM</span> EXECUTABLE <span>FILE</span> <span>=</span> <span>'</span><span>C:\MySync.dll</span><span>'</span> <span>CREATE</span> LOGIN SQLCLRSyncLogin <span>FROM</span> ASYMMETRIC <span>KEY</span><span> SQLCLRSyncKey </span><span>GRANT</span> EXTERNAL ACCESS ASSEMBLY <span>TO</span><span> SQLCLRSyncLogin; </span><span>GO</span>
<span>DROP</span><span> LOGIN SQLCLRSyncLogin </span><span>DROP</span> ASYMMETRIC <span>KEY</span> SQLCLRSyncKey
创建程序集，DLL变更后要删除重新创建：
<span>USE</span><span> SyncA; </span><span>GO</span> <span>create</span><span> ASSEMBLY MySync </span><span>FROM</span> <span>'</span><span>C:\MySync.dll</span><span>'</span> <span>WITH</span> PERMISSION_SET <span>=</span><span> EXTERNAL_ACCESS; </span><span>GO</span>
然后创建一个函数用于调用这个DLL：
<span>CREATE</span> <span>FUNCTION</span><span> dbo.fun_sync
(
</span><span>@strSql</span> <span>nvarchar</span>(<span>max</span><span>)
)
</span><span>RETURNS</span> <span>nvarchar</span>(<span>max</span><span>)
</span><span>AS</span> EXTERNAL NAME <span>[</span><span>MySync</span><span>]</span>.<span>[</span><span>MySync.SyncDataBase</span><span>]</span>.<span>[</span><span>Sync</span><span>]</span> 先来测试一下，在SyncA中执行查询：
<span>SELECT</span> dbo.fun_sync(<span>'</span><span>insert into Target(Id,Name,SyncTime) values (null,null,getdate())</span><span>'</span>)
SyncB中添加了一条数据：
下面使用触发器自动的从SyncA中将数据同步到SyncB中，其中的tt表是我临时创建的，用于保存触发器调用返回的结果：
<span>create</span> <span>Trigger</span><span> tr_source </span><span>on</span> <span>[</span><span>Source</span><span>]</span> <span>for</span> <span>INSERT</span> <span>AS</span> <span>begin</span> <span>declare</span> <span>@strSql</span> <span>nvarchar</span>(<span>max</span><span>) </span><span>select</span> <span>@strSql</span><span>=</span><span>'</span><span>insert into Target(Id,Name,SyncTime) values (</span><span>'''</span><span>+</span><span>cast</span>(Id <span>as</span> <span>nvarchar</span>)<span>+</span><span>'''</span><span>,</span><span>'''</span><span>+</span>Title<span>+</span><span>'''</span><span>,getdate())</span><span>'</span> <span>from</span><span> inserted </span><span>--</span><span>执行</span> <span>declare</span> <span>@result</span> <span>nvarchar</span>(<span>max</span><span>) </span><span>select</span> <span>@result</span><span>=</span>dbo.fun_sync(<span>@strSql</span><span>) </span><span>insert</span> <span>into</span> tt(tt) <span>values</span> (<span>@result</span><span>) </span><span>end</span>
直接执行函数没有问题，但是触发器去调用函数执行却出现异常：
<span>false:System.Data.SqlClient.SqlException: 其他会话正在使用事务的上下文。 在 System.Data.SqlClient.SqlConnection.OnError(SqlException exception, Boolean breakConnection) 在 System.Data.SqlClient.SqlInternalConnection.OnError(SqlException exception, Boolean breakConnection) 在 System.Data.SqlClient.TdsParser.ThrowExceptionAndWarning(TdsParserStateObject stateObj) 在 System.Data.SqlClient.TdsParser.Run(RunBehavior runBehavior, SqlCommand cmdHandler, SqlDataReader dataStream, BulkCopySimpleResultSet bulkCopyHandler, TdsParserStateObject stateObj) 在 System.Data.SqlClient.TdsParser.TdsExecuteTransactionManagerRequest(Byte[] buffer, TransactionManagerRequestType request, String transactionName, TransactionManagerIsolationLevel isoLevel, Int32 timeout, SqlInternalTransaction transaction, TdsParserStateObject stateObj, Boolean isDelegateControlRequest) 在 System.Data.SqlClient.SqlInternalConnectionTds.PropagateTransactionCookie(Byte[] cookie) 在 System.Data.SqlClient.SqlInternalConnection.EnlistNonNull(Transaction tx) 在 System.Data.SqlClient.SqlInternalConnection.Enlist(Transaction tx) 在 System.Data.SqlClient.SqlInternalConnectionTds.Activate(Transaction transaction) 在 System.Data.ProviderBase.DbConnectionInternal.ActivateConnection(Transaction transaction) 在 System.Data.ProviderBase.DbConnectionPool.GetConnection(DbConnection owningObject) 在 System.Data.ProviderBase.DbConnectionFactory.GetConnection(DbConnection owningConnection) 在 System.Data.ProviderBase.DbConnectionClosed.OpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory) 在 System.Data.SqlClient.SqlConnection.Open() 在 MySync.SyncDataBase.Sync(String strSql)</span>
这个错误中包含了一个false值，说明触发器调用时已经可以走到DLL这一步了。考虑到在查询中直接执行函数，走到DLL这一步是没有错误的。那么错误就发生在触发器和DLL调用产生的冲突，冲突在访问数据库上面，再深入的原因，我也没有找到。
下面使用另外一种方式实现同步，因为错误是触发器和DLL的数据库访问冲突，那么我就绕过数据库的访问。将触发器产生的SQL脚本保存到某个目录下面，然后通过其他程序监听这个目录，执行脚本文件，实现同步。
类库代码
<span>using</span><span> System;
</span><span>using</span><span> System.Data;
</span><span>using</span><span> System.Data.Sql;
</span><span>using</span><span> Microsoft.SqlServer.Server;
</span><span>using</span><span> System.Data.SqlClient;
</span><span>using</span><span> System.Data.SqlTypes;
</span><span>using</span><span> System.IO;
</span><span>namespace</span><span> MySync
{
</span><span>public</span> <span>class</span><span> SyncDataBase
{
[SqlFunction(SystemDataAccess </span>= SystemDataAccessKind.Read, DataAccess =<span> DataAccessKind.Read)]
</span><span>public</span> <span>static</span> <span>string</span> Sync(<span>string</span><span> strSql)
{
</span><span>string</span> result = <span>"</span><span>true</span><span>"</span><span>;
</span><span>try</span><span>
{
</span><span>if</span> (!Directory.Exists(<span>"</span><span>c:\\SyncLog</span><span>"</span><span>))
{
Directory.CreateDirectory(</span><span>"</span><span>c:\\SyncLog</span><span>"</span><span>);
}
</span><span>string</span> fileName = <span>@"</span><span>c:\\SyncLog\\</span><span>"</span> + DateTime.Now.ToString(<span>"</span><span>yyyyMMddHHmmss</span><span>"</span>) + <span>"</span><span>.txt</span><span>"</span><span>;
</span><span>if</span> (<span>File.Exists(fileName))
File.Delete(fileName);
</span><span>using</span> (StreamWriter sw =<span> File.CreateText(fileName))
{
sw.WriteLine(strSql);
}
}
</span><span>catch</span><span> (Exception ex)
{
result </span>= <span>"</span><span>false:</span><span>"</span> +<span> ex.ToString();
}
</span><span>return</span><span> result;
}
}
}</span>另外创建一个监听程序：MyListen
<span>using</span><span> System;
</span><span>using</span><span> System.Data;
</span><span>using</span><span> System.Data.Sql;
</span><span>using</span><span> System.Data.SqlClient;
</span><span>using</span><span> System.Data.SqlTypes;
</span><span>using</span><span> System.Configuration;
</span><span>using</span><span> System.Threading;
</span><span>using</span><span> System.IO;
</span><span>namespace</span><span> MyListen
{
</span><span>class</span><span> Program
{
</span><span>static</span> <span>void</span> Main(<span>string</span><span>[] args)
{
</span><span>string</span> connSync = ConfigurationManager.ConnectionStrings[<span>"</span><span>connSync</span><span>"</span><span>].ToString();
</span><span>string</span> filePath = ConfigurationManager.AppSettings[<span>"</span><span>filePath</span><span>"</span><span>];
</span><span>while</span> (<span>true</span><span>)
{
</span><span>//</span><span>所有txt文件</span>
<span>string</span>[] fileList = DirFile.GetFileNames(filePath, <span>"</span><span>*.txt</span><span>"</span>, <span>true</span><span>);
</span><span>foreach</span> (<span>var</span> f <span>in</span><span> fileList)
{
</span><span>string</span> strSql = <span>""</span><span>;
</span><span>using</span> (StreamReader sr = <span>new</span><span> StreamReader(f))
{
</span><span>string</span><span> line;
</span><span>while</span> ((line = sr.ReadLine()) != <span>null</span><span>)
{
strSql </span>+= line + <span>"</span> <span>"</span><span>;
}
sr.Close();
}
</span><span>try</span><span>
{
</span><span>using</span> (SqlConnection connection = <span>new</span><span> SqlConnection(connSync))
{
connection.Open();
SqlCommand command </span>= <span>new</span><span> SqlCommand(strSql, connection);
command.CommandType </span>=<span> CommandType.Text;
command.ExecuteNonQuery();
connection.Close();
}
}
</span><span>catch</span><span> (Exception ex)
{
Console.WriteLine(ex.ToString());
}
File.Delete(f);
}
</span><span>//</span><span>每10秒扫描一次</span>
Thread.Sleep(<span>5</span> * <span>1000</span><span>);
}
}
}
}</span>只要将监听程序打开，就可以实现对数据的同步。项目和数据库下载。
参考：
http://msdn.microsoft.com/zh-cn/library/Microsoft.SqlServer.Server.SqlFunctionAttribute_properties(v=vs.100).aspx
http://blog.sina.com.cn/s/blog_59c41d0d0100esjn.html
http://www.cnblogs.com/wshcn/archive/2011/12/02/2271630.html
http://www.cnblogs.com/edong/archive/2010/03/10/1682172.html
http://www.cnblogs.com/hsrzyn/archive/2013/05/28/1976555.html
핫 AI 도구
Undresser.AI Undress
사실적인 누드 사진을 만들기 위한 AI 기반 앱
AI Clothes Remover
사진에서 옷을 제거하는 온라인 AI 도구입니다.
Undress AI Tool
무료로 이미지를 벗다
Clothoff.io
AI 옷 제거제
Video Face Swap
완전히 무료인 AI 얼굴 교환 도구를 사용하여 모든 비디오의 얼굴을 쉽게 바꾸세요!
인기 기사
뜨거운 도구
메모장++7.3.1
사용하기 쉬운 무료 코드 편집기
SublimeText3 중국어 버전
중국어 버전, 사용하기 매우 쉽습니다.
스튜디오 13.0.1 보내기
강력한 PHP 통합 개발 환경
드림위버 CS6
시각적 웹 개발 도구
SublimeText3 Mac 버전
신 수준의 코드 편집 소프트웨어(SublimeText3)
iPhone에서 Google 지도를 기본 지도로 설정하는 방법
Apr 17, 2024 pm 07:34 PM
iPhone의 기본 지도는 Apple의 독점 위치 정보 제공업체인 지도입니다. 지도가 점점 좋아지고 있지만 미국 이외의 지역에서는 잘 작동하지 않습니다. Google 지도와 비교하면 아무것도 제공할 수 없습니다. 이 기사에서는 Google 지도를 사용하여 iPhone의 기본 지도로 만드는 실행 가능한 단계에 대해 설명합니다. iPhone에서 Google 지도를 기본 지도로 설정하는 방법 Google 지도를 휴대전화의 기본 지도 앱으로 설정하는 것은 생각보다 쉽습니다. 아래 단계를 따르십시오. – 전제 조건 단계 – 휴대폰에 Gmail이 설치되어 있어야 합니다. 1단계 – AppStore를 엽니다. 2단계 – “Gmail”을 검색하세요. 3단계 - Gmail 앱 옆을 클릭하세요.
mdf 파일을 sqlserver로 가져오는 방법
Apr 08, 2024 am 11:41 AM
가져오기 단계는 다음과 같습니다. MDF 파일을 SQL Server의 데이터 디렉터리(일반적으로 C:\Program Files\Microsoft SQL Server\MSSQL\DATA)에 복사합니다. SSMS(SQL Server Management Studio)에서 데이터베이스를 열고 연결을 선택합니다. 추가 버튼을 클릭하고 MDF 파일을 선택합니다. 데이터베이스 이름을 확인하고 확인 버튼을 클릭합니다.
sqlserver 데이터베이스에 이름이 지정된 개체가 이미 존재하는 문제를 해결하는 방법
Apr 05, 2024 pm 09:42 PM
SQL Server 데이터베이스에 이미 존재하는 동일한 이름을 가진 개체의 경우 다음 단계를 수행해야 합니다. 개체 유형(테이블, 뷰, 저장 프로시저)을 확인합니다. IF NOT EXISTS를 사용하면 객체가 비어 있는 경우 생성을 건너뛸 수 있습니다. 개체에 데이터가 있는 경우 다른 이름을 사용하거나 구조를 수정하세요. 기존 개체를 삭제하려면 DROP을 사용하세요. 주의하세요. 백업을 권장합니다. 삭제되거나 이름이 바뀐 개체에 대한 참조가 없는지 확인하려면 스키마 변경 사항을 확인하세요.
iPhone에 시계 앱이 없습니다. 해결 방법
May 03, 2024 pm 09:19 PM
휴대폰에 시계 앱이 없나요? 날짜와 시간은 iPhone의 상태 표시줄에 계속 표시됩니다. 그러나 시계 앱이 없으면 세계 시계, 스톱워치, 알람 시계 및 기타 여러 기능을 사용할 수 없습니다. 따라서 누락된 시계 앱을 수정하는 것이 해야 할 일 목록의 맨 위에 있어야 합니다. 이러한 솔루션은 이 문제를 해결하는 데 도움이 될 수 있습니다. 수정 1 - 시계 앱 배치 실수로 홈 화면에서 시계 앱을 제거한 경우 시계 앱을 다시 제자리에 배치할 수 있습니다. 1단계 – iPhone을 잠금 해제하고 앱 라이브러리 페이지에 도달할 때까지 왼쪽으로 스와이프합니다. 2단계 – 다음으로 검색창에 “시계”를 검색하세요. 3단계 – 검색 결과 아래에 “시계”가 표시되면 길게 누르고
sqlserver에서 실수로 삭제한 데이터베이스를 복구하는 방법
Apr 05, 2024 pm 10:39 PM
실수로 SQL Server 데이터베이스를 삭제한 경우 다음 단계를 수행하여 복구할 수 있습니다. 데이터베이스 활동 중지, 데이터베이스 로그 확인, 백업에서 복원, DBCC CHECKDB 사용 파티 도구. 데이터 손실을 방지하려면 데이터베이스를 정기적으로 백업하고 트랜잭션 로깅을 활성화하십시오.
sqlserver 포트번호 확인하는 방법
Apr 05, 2024 pm 09:57 PM
SQL Server 포트 번호를 보려면 SSMS를 열고 서버에 연결합니다. 개체 탐색기에서 서버 이름을 찾아 마우스 오른쪽 단추로 클릭하고 속성을 선택합니다. 연결 탭에서 TCP 포트 필드를 확인하세요.
sqlserver 서비스를 시작할 수 없는 경우 수행할 작업
Apr 05, 2024 pm 10:00 PM
SQL Server 서비스가 시작되지 않는 경우 해결해야 할 몇 가지 단계는 다음과 같습니다. 오류 로그를 확인하여 근본 원인을 확인합니다. 서비스 계정에 서비스를 시작할 수 있는 권한이 있는지 확인하세요. 종속성 서비스가 실행 중인지 확인하세요. 바이러스 백신 소프트웨어를 비활성화합니다. SQL Server 설치를 복구합니다. 복구가 작동하지 않으면 SQL Server를 다시 설치하십시오.
iPhone의 느린 셀룰러 데이터 인터넷 속도: 수정 사항
May 03, 2024 pm 09:01 PM
지연이 발생하고 iPhone의 모바일 데이터 연결 속도가 느립니까? 일반적으로 휴대폰의 셀룰러 인터넷 강도는 지역, 셀룰러 네트워크 유형, 로밍 유형 등과 같은 여러 요소에 따라 달라집니다. 더 빠르고 안정적인 셀룰러 인터넷 연결을 얻기 위해 할 수 있는 일이 몇 가지 있습니다. 수정 1 – iPhone 강제 다시 시작 때로는 장치를 강제로 다시 시작하면 셀룰러 연결을 포함한 많은 항목이 재설정됩니다. 1단계 – 볼륨 높이기 키를 한 번 눌렀다가 놓습니다. 그런 다음 볼륨 작게 키를 눌렀다가 다시 놓습니다. 2단계 - 프로세스의 다음 부분은 오른쪽에 있는 버튼을 누르는 것입니다. iPhone이 다시 시작되도록 하세요. 셀룰러 데이터를 활성화하고 네트워크 속도를 확인하세요. 다시 확인하세요 수정 2 – 데이터 모드 변경 5G는 더 나은 네트워크 속도를 제공하지만 신호가 약할 때 더 잘 작동합니다
