Forum
Bildirimler
Hepsini Temizle
Yazılım Genel
12
Yazılar
3
Üyeler
0
Reactions
1,100
Görüntüleme
Konu başlatıcı
Merhaba arkadaşlar,
c# (windows form uygulaması) da geliştirdiğim projemde şunu yapmak istiyorum.Veritabanındaki bir tabloda insert işlemi yapıldığı anda veritabanına bağlı bulunan tüm client lara tablodaki kayıt sayısını göndersin.Client tarafına bir timer koyup sürekli sorgulama yapılabilir belki ama çok sağlıklı bir çözüm değil çünkü 1 2 sn bir kontrol etmesi gerekecek.Bunun yerine triger ile insert anında sayıyı hesaplayabilirim ancak bunu tüm client lara nasıl göndereceğim ve client tarafında bunu nasıl yakalacağım.Veritabnım Mysql.
yardımlarınızı bekliyorum.
Gönderildi : 13/05/2015 18:17
Bunun icin soket programlama yapmaniz gerekli gibi sizin adiniza db yi dinleyecek bi server olmali ve o server ayni anda clientlarla iletisimde olmali ve gelen datayi otomatik clientlara basmali c# socket konusunu biraz inceleyebilirsiniz
saygilarimla
web olsa signalR gibi client side yada server side codlar mevcut ama winformda socket kullanabilirsiniz
ProfectSoft Yazılım ve Danışmanlık Hizmetleri
LogPusher & Bifyou E-Commerce System
www.profectsoft.com
Gönderildi : 14/05/2015 19:11
Konu başlatıcı
çok teşekkür ederim.Nasıl yapabilirim bir araştırayım...
Gönderildi : 14/05/2015 20:31
sunlar da isinize yarayabilir
https://msdn.microsoft.com/en-us/library/w89fhyex(v=vs.110).aspx
https://msdn.microsoft.com/en-us/library/bew39x2a(v=vs.110).aspx
http://www.codeproject.com/Articles/10649/An-Introduction-to-Socket-Programming-in-NET-using
Saygilar
ProfectSoft Yazılım ve Danışmanlık Hizmetleri
LogPusher & Bifyou E-Commerce System
www.profectsoft.com
Gönderildi : 14/05/2015 20:39
Konu başlatıcı
Teşekkür ederim.Peki şöyle bir şey yapabiliyor muyuz acaba ? Mesela db kendisine bağlı olan client'ların ip sini tutsa bir tabloda (connection kapanınca bu kaydı silsin belki) ve bir function veya procedure yazsam.Bu procedure/Func tablodaki ip lere veri gönderse.Procedure/Function içinde böyle bir şey yazılabilir mi acaba ? bu func/procedure de trigger ile tetiklenecek olsa.Sizce bunun olabilitesi nedir ? Fazla mı hayalci 😀
Gönderildi : 15/05/2015 17:39
Biraz fantastik oldu evet 🙂 SQL Serverdan boyle bisey beklemek onun dogasina aykiri
ProfectSoft Yazılım ve Danışmanlık Hizmetleri
LogPusher & Bifyou E-Commerce System
www.profectsoft.com
Gönderildi : 15/05/2015 20:17
Konu başlatıcı
Demek çare socket programlama... Vakit ayırdığınız için teşekkür ederim
Gönderildi : 15/05/2015 20:19
Nedemek rica ederim kolay gelsin sonuclari bize de bildirirseniz seviniriz
ProfectSoft Yazılım ve Danışmanlık Hizmetleri
LogPusher & Bifyou E-Commerce System
www.profectsoft.com
Gönderildi : 15/05/2015 20:23
Merhaba,
SqlDependency adında bir class
bulunmaktadır. Bu class db yi dinlenemize yarar yani watcher görevi yapar.
Ancak bu class yerine bu classın extension halini kullanmanızı öneririm. Bu
sayede talebinizi gerçekleştirebilirsiniz. Buraya kadar ki kısım sizin sorunuza
olan lüzumsuz bir cevaptı.
Şimdi gelelim gerçek cevaba ;
Öncelikle db den bu tarz
notification lar almak istiyor isek dbnizin enable_broker yapısını true olarak
değiştirmek gerekmektedir. Bunu mssql management studioda db nin üzerine gelip
sağ tuşa bastıktan sonra sol üstten tekrar options sekmesine gelip
"Service Broker" bölümün altında Broker Enable = true yapabilirsiniz,
Ancak bu çok yavaş bir işlem
olacaktır ve hata alma olasılığınızda yüksek oyüzden şu cümleyi çalıştırmanız
kafi olacaktır;
ALTER DATABASE DATABASEADINIZ SET
ENABLE_BROKER WITH ROLLBACK IMMEDIATE
Cümlede database adınız yazan
yere db adınızı yazıp execute ettiğinizde artık db niz dışarı bilgi verebilir
hale gelecek. Bu birinci adımdı.
Şimdi az önce yukarıda
bahsettiğim extension methodu inceleyelim. Link vermeyi beceremedim. Dolayısı ile kodu yapıştıracağım biraz uzun umarım sorun çıkarmaz.
namespace ServiceBrokerListener.Domain
{
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Threading;
using System.Xml.Linq;
public sealed class SqlDependencyEx : IDisposable
{
[Flags]
public enum NotificationTypes
{
None = 0,
Insert = 1 << 1,
Update = 1 << 2,
Delete = 1 << 3
}
public class TableChangedEventArgs : EventArgs
{
private readonly string notificationMessage;
private const string INSERTED_TAG = "inserted";
private const string DELETED_TAG = "deleted";
public TableChangedEventArgs(string notificationMessage)
{
this.notificationMessage = notificationMessage;
}
public XElement Data
{
get
{
if (string.IsNullOrWhiteSpace(notificationMessage)) return null;
return XElement.Parse(notificationMessage);
}
}
public NotificationTypes NotificationType
{
get
{
return Data.Element(INSERTED_TAG) != null
? Data.Element(DELETED_TAG) != null
? NotificationTypes.Update
: NotificationTypes.Insert
: Data.Element(DELETED_TAG) != null
? NotificationTypes.Delete
: NotificationTypes.None;
}
}
}
#region Scripts
#region Procedures
private const string SQL_PERMISSIONS_INFO = @"
DECLARE @msg VARCHAR(MAX)
DECLARE @crlf CHAR(1)
SET @crlf = CHAR(10)
SET @msg = 'Current user must have following permissions: '
SET @msg = @msg + '[CREATE PROCEDURE, CREATE SERVICE, CREATE QUEUE, SUBSCRIBE QUERY NOTIFICATIONS, CONTROL, REFERENCES] '
SET @msg = @msg + 'that are required to start query notifications. '
SET @msg = @msg + 'Grant described permissions with following script: ' + @crlf
SET @msg = @msg + 'GRANT CREATE PROCEDURE TO [<username>];' + @crlf
SET @msg = @msg + 'GRANT CREATE SERVICE TO [<username>];' + @crlf
SET @msg = @msg + 'GRANT CREATE QUEUE TO [<username>];' + @crlf
SET @msg = @msg + 'GRANT REFERENCES ON CONTRACT::[DEFAULT] TO [<username>];' + @crlf
SET @msg = @msg + 'GRANT SUBSCRIBE QUERY NOTIFICATIONS TO [<username>];' + @crlf
SET @msg = @msg + 'GRANT CONTROL ON SCHEMA::[<schemaname>] TO [<username>];'
PRINT @msg
";
/// <summary>
/// T-SQL script-template which creates notification setup procedure.
/// {0} - database name.
/// {1} - setup procedure name.
/// {2} - service broker configuration statement.
/// {3} - notification trigger configuration statement.
/// {4} - notification trigger check statement.
/// {5} - table name.
/// {6} - schema name.
/// </summary>
private const string SQL_FORMAT_CREATE_INSTALLATION_PROCEDURE = @"
USE [{0}]
" + SQL_PERMISSIONS_INFO + @"
IF OBJECT_ID ('{6}.{1}', 'P') IS NULL
BEGIN
EXEC ('
CREATE PROCEDURE {6}.{1}
AS
BEGIN
-- Service Broker configuration statement.
{2}
-- Notification Trigger check statement.
{4}
-- Notification Trigger configuration statement.
DECLARE @triggerStatement NVARCHAR(MAX)
DECLARE @select NVARCHAR(MAX)
DECLARE @sqlInserted NVARCHAR(MAX)
DECLARE @sqlDeleted NVARCHAR(MAX)
SET @triggerStatement = N''{3}''
SET @select = STUFF((SELECT '','' + COLUMN_NAME
FROM INFORMATION_SCHEMA.COLUMNS
WHERE TABLE_NAME = ''{5}'' AND TABLE_CATALOG = ''{0}''
FOR XML PATH ('''')
), 1, 1, '''')
SET @sqlInserted =
N''SET @retvalOUT = (SELECT '' + @select + N''
FROM INSERTED
FOR XML PATH(''''row''''), ROOT (''''inserted''''))''
SET @sqlDeleted =
N''SET @retvalOUT = (SELECT '' + @select + N''
FROM DELETED
FOR XML PATH(''''row''''), ROOT (''''deleted''''))''
SET @triggerStatement = REPLACE(@triggerStatement
, ''%inserted_select_statement%'', @sqlInserted)
SET @triggerStatement = REPLACE(@triggerStatement
, ''%deleted_select_statement%'', @sqlDeleted)
EXEC sp_executeSql @triggerStatement
END
')
END
";
/// <summary>
/// T-SQL script-template which creates notification uninstall procedure.
/// {0} - database name.
/// {1} - uninstall procedure name.
/// {2} - notification trigger drop statement.
/// {3} - service broker uninstall statement.
/// {4} - schema name.
/// {5} - install procedure name.
/// </summary>
private const string SQL_FORMAT_CREATE_UNINSTALLATION_PROCEDURE = @"
USE [{0}]
" + SQL_PERMISSIONS_INFO + @"
IF OBJECT_ID ('{4}.{1}', 'P') IS NULL
BEGIN
EXEC ('
CREATE PROCEDURE {4}.{1}
AS
BEGIN
-- Notification Trigger drop statement.
{3}
-- Service Broker uninstall statement.
{2}
IF OBJECT_ID (''{4}.{5}'', ''P'') IS NOT NULL
DROP PROCEDURE {4}.{5}
DROP PROCEDURE {4}.{1}
END
')
END
";
#endregion
#region ServiceBroker notification
/// <summary>
/// T-SQL script-template which prepares database for ServiceBroker notification.
/// {0} - database name;
/// {1} - conversation queue name.
/// {2} - conversation service name.
/// {3} - schema name.
/// </summary>
private const string SQL_FORMAT_INSTALL_SEVICE_BROKER_NOTIFICATION = @"
-- Setup Service Broker
IF EXISTS (SELECT * FROM sys.databases
WHERE name = '{0}' AND (is_broker_enabled = 0 OR is_trustworthy_on = 0))
BEGIN
IF (NOT EXISTS(SELECT * FROM sys.fn_my_permissions(NULL, 'SERVER')
WHERE permission_name = 'CONTROL SERVER'))
BEGIN
DECLARE @msg VARCHAR(MAX)
SET @msg = 'Current user doesn''t have CONTROL SERVER permission to enable service broker. '
SET @msg = @msg + 'Grant sufficient permissions to current user or '
SET @msg = @msg + 'execute ALTER DATABASE [<dbname>] SET ENABLE_BROKER with admin rights.'
RAISERROR (@msg, 16, 1)
END
ELSE
BEGIN
ALTER DATABASE [{0}] SET SINGLE_USER WITH ROLLBACK IMMEDIATE
ALTER DATABASE [{0}] SET ENABLE_BROKER;
ALTER DATABASE [{0}] SET MULTI_USER WITH ROLLBACK IMMEDIATE
-- FOR SQL Express
ALTER AUTHORIZATION ON DATABASE::[{0}] TO [sa]
ALTER DATABASE [{0}] SET TRUSTWORTHY ON;
END
END
-- Create a queue which will hold the tracked information
IF NOT EXISTS (SELECT * FROM sys.service_queues WHERE name = '{1}')
CREATE QUEUE {3}.[{1}]
-- Create a service on which tracked information will be sent
IF NOT EXISTS(SELECT * FROM sys.services WHERE name = '{2}')
CREATE SERVICE [{2}] ON QUEUE {3}.[{1}] ([DEFAULT])
";
/// <summary>
/// T-SQL script-template which removes database notification.
/// {0} - conversation queue name.
/// {1} - conversation service name.
/// {2} - schema name.
/// </summary>
private const string SQL_FORMAT_UNINSTALL_SERVICE_BROKER_NOTIFICATION = @"
DECLARE @serviceId INT
SELECT @serviceId = service_id FROM sys.services
WHERE sys.services.name = '{1}'
DECLARE @ConvHandle uniqueidentifier
DECLARE Conv CURSOR FOR
SELECT CEP.conversation_handle FROM sys.conversation_endpoints CEP
WHERE CEP.service_id = @serviceId AND ([state] != 'CD' OR [lifetime] > GETDATE() + 1)
OPEN Conv;
FETCH NEXT FROM Conv INTO @ConvHandle;
WHILE (@@FETCH_STATUS = 0) BEGIN
END CONVERSATION @ConvHandle WITH CLEANUP;
FETCH NEXT FROM Conv INTO @ConvHandle;
END
CLOSE Conv;
DEALLOCATE Conv;
-- Droping service and queue.
DROP SERVICE [{1}];
IF OBJECT_ID ('{2}.{0}', 'SQ') IS NOT NULL
DROP QUEUE {2}.[{0}];
";
#endregion
#region Notification Trigger
/// <summary>
/// T-SQL script-template which creates notification trigger.
/// {0} - notification trigger name.
/// {1} - schema name.
/// </summary>
private const string SQL_FORMAT_DELETE_NOTIFICATION_TRIGGER = @"
IF OBJECT_ID ('{1}.{0}', 'TR') IS NOT NULL
DROP TRIGGER {1}.[{0}];
";
private const string SQL_FORMAT_CHECK_NOTIFICATION_TRIGGER = @"
IF OBJECT_ID ('{1}.{0}', 'TR') IS NOT NULL
RETURN;
";
/// <summary>
/// T-SQL script-template which creates notification trigger.
/// {0} - monitorable table name.
/// {1} - notification trigger name.
/// {2} - event data (INSERT, DELETE, UPDATE...).
/// {3} - conversation service name.
/// {4} - detailed changes tracking mode.
/// {5} - schema name.
/// %inserted_select_statement% - sql code which sets trigger "inserted" value to @retvalOUT variable.
/// %deleted_select_statement% - sql code which sets trigger "deleted" value to @retvalOUT variable.
/// </summary>
private const string SQL_FORMAT_CREATE_NOTIFICATION_TRIGGER = @"
CREATE TRIGGER [{1}]
ON {5}.[{0}]
AFTER {2}
AS
SET NOCOUNT ON;
--Trigger {0} is rising...
IF EXISTS (SELECT * FROM sys.services WHERE name = '{3}')
BEGIN
DECLARE @message NVARCHAR(MAX)
SET @message = N'<root/>'
IF ({4} EXISTS(SELECT 1))
BEGIN
DECLARE @retvalOUT NVARCHAR(MAX)
%inserted_select_statement%
IF (@retvalOUT IS NOT NULL)
BEGIN SET @message = N'<root>' + @retvalOUT END
%deleted_select_statement%
IF (@retvalOUT IS NOT NULL)
BEGIN
IF (@message = N'<root/>') BEGIN SET @message = N'<root>' + @retvalOUT END
ELSE BEGIN SET @message = @message + @retvalOUT END
END
IF (@message != N'<root/>') BEGIN SET @message = @message + N'</root>' END
END
--Beginning of dialog...
DECLARE @ConvHandle UNIQUEIDENTIFIER
--Determine the Initiator Service, Target Service and the Contract
BEGIN DIALOG @ConvHandle
FROM SERVICE [{3}] TO SERVICE '{3}' ON CONTRACT [DEFAULT] WITH ENCRYPTION=OFF, LIFETIME = 60;
--Send the Message
SEND ON CONVERSATION @ConvHandle MESSAGE TYPE [DEFAULT] (@message);
--End conversation
END CONVERSATION @ConvHandle;
END
";
#endregion
#region Miscellaneous
/// <summary>
/// T-SQL script-template which helps to receive changed data in monitorable table.
/// {0} - database name.
/// {1} - conversation queue name.
/// {2} - timeout.
/// {3} - schema name.
/// </summary>
private const string SQL_FORMAT_RECEIVE_EVENT = @"
DECLARE @ConvHandle UNIQUEIDENTIFIER
DECLARE @message VARBINARY(MAX)
USE [{0}]
WAITFOR (RECEIVE TOP(1) @ConvHandle=Conversation_Handle
, @message=message_body FROM {3}.[{1}]), TIMEOUT {2};
BEGIN TRY END CONVERSATION @ConvHandle; END TRY BEGIN CATCH END CATCH
SELECT CAST(@message AS NVARCHAR(MAX))
";
/// <summary>
/// T-SQL script-template which executes stored procedure.
/// {0} - database name.
/// {1} - procedure name.
/// {2} - schema name.
/// </summary>
private const string SQL_FORMAT_EXECUTE_PROCEDURE = @"
USE [{0}]
IF OBJECT_ID ('{2}.{1}', 'P') IS NOT NULL
EXEC {2}.{1}
";
/// <summary>
/// T-SQL script-template which returns all dependency identities in the database.
/// {0} - database name.
/// </summary>
private const string SQL_FORMAT_GET_DEPENDENCY_IDENTITIES = @"
USE [{0}]
SELECT REPLACE(name , 'ListenerService_' , '')
FROM sys.services
WHERE [name] like 'ListenerService_%';
";
#endregion
#region Forced cleaning of database
/// <summary>
/// T-SQL script-template which cleans database from notifications.
/// {0} - database name.
/// </summary>
private const string SQL_FORMAT_FORCED_DATABASE_CLEANING = @"
USE [{0}]
DECLARE @db_name VARCHAR(MAX)
SET @db_name = '{0}' -- provide your own db name
DECLARE @proc_name VARCHAR(MAX)
DECLARE procedures CURSOR
FOR
SELECT sys.schemas.name + '.' + sys.objects.name
FROM sys.objects
INNER JOIN sys.schemas ON sys.objects.schema_id = sys.schemas.schema_id
WHERE sys.objects.[type] = 'P' AND sys.objects.[name] like 'sp_UninstallListenerNotification_%'
OPEN procedures;
FETCH NEXT FROM procedures INTO @proc_name
WHILE (@@FETCH_STATUS = 0)
BEGIN
EXEC ('USE [' + @db_name + '] EXEC ' + @proc_name + ' IF (OBJECT_ID ('''
+ @proc_name + ''', ''P'') IS NOT NULL) DROP PROCEDURE '
+ @proc_name)
FETCH NEXT FROM procedures INTO @proc_name
END
CLOSE procedures;
DEALLOCATE procedures;
DECLARE procedures CURSOR
FOR
SELECT sys.schemas.name + '.' + sys.objects.name
FROM sys.objects
INNER JOIN sys.schemas ON sys.objects.schema_id = sys.schemas.schema_id
WHERE sys.objects.[type] = 'P' AND sys.objects.[name] like 'sp_InstallListenerNotification_%'
OPEN procedures;
FETCH NEXT FROM procedures INTO @proc_name
WHILE (@@FETCH_STATUS = 0)
BEGIN
EXEC ('USE [' + @db_name + '] DROP PROCEDURE '
+ @proc_name)
FETCH NEXT FROM procedures INTO @proc_name
END
CLOSE procedures;
DEALLOCATE procedures;
";
#endregion
#endregion
private const int COMMAND_TIMEOUT = 60000;
private static readonly List<int> ActiveEntities = new List<int>();
private Thread listenerThread;
public string ConversationQueueName
{
get
{
return string.Format("ListenerQueue_{0}", this.Identity);
}
}
public string ConversationServiceName
{
get
{
return string.Format("ListenerService_{0}", this.Identity);
}
}
public string ConversationTriggerName
{
get
{
return string.Format("tr_Listener_{0}", this.Identity);
}
}
public string InstallListenerProcedureName
{
get
{
return string.Format("sp_InstallListenerNotification_{0}", this.Identity);
}
}
public string UninstallListenerProcedureName
{
get
{
return string.Format("sp_UninstallListenerNotification_{0}", this.Identity);
}
}
public string ConnectionString { get; private set; }
public string DatabaseName { get; private set; }
public string TableName { get; private set; }
public string SchemaName { get; private set; }
public NotificationTypes NotificaionTypes { get; private set; }
public bool DetailsIncluded { get; private set; }
public int Identity
{
get;
private set;
}
public bool Active { get; private set; }
public event EventHandler<TableChangedEventArgs> TableChanged;
public event EventHandler NotificationProcessStopped;
public SqlDependencyEx(
string connectionString,
string databaseName,
string tableName,
string schemaName = "dbo",
NotificationTypes listenerType =
NotificationTypes.Insert | NotificationTypes.Update | NotificationTypes.Delete,
bool receiveDetails = true, int identity = 1)
{
this.ConnectionString = connectionString;
this.DatabaseName = databaseName;
this.TableName = tableName;
this.SchemaName = schemaName;
this.NotificaionTypes = listenerType;
this.DetailsIncluded = receiveDetails;
this.Identity = identity;
}
public void Start()
{
lock (ActiveEntities)
{
if (ActiveEntities.Contains(this.Identity))
throw new InvalidOperationException("An object with the same identity has already been started.");
ActiveEntities.Add(this.Identity);
}
this.InstallNotification();
ThreadStart threadLoop = () =>
{
try
{
while (true)
{
string message = ReceiveEvent();
this.Active = true;
if (!string.IsNullOrWhiteSpace(message))
OnTableChanged(message);
}
}
finally
{
Active = false;
OnNotificationProcessStopped();
}
};
var thread = new Thread(threadLoop)
{
Name =
string.Format(
"{0}_Thread_{1}",
this.GetType().FullName,
this.Identity),
IsBackground = true
};
thread.Start();
this.listenerThread = thread;
}
public void Stop()
{
UninstallNotification();
lock (ActiveEntities)
if (ActiveEntities.Contains(Identity)) ActiveEntities.Remove(Identity);
var thread = this.listenerThread;
if ((thread == null) || (!thread.IsAlive))
return;
thread.Abort();
thread.Join();
}
public void Dispose()
{
Stop();
}
public static int[] GetDependencyDbIdentities(string connectionString, string database)
{
if (connectionString == null)
{
throw new ArgumentNullException("connectionString");
}
if (database == null)
{
throw new ArgumentNullException("database");
}
List<string> result = new List<string>();
using (SqlConnection connection = new SqlConnection(connectionString))
using (SqlCommand command = connection.CreateCommand())
{
connection.Open();
command.CommandText = string.Format(SQL_FORMAT_GET_DEPENDENCY_IDENTITIES, database);
command.CommandType = CommandType.Text;
using (SqlDataReader reader = command.ExecuteReader())
while (reader.Read())
result.Add(reader.GetString(0));
}
int temp;
return
result.Select(p => int.TryParse(p, out temp) ? temp : -1)
.Where(p => p != -1)
.ToArray();
}
public static void CleanDatabase(string connectionString, string database)
{
ExecuteNonQuery(
string.Format(SQL_FORMAT_FORCED_DATABASE_CLEANING, database),
connectionString);
}
private static void ExecuteNonQuery(string commandText, string connectionString)
{
using (SqlConnection conn = new SqlConnection(connectionString))
using (SqlCommand command = new SqlCommand(commandText, conn))
{
conn.Open();
command.CommandType = CommandType.Text;
command.ExecuteNonQuery();
}
}
private string ReceiveEvent()
{
var commandText = string.Format(
SQL_FORMAT_RECEIVE_EVENT,
this.DatabaseName,
this.ConversationQueueName,
COMMAND_TIMEOUT / 2,
this.SchemaName);
using (SqlConnection conn = new SqlConnection(this.ConnectionString))
using (SqlCommand command = new SqlCommand(commandText, conn))
{
conn.Open();
command.CommandType = CommandType.Text;
command.CommandTimeout = COMMAND_TIMEOUT;
using (var reader = command.ExecuteReader())
{
if (!reader.Read() || reader.IsDBNull(0)) return string.Empty;
return reader.GetString(0);
}
}
}
private string GetUninstallNotificationProcedureScript()
{
string uninstallServiceBrokerNotificationScript = string.Format(
SQL_FORMAT_UNINSTALL_SERVICE_BROKER_NOTIFICATION,
this.ConversationQueueName,
this.ConversationServiceName,
this.SchemaName);
string uninstallNotificationTriggerScript = string.Format(
SQL_FORMAT_DELETE_NOTIFICATION_TRIGGER,
this.ConversationTriggerName,
this.SchemaName);
string uninstallationProcedureScript =
string.Format(
SQL_FORMAT_CREATE_UNINSTALLATION_PROCEDURE,
this.DatabaseName,
this.UninstallListenerProcedureName,
uninstallServiceBrokerNotificationScript.Replace("'", "''"),
uninstallNotificationTriggerScript.Replace("'", "''"),
this.SchemaName,
this.InstallListenerProcedureName);
return uninstallationProcedureScript;
}
private string GetInstallNotificationProcedureScript()
{
string installServiceBrokerNotificationScript = string.Format(
SQL_FORMAT_INSTALL_SEVICE_BROKER_NOTIFICATION,
this.DatabaseName,
this.ConversationQueueName,
this.ConversationServiceName,
this.SchemaName);
string installNotificationTriggerScript =
string.Format(
SQL_FORMAT_CREATE_NOTIFICATION_TRIGGER,
this.TableName,
this.ConversationTriggerName,
GetTriggerTypeByListenerType(),
this.ConversationServiceName,
this.DetailsIncluded ? string.Empty : @"NOT",
this.SchemaName);
string uninstallNotificationTriggerScript =
string.Format(
SQL_FORMAT_CHECK_NOTIFICATION_TRIGGER,
this.ConversationTriggerName,
this.SchemaName);
string installationProcedureScript =
string.Format(
SQL_FORMAT_CREATE_INSTALLATION_PROCEDURE,
this.DatabaseName,
this.InstallListenerProcedureName,
installServiceBrokerNotificationScript.Replace("'", "''"),
installNotificationTriggerScript.Replace("'", "''''"),
uninstallNotificationTriggerScript.Replace("'", "''"),
this.TableName,
this.SchemaName);
return installationProcedureScript;
}
private string GetTriggerTypeByListenerType()
{
StringBuilder result = new StringBuilder();
if (this.NotificaionTypes.HasFlag(NotificationTypes.Insert))
result.Append("INSERT");
if (this.NotificaionTypes.HasFlag(NotificationTypes.Update))
result.Append(result.Length == 0 ? "UPDATE" : ", UPDATE");
if (this.NotificaionTypes.HasFlag(NotificationTypes.Delete))
result.Append(result.Length == 0 ? "DELETE" : ", DELETE");
if (result.Length == 0) result.Append("INSERT");
return result.ToString();
}
private void UninstallNotification()
{
string execUninstallationProcedureScript = string.Format(
SQL_FORMAT_EXECUTE_PROCEDURE,
this.DatabaseName,
this.UninstallListenerProcedureName,
this.SchemaName);
ExecuteNonQuery(execUninstallationProcedureScript, this.ConnectionString);
}
private void InstallNotification()
{
string execInstallationProcedureScript = string.Format(
SQL_FORMAT_EXECUTE_PROCEDURE,
this.DatabaseName,
this.InstallListenerProcedureName,
this.SchemaName);
ExecuteNonQuery(GetInstallNotificationProcedureScript(), this.ConnectionString);
ExecuteNonQuery(GetUninstallNotificationProcedureScript(), this.ConnectionString);
ExecuteNonQuery(execInstallationProcedureScript, this.ConnectionString);
}
private void OnTableChanged(string message)
{
var evnt = this.TableChanged;
if (evnt == null) return;
evnt.Invoke(this, new TableChangedEventArgs(message));
}
private void OnNotificationProcessStopped()
{
var evnt = NotificationProcessStopped;
if (evnt == null) return;
evnt.BeginInvoke(this, EventArgs.Empty, null, null);
}
}
}
Projenizin üzerine gelin sağ tuş> add > new item boş bir .cs dosyası seçip adınıda ServiceBrokerListener.cs koyup içini tamamen slip yukarıdaki kodu yapıştırdıkmı 2. aşamada tamamdır.
Şimdi gelelim dinleme kodumuzu yazmaya ;
private void Form1_Load(object sender, EventArgs e)
{
string cons = @"Data Source=BURAKSENTURK\SQLEXPRESS;Initial Catalog=test;User ID=burak;Password=senturk!";
//Connection stringiniz yukarı
SqlDependencyEx sqlDependency = new SqlDependencyEx(cons, "test", "ILLER");
//extension methodda parametre olarak constring, database adı , ve dinleyeceğimiz tablo adını ekliyoruz.
{
sqlDependency.TableChanged += new EventHandler<SqlDependencyEx.TableChangedEventArgs>(sqlDependency_TableChanged);
sqlDependency.Start();
}
//burada tablechanged eventini oluşturuyor ve start methodunu çalıştırıyoruz.
}
void sqlDependency_TableChanged(object sender, SqlDependencyEx.TableChangedEventArgs e)
{
MessageBox.Show("hey");
}
//tabloda herhangi bir değişiklik olur ise ne yapmasını istiyor isek ki siz burada muhtemelen bir count alacaksınız. Artık orası size kalmış
Buraya yapıştırınca kodları sayfa düzeni biraz bozuldu ancak problem olmaz diye umuyorum.
Tahminimce işinizi görür.
Saygılarımla
Gönderildi : 29/05/2015 15:03
Paylaşımınız çok güzel ve bunun için teşekkürler. Lakin forumdaki bütün arkadaşlarımız sorunların çözümlerini direk paylaşmak yerine adresleme ile soruyu soran arkadaşlarımızında bu konuyu tam olarak öğrenmelerini amaçlarsak soruyu soran arkadaşımız copy paste yapmak yerine asıl neresini düzeltmesi gerektiğini daha net öğrenir diye düşünmekteyim...
Paylaşımınız için tekrar teşekkürler.
Saygılarımla
ProfectSoft Yazılım ve Danışmanlık Hizmetleri
LogPusher & Bifyou E-Commerce System
www.profectsoft.com
Gönderildi : 29/05/2015 16:32
Selam Tekrar,
Bu tarz savunma içerikli yazışmalardan hoşlanmam. Ancak yinede son olmak kaydı ile yazıyorum.
1. İlk iki üç cümlemde bahsettiğim lüzumsuz cevap kısmı sanırım bahsettiğiniz cevaptı. Ben o tarz cevapları öğreticiden çok yorucu olarak bulmaktayım. Dolayısı ile mümkün mertebe uzak dururum (Kişisel görüştür.)
2. Eklediğim uzun kod bloğu bir adet class tır. Ben yazmadım. İlgili methodun ex edilmiş halidir. Eğer sayfadaki yazı editörünün linkleme yapısı browserımda çalışmış olsa idi linkini verir geçer buraya yapıştırma ile uğraşmazdım.Ne yazık ki kendi sayfama upload edip buraya reklama benzer bir linki text halinde de vermek istemedim.
3. Son olarak eklediğim kod bloğu ise ilgili extension methodun kullanımına basit bir örnektir.
Eğer belirttiğiniz cevap methodolojisi forum kuralı ise postumu gönül rahatlığı ile silebilirsiniz. Eğer değil ise ve kişisel görüşünüz ise lütfen bu tarz postları kişisel mesaj olarak iletin ki konu dağılmasın.
Yine de bundan sonra atacağım postları atarken nazik tavsiyenizi dikkate alıyor olacağım.
Saygılarımla,
Saygılarımla
Gönderildi : 29/05/2015 17:10
Teşekkürler
Saygılarımla
ProfectSoft Yazılım ve Danışmanlık Hizmetleri
LogPusher & Bifyou E-Commerce System
www.profectsoft.com
Gönderildi : 29/05/2015 17:13
