1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
|
using EFCache;
using Microsoft.Win32;
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Data;
using System.Windows.Documents;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Media.Imaging;
using System.Windows.Navigation;
using System.Windows.Shapes;
using System.Windows.Threading;
using Tango.BL;
using Tango.BL.Builders;
using Tango.BL.Catalogs;
using Tango.BL.Entities;
using Tango.Core;
using Tango.Core.Commands;
using Tango.DragAndDrop;
using Tango.FirmwareUpdateLib;
using Tango.FirmwareUpdateLib.WPF;
using Tango.Logging;
using Tango.SharedUI;
using Tango.Web;
using System.Data;
using System.Data.SqlClient;
using System.Security.Permissions;
using TableDependency.SqlClient.Base;
using TableDependency.SqlClient;
using TableDependency.SqlClient.Base.EventArgs;
using TableDependency.SqlClient.Base.Abstracts;
namespace Tango.UITests
{
/// <summary>
/// Interaction logic for MainWindow.xaml
/// </summary>
public partial class MainWindow : Window
{
private ITableDependency _dep;
private DataSource _dataSource;
public MainWindow()
{
_dataSource = new DataSource()
{
Address = "twine.database.windows.net",
Catalog = "Tango_DEV",
Type = DataSourceType.SQLServer,
UserName = "Roy",
Password = "Aa123456",
IntegratedSecurity = false,
};
InitializeComponent();
EntityFrameworkCache.Initialize(new MyMemoryCache() { Expiration = TimeSpan.FromMinutes(1) });
this.Closing += MainWindow_Closing;
}
private void MainWindow_Closing(object sender, System.ComponentModel.CancelEventArgs e)
{
if (_dep != null)
{
_dep.Stop();
_dep.Dispose();
}
}
private void btnStart_Click(object sender, RoutedEventArgs e)
{
Stopwatch watch = Stopwatch.StartNew();
using (ObservablesContext db = ObservablesContext.CreateDefault(_dataSource))
{
var users = db.Users.ToList();
var jobs = new JobsCollectionBuilder(db).SetAll().WithSegments().WithBrushStops().Build();
var first_job = jobs.First();
if (first_job.Name == "Changed Name 2")
{
Debug.WriteLine("Changed and cached !!!");
}
else
{
Debug.WriteLine("Not working.");
}
}
Debug.WriteLine($"Time to complete: {watch.Elapsed.TotalSeconds} seconds");
}
private void btnChange_Click(object sender, RoutedEventArgs e)
{
using (ObservablesContext db = ObservablesContext.CreateDefault(_dataSource))
{
var jobs = new JobsCollectionBuilder(db).SetAll().WithSegments().WithBrushStops().Build();
var first_job = jobs.First();
first_job.Name = "Changed Name 2";
db.SaveChanges();
}
}
private void btnListen_Click(object sender, RoutedEventArgs e)
{
String str = _dataSource.ToConnection().ConnectionString;
var dep = new SqlTableDependency<DAL.Remote.DB.USER>(str, "USERS", "dbo");
dep.TraceLevel = TraceLevel.Verbose;
dep.TraceListener = new TextWriterTraceListener(Console.Out);
dep.OnChanged += Changed;
dep.Start();
_dep = dep;
}
private void Changed(object sender, RecordChangedEventArgs<DAL.Remote.DB.USER> e)
{
var changedEntity = e.Entity;
Console.WriteLine("DML operation: " + e.ChangeType);
Console.WriteLine(changedEntity.ToJsonString());
}
}
}
|
