Skip to content

Commit bc465fa

Browse files
optimajetoptimajet
committed
Updated to WFE 3.2.0
1 parent 9eb11af commit bc465fa

55 files changed

Lines changed: 125 additions & 104 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎Provider for Apache Ignite/Properties/AssemblyInfo.cs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,5 +32,5 @@
3232
// You can specify all the values or you can default the Build and Revision Numbers
3333
// by using the '*' as shown below:
3434
// [assembly: AssemblyVersion("1.0.*")]
35-
[assembly: AssemblyVersion("3.1.0")]
36-
[assembly: AssemblyFileVersion("3.1.0")]
35+
[assembly: AssemblyVersion("3.2.0")]
36+
[assembly: AssemblyFileVersion("3.2.0")]

‎Provider for MS SQL Server/Properties/AssemblyInfo.cs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,5 +32,5 @@
3232
// You can specify all the values or you can default the Build and Revision Numbers
3333
// by using the '*' as shown below:
3434
// [assembly: AssemblyVersion("1.0.*")]
35-
[assembly: AssemblyVersion("3.1.0")]
36-
[assembly: AssemblyFileVersion("3.1.0")]
35+
[assembly: AssemblyVersion("3.2.0")]
36+
[assembly: AssemblyFileVersion("3.2.0")]

‎Provider for MS SQL Server/Scripts/CreatePersistenceObjects.sql‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
/*
22
Company: OptimaJet
33
Project: WorkflowEngine.NET Provider for MSSQL and Azure SQL
4-
Version: 3.1
4+
Version: 3.2
55
File: CreatePersistenceObjects.sql
66
77
*/

‎Provider for MS SQL Server/Scripts/DropPersistenceObjects.sql‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
/*
22
Company: OptimaJet
33
Project: WorkflowEngine.NET Provider for MSSQL
4-
Version: 3.1
4+
Version: 3.2
55
File: DropPersistenceObjects.sql
66
*/
77

‎Provider for MongoDB/Properties/AssemblyInfo.cs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,5 +32,5 @@
3232
// You can specify all the values or you can default the Build and Revision Numbers
3333
// by using the '*' as shown below:
3434
// [assembly: AssemblyVersion("1.0.*")]
35-
[assembly: AssemblyVersion("3.1.0")]
36-
[assembly: AssemblyFileVersion("3.1.0")]
35+
[assembly: AssemblyVersion("3.2.0")]
36+
[assembly: AssemblyFileVersion("3.2.0")]

‎Provider for MySQL/DbObject.cs‎

Lines changed: 22 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
using System.Collections.Generic;
44
using System.Data;
55
using System.Linq;
6+
using System.Threading.Tasks;
67

78
namespace OptimaJet.Workflow.MySQL
89
{
@@ -114,10 +115,15 @@ public static int ExecuteCommand(MySqlConnection connection, string commandText,
114115
}
115116

116117
public static T[] Select(MySqlConnection connection, string commandText, params MySqlParameter[] parameters)
118+
{
119+
return SelectAsync(connection, commandText, parameters).Result;
120+
}
121+
122+
public static async Task<T[]> SelectAsync(MySqlConnection connection, string commandText, params MySqlParameter[] parameters)
117123
{
118124
if (connection.State != ConnectionState.Open)
119125
{
120-
connection.Open();
126+
await connection.OpenAsync().ConfigureAwait(false);
121127
}
122128

123129
using (var command = connection.CreateCommand())
@@ -126,21 +132,23 @@ public static T[] Select(MySqlConnection connection, string commandText, params
126132
command.CommandText = commandText;
127133
command.CommandType = CommandType.Text;
128134
command.Parameters.AddRange(parameters);
129-
130-
var dt = new DataTable();
131-
using (var oda = new MySqlDataAdapter(command))
132-
{
133-
oda.Fill(dt);
134-
}
135-
136135
var res = new List<T>();
137-
138-
foreach (DataRow row in dt.Rows)
136+
using (var reader = await command.ExecuteReaderAsync().ConfigureAwait(false))
139137
{
140-
T item = new T();
141-
foreach (var c in item.DBColumns)
142-
item.SetValue(c.Name, row[c.Name]);
143-
res.Add(item);
138+
while (await reader.ReadAsync().ConfigureAwait(false))
139+
{
140+
T item = new T();
141+
for (int i = 0; i < reader.FieldCount; i++)
142+
{
143+
var name = reader.GetName(i);
144+
var column = item.DBColumns.FirstOrDefault(c => c.Name.Equals(name, StringComparison.OrdinalIgnoreCase));
145+
if (column != null)
146+
{
147+
item.SetValue(column.Name, reader.IsDBNull(i) ? null : reader.GetValue(i));
148+
}
149+
}
150+
res.Add(item);
151+
}
144152
}
145153

146154
return res.ToArray();

‎Provider for MySQL/OptimaJet.Workflow.MySQL.csproj‎

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -41,9 +41,8 @@
4141
<AssemblyOriginatorKeyFile>Workflow.snk</AssemblyOriginatorKeyFile>
4242
</PropertyGroup>
4343
<ItemGroup>
44-
<Reference Include="MySql.Data, Version=6.9.8.0, Culture=neutral, PublicKeyToken=c5687fc88969c44d, processorArchitecture=MSIL">
45-
<SpecificVersion>False</SpecificVersion>
46-
<HintPath>..\DLL\MySql.Data.dll</HintPath>
44+
<Reference Include="MySql.Data, Version=6.9.12.0, Culture=neutral, PublicKeyToken=c5687fc88969c44d, processorArchitecture=MSIL">
45+
<HintPath>..\packages\MySql.Data.6.9.12\lib\net45\MySql.Data.dll</HintPath>
4746
</Reference>
4847
<Reference Include="Newtonsoft.Json">
4948
<HintPath>..\DLL\Newtonsoft.Json.dll</HintPath>

‎Provider for MySQL/Properties/AssemblyInfo.cs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,5 +32,5 @@
3232
// You can specify all the values or you can default the Build and Revision Numbers
3333
// by using the '*' as shown below:
3434
// [assembly: AssemblyVersion("1.0.*")]
35-
[assembly: AssemblyVersion("3.1.0")]
36-
[assembly: AssemblyFileVersion("3.1.0")]
35+
[assembly: AssemblyVersion("3.2.0")]
36+
[assembly: AssemblyFileVersion("3.2.0")]

‎Provider for MySQL/Scripts/CreatePersistenceObjects.sql‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
/*
44
Company: OptimaJet
55
Project: WorkflowEngine.NET Provider for MySQL
6-
Version: 3.1
6+
Version: 3.2
77
File: CreatePersistenceObjects.sql
88
*/
99

‎Provider for MySQL/Scripts/DropPersistenceObjects.sql‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
/*
22
Company: OptimaJet
33
Project: WorkflowEngine.NET Provider for MySQL
4-
Version: 3.1
4+
Version: 3.2
55
File: DropPersistenceObjects.sql
66
*/
77

0 commit comments

Comments
 (0)