в 15:31, 26 мая 2010

2010-05-26T15:31:02Z

Admin: 1 версия

2010-05-26T12:06:20Z

1 версия

Новая страница

==Query Notifications==

<source lang="csharp">
#include "stdafx.h"
using namespace System;
using namespace System::Data;
using namespace System::Threading;
using namespace System::Data::SqlClient;
ref class MyNotification
{
public:
MyNotification(String^ connectionString, String^ sql)
{
ConnectionString = connectionString;
Sql = sql;
SqlDependency::Start(ConnectionString);
SyncHandle = gcnew AutoResetEvent(true);
ChargeNotification();
}
void OnChangedHandler(Object^ caller, SqlNotificationEventArgs^ e)
{
if ( e->Source == SqlNotificationSource::Data &&
e->Type == SqlNotificationType::Change &&
(e->Info == SqlNotificationInfo::Delete ||
e->Info == SqlNotificationInfo::Insert ||
e->Info == SqlNotificationInfo::Update) ){
Console::WriteLine(e->Info.ToString());
ChargeNotification();
}
}
void ChargeNotification()
{
SqlConnection^ connection = gcnew SqlConnection(ConnectionString);
connection->Open();
SqlCommand^ WatchCommand = gcnew SqlCommand(Sql, connection);
SqlDependency^ myDependency = gcnew SqlDependency(WatchCommand);
myDependency->OnChange += gcnew OnChangeEventHandler(this, &MyNotification::OnChangedHandler);
SqlDataReader^ myReader = WatchCommand->ExecuteReader();
myReader->Close();
SyncHandle->Set();
}
void Wait()
{
SyncHandle->Reset();
SyncHandle->WaitOne();
}
String^ ConnectionString;
String^ Sql;
AutoResetEvent^ SyncHandle;
};
void main()
{
SqlConnection^ myConnection = nullptr;
SqlConnectionStringBuilder^ connectionBuilder = gcnew SqlConnectionStringBuilder();
connectionBuilder->DataSource = "localhost\\sqlexpress";
connectionBuilder->InitialCatalog = "myCatalog";
connectionBuilder->IntegratedSecurity = true;
myConnection = gcnew SqlConnection(connectionBuilder->ToString());
myConnection->Open();

MyNotification^ commandNotification = gcnew MyNotification(myConnection->ConnectionString,"SELECT ID, Song FROM dbo.Music");
SqlCommand^ testCommand = gcnew SqlCommand("INSERT INTO Music(Song) VALUES("T")",myConnection);
testCommand->ExecuteNonQuery();
commandNotification->Wait();
testCommand->CommandText ="UPDATE Music SET Song="T" WHERE Song="T"";
testCommand->ExecuteNonQuery();
commandNotification->Wait();
testCommand->CommandText = "DELETE FROM Music WHERE Song="T"";
testCommand->ExecuteNonQuery();
commandNotification->Wait();
myConnection->Close();
}

</source>

← Предыдущая	Версия 15:31, 26 мая 2010
(нет различий)

Visual C++ .NET/Database ADO.net/SqlDependency - История изменений

в 15:31, 26 мая 2010

Admin: 1 версия