blob: 92892f1343942306844711e6e191e931af6bb69d (
plain)
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
|
using System.Collections.Generic;
using System.Data;
using Marina.DataAccess.Builders;
using Marina.Infrastructure;
using Marina.Infrastructure.Container;
namespace Marina.DataAccess {
public class DatabaseGateway : IDatabaseGateway {
private readonly IDatabaseConnectionFactory _connectionFactory;
public DatabaseGateway() : this( Resolve.DependencyFor< IDatabaseConnectionFactory >( ) ) {}
public DatabaseGateway( IDatabaseConnectionFactory connectionFactory ) {
_connectionFactory = connectionFactory;
}
public DataTable LoadTableUsing( string sqlQuery ) {
using ( IDatabaseConnection connection = _connectionFactory.Create( ) ) {
IDatabaseCommand command = connection.CreateCommandFor( sqlQuery );
return ( null != command ) ? command.ExecuteQuery( ) : null;
}
}
public IEnumerable< IDatabaseRow > FindAllRowsMatching( IQuery query ) {
using ( IDatabaseConnection connection = _connectionFactory.Create( ) ) {
DataTable table = connection.CreateCommandFor( query ).ExecuteQuery( );
if ( null != table ) {
foreach ( DataRow row in table.Rows ) {
yield return new DatabaseRow( row );
}
}
}
}
public void Execute( params IQuery[] queries ) {
Execute( ListFactory.From( queries ) );
}
public void Execute( IEnumerable< IQuery > queries ) {
using ( IDatabaseConnection connection = _connectionFactory.Create( ) ) {
foreach ( IQuery query in queries ) {
connection.CreateCommandFor( query ).ExecuteQuery( );
}
}
}
public long ExecuteScalar( IQuery query ) {
using ( IDatabaseConnection connection = _connectionFactory.Create( ) ) {
return connection.CreateCommandFor( query ).ExecuteScalarQuery( );
}
}
public IDatabaseRow LoadRowUsing( IQuery query ) {
using ( IDatabaseConnection connection = _connectionFactory.Create( ) ) {
DataTable table = connection.CreateCommandFor( query ).ExecuteQuery( );
return table.Rows.Count > 0 ? new DatabaseRow( table.Rows[ 0 ] ) : DatabaseRow.Blank;
}
}
}
}
|
