Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- SqlCommand cmd = new SqlCommand("SELECT id FROM dbo.DataRequests", m_sqlConn);
- private void OnChange(object sender, SqlNotificationEventArgs e)
- {
- SqlDependency dependency = sender as SqlDependency;
- dependency.OnChange -= OnChange;
- Console.WriteLine("Info: " + e.Info.ToString());
- Console.WriteLine("Source: " + e.Source.ToString());
- Console.WriteLine("Type: " + e.Type.ToString());
- Console.WriteLine(DateTime.Now);
- GetMessages();
- }
- CREATE TABLE ##TempTab(
- [field1] [varchar](50) NULL,
- [field2] [varchar](50) NULL
- }
- select * from ##temptable left outer join mytable
- ON ##temptable.field1=myTable.field1 AND ##temptable.field2=myTable.field2
- WHERE myTable.field2 is null
- select * from mytable left outer join ##temptable
- ON ##temptable.field1=myTable.field1 AND ##temptable.field2=myTable.field2
- WHERE ##temptable.field2 is null
- string commandString = string.Format("SELECT [Id] FROM [dbo].[Tech]");
- command = new SqlCommand(commandString, connection);
- private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
- {
- SqlDependency dependency = (SqlDependency)sender;
- dependency.OnChange -= dependency_OnChange;
- this.Dispatcher.Invoke((System.Action)(() =>
- {
- if (e.Info.ToString().ToLower().Trim() == "insert")
- {
- GetData();
- int NewTechID = TechIDs.Last();
- }
- }));
- }
- private void GetData()
- {
- command.Notification = null;
- SqlDependency dependency = new SqlDependency(command);
- dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
- command.Connection.Open();
- using (SqlDataReader reader = command.ExecuteReader())
- {
- while (reader.Read())
- {
- TechIDs.add(int.Parse(reader.GetValue(0).ToString()));
- }
- reader.Close();
- }
- command.Connection.Close();
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement