|
0
|
1 using System;
|
|
|
2 using System.Data.Linq.Mapping;
|
|
|
3 using System.Linq;
|
|
|
4
|
|
|
5 using BLToolkit.Data;
|
|
|
6 using BLToolkit.Data.DataProvider;
|
|
|
7 using BLToolkit.Data.Linq;
|
|
|
8 using BLToolkit.DataAccess;
|
|
|
9 using BLToolkit.Mapping;
|
|
|
10
|
|
|
11 using NUnit.Framework;
|
|
|
12
|
|
|
13 using UnitTests.Linq.Interface.Model;
|
|
|
14
|
|
|
15 namespace Data.Linq.ProviderSpecific
|
|
|
16 {
|
|
|
17 using Model;
|
|
|
18
|
|
|
19 [TestFixture, Category("Oracle")]
|
|
|
20 public class Oracle : TestBase
|
|
|
21 {
|
|
|
22 #region Sequence
|
|
|
23
|
|
|
24 [Test]
|
|
|
25 public void SequenceInsert([IncludeDataContexts("Oracle")] string context)
|
|
|
26 {
|
|
|
27 using (var db = new TestDbManager(context))
|
|
|
28 {
|
|
|
29 db.GetTable<OracleSpecific.SequenceTest>().Where(_ => _.Value == "SeqValue").Delete();
|
|
|
30 db.Insert(new OracleSpecific.SequenceTest { Value = "SeqValue" });
|
|
|
31
|
|
|
32 var id = db.GetTable<OracleSpecific.SequenceTest>().Single(_ => _.Value == "SeqValue").ID;
|
|
|
33
|
|
|
34 db.GetTable<OracleSpecific.SequenceTest>().Where(_ => _.ID == id).Delete();
|
|
|
35
|
|
|
36 Assert.AreEqual(0, db.GetTable<OracleSpecific.SequenceTest>().Count(_ => _.Value == "SeqValue"));
|
|
|
37 }
|
|
|
38 }
|
|
|
39
|
|
|
40 [Test]
|
|
|
41 public void SequenceInsertWithIdentity([IncludeDataContexts("Oracle")] string context)
|
|
|
42 {
|
|
|
43 using (var db = new TestDbManager(context))
|
|
|
44 {
|
|
|
45 db.GetTable<OracleSpecific.SequenceTest>().Where(_ => _.Value == "SeqValue").Delete();
|
|
|
46
|
|
|
47 var id1 = Convert.ToInt32(db.InsertWithIdentity(new OracleSpecific.SequenceTest { Value = "SeqValue" }));
|
|
|
48 var id2 = db.GetTable<OracleSpecific.SequenceTest>().Single(_ => _.Value == "SeqValue").ID;
|
|
|
49
|
|
|
50 Assert.AreEqual(id1, id2);
|
|
|
51
|
|
|
52 db.GetTable<OracleSpecific.SequenceTest>().Where(_ => _.ID == id1).Delete();
|
|
|
53
|
|
|
54 Assert.AreEqual(0, db.GetTable<OracleSpecific.SequenceTest>().Count(_ => _.Value == "SeqValue"));
|
|
|
55 }
|
|
|
56 }
|
|
|
57
|
|
|
58 #endregion
|
|
|
59
|
|
|
60 #region InsertBatch
|
|
|
61
|
|
|
62 [Table(Name = "stg_trade_information")]
|
|
|
63 public class Trade
|
|
|
64 {
|
|
|
65 [MapField("STG_TRADE_ID")] public int ID { get; set; }
|
|
|
66 [MapField("STG_TRADE_VERSION")] public int Version { get; set; }
|
|
|
67 [MapField("INFORMATION_TYPE_ID")] public int TypeID { get; set; }
|
|
|
68 [MapField("INFORMATION_TYPE_NAME")] public string TypeName { get; set; }
|
|
|
69 [MapField("value")] public string Value { get; set; }
|
|
|
70 [MapField("value_as_integer")] public int? ValueAsInteger { get; set; }
|
|
|
71 [MapField("value_as_date")] public DateTime? ValueAsDate { get; set; }
|
|
|
72 }
|
|
|
73
|
|
|
74 [Test]
|
|
|
75 public void InsertBatch1([IncludeDataContexts("Oracle")] string context)
|
|
|
76 {
|
|
|
77 var data = new[]
|
|
|
78 {
|
|
|
79 new Trade { ID = 375, Version = 1, TypeID = 20224, TypeName = "Gas Month", },
|
|
|
80 new Trade { ID = 328, Version = 1, TypeID = 20224, TypeName = "Gas Month", },
|
|
|
81 new Trade { ID = 348, Version = 1, TypeID = 20224, TypeName = "Gas Month", },
|
|
|
82 new Trade { ID = 357, Version = 1, TypeID = 20224, TypeName = "Gas Month", },
|
|
|
83 new Trade { ID = 371, Version = 1, TypeID = 20224, TypeName = "Gas Month", },
|
|
|
84 new Trade { ID = 333, Version = 1, TypeID = 20224, TypeName = "Gas Month", ValueAsInteger = 1, ValueAsDate = new DateTime(2011, 1, 5) },
|
|
|
85 new Trade { ID = 353, Version = 1, TypeID = 20224, TypeName = "Gas Month", ValueAsInteger = 1000000000, },
|
|
|
86 new Trade { ID = 973, Version = 1, TypeID = 20160, TypeName = "EU Allowances", },
|
|
|
87 };
|
|
|
88
|
|
|
89 using (var db = new TestDbManager(context))
|
|
|
90 {
|
|
|
91 db.InsertBatch(5, data);
|
|
|
92 }
|
|
|
93 }
|
|
|
94
|
|
|
95 [Test]
|
|
|
96 public void InsertBatch2([IncludeDataContexts("Oracle")] string context)
|
|
|
97 {
|
|
|
98 using (var db = new TestDbManager(context))
|
|
|
99 {
|
|
|
100 db.Types2.Delete(_ => _.ID > 1000);
|
|
|
101
|
|
|
102 db.InsertBatch(2, new[]
|
|
|
103 {
|
|
|
104 new LinqDataTypes2 { ID = 1003, MoneyValue = 0m, DateTimeValue = null, BoolValue = true, GuidValue = new Guid("ef129165-6ffe-4df9-bb6b-bb16e413c883"), SmallIntValue = null, IntValue = null },
|
|
|
105 new LinqDataTypes2 { ID = 1004, MoneyValue = 0m, DateTimeValue = DateTime.Now, BoolValue = false, GuidValue = null, SmallIntValue = 2, IntValue = 1532334 },
|
|
|
106 new LinqDataTypes2 { ID = 1005, MoneyValue = 1m, DateTimeValue = DateTime.Now, BoolValue = false, GuidValue = null, SmallIntValue = 5, IntValue = null },
|
|
|
107 new LinqDataTypes2 { ID = 1006, MoneyValue = 2m, DateTimeValue = DateTime.Now, BoolValue = false, GuidValue = null, SmallIntValue = 6, IntValue = 153 },
|
|
|
108 });
|
|
|
109
|
|
|
110 db.Types2.Delete(_ => _.ID > 1000);
|
|
|
111 }
|
|
|
112 }
|
|
|
113
|
|
|
114 #endregion
|
|
|
115
|
|
|
116 #region Transaction
|
|
|
117
|
|
|
118 [TableName("demo_product_info")]
|
|
|
119 public new class Product
|
|
|
120 {
|
|
|
121 [MapField("PRODUCT_ID"), PrimaryKey, NonUpdatable]
|
|
|
122 public int Id;
|
|
|
123
|
|
|
124 [MapField("PRODUCT_NAME")]
|
|
|
125 public string Name;
|
|
|
126
|
|
|
127 [MapField("PRODUCT_DESCRIPTION")]
|
|
|
128 public string Description;
|
|
|
129 }
|
|
|
130
|
|
|
131 public abstract class ProductEntityAccesor : DataAccessor<Product>
|
|
|
132 {
|
|
|
133 public abstract int Insert(Product product);
|
|
|
134 public abstract void Delete(int id);
|
|
|
135 public abstract Product SelectByKey(int id);
|
|
|
136 public abstract Product SelectByKey(DbManager db, int id);
|
|
|
137 }
|
|
|
138
|
|
|
139 //[Test]
|
|
|
140 public void CanInsertProductWithAccessorTest([IncludeDataContexts("Oracle")] string context)
|
|
|
141 {
|
|
|
142 using (var dbManager = new TestDbManager(context))
|
|
|
143 {
|
|
|
144 var productEntityAccesor = DataAccessor.CreateInstance<ProductEntityAccesor>(dbManager);
|
|
|
145
|
|
|
146 productEntityAccesor.BeginTransaction();
|
|
|
147
|
|
|
148 var id = productEntityAccesor.Insert(new Product { Name = "product name test", Description = "product description test" });
|
|
|
149 //This assert fails bacause id == 0 and it does not insert until the CommitTransaction is called.
|
|
|
150 Assert.AreNotEqual(0, id);
|
|
|
151
|
|
|
152 Product product = productEntityAccesor.SelectByKey(id);
|
|
|
153 Assert.IsNotNull(product);
|
|
|
154
|
|
|
155 productEntityAccesor.Delete(id);
|
|
|
156
|
|
|
157 productEntityAccesor.CommitTransaction();
|
|
|
158 }
|
|
|
159 }
|
|
|
160
|
|
|
161 #endregion
|
|
|
162 }
|
|
|
163 }
|
