aboutsummaryrefslogtreecommitdiffstatshomepage
diff options
context:
space:
mode:
authorJeff Ames2008-01-14 16:47:36 +0000
committerJeff Ames2008-01-14 16:47:36 +0000
commit6716668187675d5950d2b3a7a925da7327440ca1 (patch)
treea1448cee1cf162b0d5c0e755fae5b956f465ec51
parentRemove unused SOG constructor (diff)
downloadopensim-SC-6716668187675d5950d2b3a7a925da7327440ca1.zip
opensim-SC-6716668187675d5950d2b3a7a925da7327440ca1.tar.gz
opensim-SC-6716668187675d5950d2b3a7a925da7327440ca1.tar.bz2
opensim-SC-6716668187675d5950d2b3a7a925da7327440ca1.tar.xz
Set svn:eol-style.
Diffstat
-rw-r--r--ThirdParty/TribalMedia/TribalMedia.Framework.Data/DataReader.cs298
-rw-r--r--ThirdParty/TribalMedia/TribalMedia.Framework.Data/DatabaseMapper.cs268
-rw-r--r--ThirdParty/TribalMedia/TribalMedia.Framework.Data/FieldMapper.cs496
-rw-r--r--ThirdParty/TribalMedia/TribalMedia.Framework.Data/ObjectTableMapper.cs322
-rw-r--r--ThirdParty/TribalMedia/TribalMedia.Framework.Data/Properties/AssemblyInfo.cs78
-rw-r--r--ThirdParty/TribalMedia/TribalMedia.Framework.Data/RowMapper.cs168
-rw-r--r--ThirdParty/TribalMedia/TribalMedia.Framework.Data/Schema.cs176
-rw-r--r--ThirdParty/TribalMedia/TribalMedia.Framework.Data/TableMapper.cs214
8 files changed, 1010 insertions, 1010 deletions
diff --git a/ThirdParty/TribalMedia/TribalMedia.Framework.Data/DataReader.cs b/ThirdParty/TribalMedia/TribalMedia.Framework.Data/DataReader.cs
index f0b3e88..6f84d43 100644
--- a/ThirdParty/TribalMedia/TribalMedia.Framework.Data/DataReader.cs
+++ b/ThirdParty/TribalMedia/TribalMedia.Framework.Data/DataReader.cs
@@ -1,150 +1,150 @@
1/* 1/*
2* Copyright (c) Tribal Media AB, http://tribalmedia.se/ 2* Copyright (c) Tribal Media AB, http://tribalmedia.se/
3* 3*
4* Redistribution and use in source and binary forms, with or without 4* Redistribution and use in source and binary forms, with or without
5* modification, are permitted provided that the following conditions are met: 5* modification, are permitted provided that the following conditions are met:
6* * Redistributions of source code must retain the above copyright 6* * Redistributions of source code must retain the above copyright
7* notice, this list of conditions and the following disclaimer. 7* notice, this list of conditions and the following disclaimer.
8* * Redistributions in binary form must reproduce the above copyright 8* * Redistributions in binary form must reproduce the above copyright
9* notice, this list of conditions and the following disclaimer in the 9* notice, this list of conditions and the following disclaimer in the
10* documentation and/or other materials provided with the distribution. 10* documentation and/or other materials provided with the distribution.
11* * The name of Tribal Media AB may not be used to endorse or promote products 11* * The name of Tribal Media AB may not be used to endorse or promote products
12* derived from this software without specific prior written permission. 12* derived from this software without specific prior written permission.
13* 13*
14* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY 14* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
15* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 15* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
16* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 16* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
17* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY 17* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
18* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES 18* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
19* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 19* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
20* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND 20* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
21* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 21* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
22* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS 22* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
23* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 23* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
24* 24*
25*/ 25*/
26 26
27using System; 27using System;
28using System.Data; 28using System.Data;
29using System.IO; 29using System.IO;
30 30
31namespace TribalMedia.Framework.Data 31namespace TribalMedia.Framework.Data
32{ 32{
33 public class DataReader 33 public class DataReader
34 { 34 {
35 private readonly IDataReader m_source; 35 private readonly IDataReader m_source;
36 36
37 public DataReader(IDataReader source) 37 public DataReader(IDataReader source)
38 { 38 {
39 m_source = source; 39 m_source = source;
40 } 40 }
41 41
42 public object Get(string name) 42 public object Get(string name)
43 { 43 {
44 return m_source[name]; 44 return m_source[name];
45 } 45 }
46 46
47 public ushort GetUShort(string name) 47 public ushort GetUShort(string name)
48 { 48 {
49 return (ushort) m_source.GetInt32(m_source.GetOrdinal(name)); 49 return (ushort) m_source.GetInt32(m_source.GetOrdinal(name));
50 } 50 }
51 51
52 public byte GetByte(string name) 52 public byte GetByte(string name)
53 { 53 {
54 int ordinal = m_source.GetOrdinal(name); 54 int ordinal = m_source.GetOrdinal(name);
55 byte value = (byte) m_source.GetInt16(ordinal); 55 byte value = (byte) m_source.GetInt16(ordinal);
56 return value; 56 return value;
57 } 57 }
58 58
59 public sbyte GetSByte(string name) 59 public sbyte GetSByte(string name)
60 { 60 {
61 return (sbyte) m_source.GetInt16(m_source.GetOrdinal(name)); 61 return (sbyte) m_source.GetInt16(m_source.GetOrdinal(name));
62 } 62 }
63 63
64 //public Vector3 GetVector(string s) 64 //public Vector3 GetVector(string s)
65 //{ 65 //{
66 // float x = GetFloat(s + "X"); 66 // float x = GetFloat(s + "X");
67 // float y = GetFloat(s + "Y"); 67 // float y = GetFloat(s + "Y");
68 // float z = GetFloat(s + "Z"); 68 // float z = GetFloat(s + "Z");
69 69
70 // Vector3 vector = new Vector3(x, y, z); 70 // Vector3 vector = new Vector3(x, y, z);
71 71
72 // return vector; 72 // return vector;
73 //} 73 //}
74 74
75 //public Quaternion GetQuaternion(string s) 75 //public Quaternion GetQuaternion(string s)
76 //{ 76 //{
77 // float x = GetFloat(s + "X"); 77 // float x = GetFloat(s + "X");
78 // float y = GetFloat(s + "Y"); 78 // float y = GetFloat(s + "Y");
79 // float z = GetFloat(s + "Z"); 79 // float z = GetFloat(s + "Z");
80 // float w = GetFloat(s + "W"); 80 // float w = GetFloat(s + "W");
81 81
82 // Quaternion quaternion = new Quaternion(x, y, z, w); 82 // Quaternion quaternion = new Quaternion(x, y, z, w);
83 83
84 // return quaternion; 84 // return quaternion;
85 //} 85 //}
86 86
87 public float GetFloat(string name) 87 public float GetFloat(string name)
88 { 88 {
89 return m_source.GetFloat(m_source.GetOrdinal(name)); 89 return m_source.GetFloat(m_source.GetOrdinal(name));
90 } 90 }
91 91
92 public byte[] GetBytes(string name) 92 public byte[] GetBytes(string name)
93 { 93 {
94 int ordinal = m_source.GetOrdinal(name); 94 int ordinal = m_source.GetOrdinal(name);
95 95
96 if (m_source.GetValue(ordinal) == DBNull.Value) 96 if (m_source.GetValue(ordinal) == DBNull.Value)
97 { 97 {
98 return null; 98 return null;
99 } 99 }
100 100
101 byte[] buffer = new byte[16384]; 101 byte[] buffer = new byte[16384];
102 102
103 MemoryStream memStream = new MemoryStream(); 103 MemoryStream memStream = new MemoryStream();
104 104
105 long totalRead = 0; 105 long totalRead = 0;
106 106
107 int bytesRead; 107 int bytesRead;
108 do 108 do
109 { 109 {
110 bytesRead = (int) m_source.GetBytes(ordinal, totalRead, buffer, 0, buffer.Length); 110 bytesRead = (int) m_source.GetBytes(ordinal, totalRead, buffer, 0, buffer.Length);
111 totalRead += bytesRead; 111 totalRead += bytesRead;
112 112
113 memStream.Write(buffer, 0, bytesRead); 113 memStream.Write(buffer, 0, bytesRead);
114 } while (bytesRead == buffer.Length); 114 } while (bytesRead == buffer.Length);
115 115
116 return memStream.ToArray(); 116 return memStream.ToArray();
117 } 117 }
118 118
119 public string GetString(string name) 119 public string GetString(string name)
120 { 120 {
121 int ordinal = m_source.GetOrdinal(name); 121 int ordinal = m_source.GetOrdinal(name);
122 object value = m_source.GetValue(ordinal); 122 object value = m_source.GetValue(ordinal);
123 123
124 if (value is DBNull) 124 if (value is DBNull)
125 { 125 {
126 return null; 126 return null;
127 } 127 }
128 128
129 return (string) value; 129 return (string) value;
130 } 130 }
131 131
132 public bool Read() 132 public bool Read()
133 { 133 {
134 return m_source.Read(); 134 return m_source.Read();
135 } 135 }
136 136
137 internal Guid GetGuid(string name) 137 internal Guid GetGuid(string name)
138 { 138 {
139 string guidString = GetString(name); 139 string guidString = GetString(name);
140 if (String.IsNullOrEmpty(guidString)) 140 if (String.IsNullOrEmpty(guidString))
141 { 141 {
142 return Guid.Empty; 142 return Guid.Empty;
143 } 143 }
144 else 144 else
145 { 145 {
146 return new Guid(guidString); 146 return new Guid(guidString);
147 } 147 }
148 } 148 }
149 } 149 }
150} \ No newline at end of file 150} \ No newline at end of file
diff --git a/ThirdParty/TribalMedia/TribalMedia.Framework.Data/DatabaseMapper.cs b/ThirdParty/TribalMedia/TribalMedia.Framework.Data/DatabaseMapper.cs
index fe31177..0b9d16d 100644
--- a/ThirdParty/TribalMedia/TribalMedia.Framework.Data/DatabaseMapper.cs
+++ b/ThirdParty/TribalMedia/TribalMedia.Framework.Data/DatabaseMapper.cs
@@ -1,135 +1,135 @@
1/* 1/*
2* Copyright (c) Tribal Media AB, http://tribalmedia.se/ 2* Copyright (c) Tribal Media AB, http://tribalmedia.se/
3* 3*
4* Redistribution and use in source and binary forms, with or without 4* Redistribution and use in source and binary forms, with or without
5* modification, are permitted provided that the following conditions are met: 5* modification, are permitted provided that the following conditions are met:
6* * Redistributions of source code must retain the above copyright 6* * Redistributions of source code must retain the above copyright
7* notice, this list of conditions and the following disclaimer. 7* notice, this list of conditions and the following disclaimer.
8* * Redistributions in binary form must reproduce the above copyright 8* * Redistributions in binary form must reproduce the above copyright
9* notice, this list of conditions and the following disclaimer in the 9* notice, this list of conditions and the following disclaimer in the
10* documentation and/or other materials provided with the distribution. 10* documentation and/or other materials provided with the distribution.
11* * The name of Tribal Media AB may not be used to endorse or promote products 11* * The name of Tribal Media AB may not be used to endorse or promote products
12* derived from this software without specific prior written permission. 12* derived from this software without specific prior written permission.
13* 13*
14* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY 14* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
15* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 15* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
16* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 16* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
17* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY 17* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
18* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES 18* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
19* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 19* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
20* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND 20* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
21* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 21* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
22* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS 22* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
23* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 23* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
24* 24*
25*/ 25*/
26 26
27using System; 27using System;
28using System.Collections.Generic; 28using System.Collections.Generic;
29using System.Data; 29using System.Data;
30using System.Data.Common; 30using System.Data.Common;
31 31
32namespace TribalMedia.Framework.Data 32namespace TribalMedia.Framework.Data
33{ 33{
34 public abstract class DatabaseMapper 34 public abstract class DatabaseMapper
35 { 35 {
36 protected string m_connectionString; 36 protected string m_connectionString;
37 37
38 public DatabaseMapper(string connectionString) 38 public DatabaseMapper(string connectionString)
39 { 39 {
40 m_connectionString = connectionString; 40 m_connectionString = connectionString;
41 } 41 }
42 42
43 public abstract DbConnection GetNewConnection(); 43 public abstract DbConnection GetNewConnection();
44 44
45 public abstract string CreateParamName(string fieldName); 45 public abstract string CreateParamName(string fieldName);
46 46
47 public DbCommand CreateSelectCommand(TableMapper mapper, DbConnection connection, string fieldName, object key) 47 public DbCommand CreateSelectCommand(TableMapper mapper, DbConnection connection, string fieldName, object key)
48 { 48 {
49 string table = mapper.TableName; 49 string table = mapper.TableName;
50 50
51 DbCommand command = connection.CreateCommand(); 51 DbCommand command = connection.CreateCommand();
52 52
53 string conditionString = CreateCondition(mapper, command, fieldName, key); 53 string conditionString = CreateCondition(mapper, command, fieldName, key);
54 54
55 string query = 55 string query =
56 String.Format("select * from {0} where {1}", table, conditionString); 56 String.Format("select * from {0} where {1}", table, conditionString);
57 57
58 command.CommandText = query; 58 command.CommandText = query;
59 command.CommandType = CommandType.Text; 59 command.CommandType = CommandType.Text;
60 60
61 return command; 61 return command;
62 } 62 }
63 63
64 public string CreateCondition(TableMapper mapper, DbCommand command, string fieldName, object key) 64 public string CreateCondition(TableMapper mapper, DbCommand command, string fieldName, object key)
65 { 65 {
66 string keyFieldParamName = mapper.CreateParamName(fieldName); 66 string keyFieldParamName = mapper.CreateParamName(fieldName);
67 67
68 DbParameter param = command.CreateParameter(); 68 DbParameter param = command.CreateParameter();
69 param.ParameterName = keyFieldParamName; 69 param.ParameterName = keyFieldParamName;
70 param.Value = FieldMapper.ConvertToDbType(key); 70 param.Value = FieldMapper.ConvertToDbType(key);
71 command.Parameters.Add(param); 71 command.Parameters.Add(param);
72 72
73 return String.Format("{0}={1}", fieldName, keyFieldParamName); 73 return String.Format("{0}={1}", fieldName, keyFieldParamName);
74 } 74 }
75 75
76 public DbCommand CreateUpdateCommand(TableMapper mapper, DbConnection connection, object rowMapper, object primaryKey) 76 public DbCommand CreateUpdateCommand(TableMapper mapper, DbConnection connection, object rowMapper, object primaryKey)
77 { 77 {
78 string table = mapper.TableName; 78 string table = mapper.TableName;
79 79
80 List<string> fieldNames = new List<string>(); 80 List<string> fieldNames = new List<string>();
81 81
82 DbCommand command = connection.CreateCommand(); 82 DbCommand command = connection.CreateCommand();
83 83
84 foreach (FieldMapper fieldMapper in mapper.Schema.Fields.Values) 84 foreach (FieldMapper fieldMapper in mapper.Schema.Fields.Values)
85 { 85 {
86 if (fieldMapper != mapper.KeyFieldMapper) 86 if (fieldMapper != mapper.KeyFieldMapper)
87 { 87 {
88 fieldMapper.ExpandField(rowMapper, command, fieldNames); 88 fieldMapper.ExpandField(rowMapper, command, fieldNames);
89 } 89 }
90 } 90 }
91 91
92 List<string> assignments = new List<string>(); 92 List<string> assignments = new List<string>();
93 93
94 foreach (string field in fieldNames) 94 foreach (string field in fieldNames)
95 { 95 {
96 assignments.Add(String.Format("{0}={1}", field, mapper.CreateParamName(field))); 96 assignments.Add(String.Format("{0}={1}", field, mapper.CreateParamName(field)));
97 } 97 }
98 98
99 string conditionString = mapper.CreateCondition(command, mapper.KeyFieldMapper.FieldName, primaryKey); 99 string conditionString = mapper.CreateCondition(command, mapper.KeyFieldMapper.FieldName, primaryKey);
100 100
101 command.CommandText = 101 command.CommandText =
102 String.Format("update {0} set {1} where {2}", table, String.Join(", ", assignments.ToArray()), 102 String.Format("update {0} set {1} where {2}", table, String.Join(", ", assignments.ToArray()),
103 conditionString); 103 conditionString);
104 104
105 return command; 105 return command;
106 } 106 }
107 107
108 public DbCommand CreateInsertCommand(TableMapper mapper, DbConnection connection, object obj) 108 public DbCommand CreateInsertCommand(TableMapper mapper, DbConnection connection, object obj)
109 { 109 {
110 string table = mapper.TableName; 110 string table = mapper.TableName;
111 111
112 List<string> fieldNames = new List<string>(); 112 List<string> fieldNames = new List<string>();
113 113
114 DbCommand command = connection.CreateCommand(); 114 DbCommand command = connection.CreateCommand();
115 115
116 foreach (FieldMapper fieldMapper in mapper.Schema.Fields.Values) 116 foreach (FieldMapper fieldMapper in mapper.Schema.Fields.Values)
117 { 117 {
118 fieldMapper.ExpandField(obj, command, fieldNames); 118 fieldMapper.ExpandField(obj, command, fieldNames);
119 } 119 }
120 120
121 List<string> paramNames = new List<string>(); 121 List<string> paramNames = new List<string>();
122 122
123 foreach (string field in fieldNames) 123 foreach (string field in fieldNames)
124 { 124 {
125 paramNames.Add(mapper.CreateParamName(field)); 125 paramNames.Add(mapper.CreateParamName(field));
126 } 126 }
127 127
128 command.CommandText = 128 command.CommandText =
129 String.Format("insert into {0} ({1}) values ({2})", table, String.Join(", ", fieldNames.ToArray()), 129 String.Format("insert into {0} ({1}) values ({2})", table, String.Join(", ", fieldNames.ToArray()),
130 String.Join(", ", paramNames.ToArray())); 130 String.Join(", ", paramNames.ToArray()));
131 131
132 return command; 132 return command;
133 } 133 }
134 } 134 }
135} \ No newline at end of file 135} \ No newline at end of file
diff --git a/ThirdParty/TribalMedia/TribalMedia.Framework.Data/FieldMapper.cs b/ThirdParty/TribalMedia/TribalMedia.Framework.Data/FieldMapper.cs
index 28a603a..a1fafbe 100644
--- a/ThirdParty/TribalMedia/TribalMedia.Framework.Data/FieldMapper.cs
+++ b/ThirdParty/TribalMedia/TribalMedia.Framework.Data/FieldMapper.cs
@@ -1,249 +1,249 @@
1/* 1/*
2* Copyright (c) Tribal Media AB, http://tribalmedia.se/ 2* Copyright (c) Tribal Media AB, http://tribalmedia.se/
3* 3*
4* Redistribution and use in source and binary forms, with or without 4* Redistribution and use in source and binary forms, with or without
5* modification, are permitted provided that the following conditions are met: 5* modification, are permitted provided that the following conditions are met:
6* * Redistributions of source code must retain the above copyright 6* * Redistributions of source code must retain the above copyright
7* notice, this list of conditions and the following disclaimer. 7* notice, this list of conditions and the following disclaimer.
8* * Redistributions in binary form must reproduce the above copyright 8* * Redistributions in binary form must reproduce the above copyright
9* notice, this list of conditions and the following disclaimer in the 9* notice, this list of conditions and the following disclaimer in the
10* documentation and/or other materials provided with the distribution. 10* documentation and/or other materials provided with the distribution.
11* * The name of Tribal Media AB may not be used to endorse or promote products 11* * The name of Tribal Media AB may not be used to endorse or promote products
12* derived from this software without specific prior written permission. 12* derived from this software without specific prior written permission.
13* 13*
14* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY 14* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
15* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 15* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
16* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 16* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
17* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY 17* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
18* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES 18* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
19* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 19* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
20* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND 20* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
21* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 21* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
22* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS 22* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
23* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 23* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
24* 24*
25*/ 25*/
26 26
27using System; 27using System;
28using System.Collections.Generic; 28using System.Collections.Generic;
29using System.Data.Common; 29using System.Data.Common;
30 30
31namespace TribalMedia.Framework.Data 31namespace TribalMedia.Framework.Data
32{ 32{
33 public delegate TField RowMapperGetAccessor<TRowMapper, TField>(TRowMapper rowMapper); 33 public delegate TField RowMapperGetAccessor<TRowMapper, TField>(TRowMapper rowMapper);
34 34
35 public delegate void RowMapperSetAccessor<TRowMapper, TField>(TRowMapper rowMapper, TField value); 35 public delegate void RowMapperSetAccessor<TRowMapper, TField>(TRowMapper rowMapper, TField value);
36 36
37 public delegate TField ObjectGetAccessor<TObj, TField>(TObj obj); 37 public delegate TField ObjectGetAccessor<TObj, TField>(TObj obj);
38 38
39 public delegate void ObjectSetAccessor<TObj, TField>(TObj obj, TField value); 39 public delegate void ObjectSetAccessor<TObj, TField>(TObj obj, TField value);
40 40
41 public abstract class FieldMapper 41 public abstract class FieldMapper
42 { 42 {
43 private readonly TableMapper m_tableMapper; 43 private readonly TableMapper m_tableMapper;
44 private readonly string m_fieldName; 44 private readonly string m_fieldName;
45 45
46 public string FieldName 46 public string FieldName
47 { 47 {
48 get { return m_fieldName; } 48 get { return m_fieldName; }
49 } 49 }
50 50
51 protected Type m_valueType; 51 protected Type m_valueType;
52 52
53 public Type ValueType 53 public Type ValueType
54 { 54 {
55 get { return m_valueType; } 55 get { return m_valueType; }
56 } 56 }
57 57
58 public abstract object GetParamValue(object obj); 58 public abstract object GetParamValue(object obj);
59 59
60 public FieldMapper( TableMapper tableMapper, string fieldName, Type valueType) 60 public FieldMapper( TableMapper tableMapper, string fieldName, Type valueType)
61 { 61 {
62 m_fieldName = fieldName; 62 m_fieldName = fieldName;
63 m_valueType = valueType; 63 m_valueType = valueType;
64 m_tableMapper = tableMapper; 64 m_tableMapper = tableMapper;
65 } 65 }
66 66
67 public abstract void SetPropertyFromReader(object mapper, DataReader reader); 67 public abstract void SetPropertyFromReader(object mapper, DataReader reader);
68 68
69 public void RawAddParam(DbCommand command, List<string> fieldNames, string fieldName, object value) 69 public void RawAddParam(DbCommand command, List<string> fieldNames, string fieldName, object value)
70 { 70 {
71 string paramName = m_tableMapper.CreateParamName(fieldName); 71 string paramName = m_tableMapper.CreateParamName(fieldName);
72 fieldNames.Add(fieldName); 72 fieldNames.Add(fieldName);
73 73
74 DbParameter param = command.CreateParameter(); 74 DbParameter param = command.CreateParameter();
75 param.ParameterName = paramName; 75 param.ParameterName = paramName;
76 param.Value = value; 76 param.Value = value;
77 77
78 command.Parameters.Add(param); 78 command.Parameters.Add(param);
79 } 79 }
80 80
81 public void ExpandField<TObj>(TObj obj, DbCommand command, List<string> fieldNames) 81 public void ExpandField<TObj>(TObj obj, DbCommand command, List<string> fieldNames)
82 { 82 {
83 string fieldName = FieldName; 83 string fieldName = FieldName;
84 object value = GetParamValue(obj); 84 object value = GetParamValue(obj);
85 85
86 //if (ValueType == typeof (Vector3)) 86 //if (ValueType == typeof (Vector3))
87 //{ 87 //{
88 // Vector3 vector = (Vector3) value; 88 // Vector3 vector = (Vector3) value;
89 89
90 // RawAddParam(command, fieldNames, fieldName + "X", vector.X); 90 // RawAddParam(command, fieldNames, fieldName + "X", vector.X);
91 // RawAddParam(command, fieldNames, fieldName + "Y", vector.Y); 91 // RawAddParam(command, fieldNames, fieldName + "Y", vector.Y);
92 // RawAddParam(command, fieldNames, fieldName + "Z", vector.Z); 92 // RawAddParam(command, fieldNames, fieldName + "Z", vector.Z);
93 //} 93 //}
94 //else if (ValueType == typeof (Quaternion)) 94 //else if (ValueType == typeof (Quaternion))
95 //{ 95 //{
96 // Quaternion quaternion = (Quaternion) value; 96 // Quaternion quaternion = (Quaternion) value;
97 97
98 // RawAddParam(command, fieldNames, fieldName + "X", quaternion.X); 98 // RawAddParam(command, fieldNames, fieldName + "X", quaternion.X);
99 // RawAddParam(command, fieldNames, fieldName + "Y", quaternion.Y); 99 // RawAddParam(command, fieldNames, fieldName + "Y", quaternion.Y);
100 // RawAddParam(command, fieldNames, fieldName + "Z", quaternion.Z); 100 // RawAddParam(command, fieldNames, fieldName + "Z", quaternion.Z);
101 // RawAddParam(command, fieldNames, fieldName + "W", quaternion.W); 101 // RawAddParam(command, fieldNames, fieldName + "W", quaternion.W);
102 //} 102 //}
103 //else 103 //else
104 //{ 104 //{
105 RawAddParam(command, fieldNames, fieldName, ConvertToDbType(value)); 105 RawAddParam(command, fieldNames, fieldName, ConvertToDbType(value));
106 //} 106 //}
107 } 107 }
108 108
109 protected object GetValue(DataReader reader) 109 protected object GetValue(DataReader reader)
110 { 110 {
111 object value; 111 object value;
112 //if (ValueType == typeof (Vector3)) 112 //if (ValueType == typeof (Vector3))
113 //{ 113 //{
114 // value = reader.GetVector(m_fieldName); 114 // value = reader.GetVector(m_fieldName);
115 //} 115 //}
116 //else if (ValueType == typeof (Quaternion)) 116 //else if (ValueType == typeof (Quaternion))
117 //{ 117 //{
118 // value = reader.GetQuaternion(m_fieldName); 118 // value = reader.GetQuaternion(m_fieldName);
119 //} 119 //}
120 //else 120 //else
121 //if (ValueType == typeof(UID)) 121 //if (ValueType == typeof(UID))
122 //{ 122 //{
123 // Guid guid = reader.GetGuid(m_fieldName); 123 // Guid guid = reader.GetGuid(m_fieldName);
124 // value = new UID(guid); 124 // value = new UID(guid);
125 //} 125 //}
126 //else 126 //else
127 if (ValueType == typeof(Guid)) 127 if (ValueType == typeof(Guid))
128 { 128 {
129 value = reader.GetGuid(m_fieldName); 129 value = reader.GetGuid(m_fieldName);
130 } 130 }
131 else if (ValueType == typeof (bool)) 131 else if (ValueType == typeof (bool))
132 { 132 {
133 uint boolVal = reader.GetUShort(m_fieldName); 133 uint boolVal = reader.GetUShort(m_fieldName);
134 value = (boolVal == 1); 134 value = (boolVal == 1);
135 } 135 }
136 else 136 else
137 if (ValueType == typeof (byte)) 137 if (ValueType == typeof (byte))
138 { 138 {
139 value = reader.GetByte(m_fieldName); 139 value = reader.GetByte(m_fieldName);
140 } 140 }
141 else if (ValueType == typeof (sbyte)) 141 else if (ValueType == typeof (sbyte))
142 { 142 {
143 value = reader.GetSByte(m_fieldName); 143 value = reader.GetSByte(m_fieldName);
144 } 144 }
145 else if (ValueType == typeof (ushort)) 145 else if (ValueType == typeof (ushort))
146 { 146 {
147 value = reader.GetUShort(m_fieldName); 147 value = reader.GetUShort(m_fieldName);
148 } 148 }
149 else if (ValueType == typeof (byte[])) 149 else if (ValueType == typeof (byte[]))
150 { 150 {
151 value = reader.GetBytes(m_fieldName); 151 value = reader.GetBytes(m_fieldName);
152 } 152 }
153 else 153 else
154 { 154 {
155 value = reader.Get(m_fieldName); 155 value = reader.Get(m_fieldName);
156 } 156 }
157 157
158 if (value is DBNull) 158 if (value is DBNull)
159 { 159 {
160 value = default(ValueType); 160 value = default(ValueType);
161 } 161 }
162 162
163 return value; 163 return value;
164 } 164 }
165 165
166 public static object ConvertToDbType(object value) 166 public static object ConvertToDbType(object value)
167 { 167 {
168 //if (value is UID) 168 //if (value is UID)
169 //{ 169 //{
170 // return (value as UID).UUID.ToString(); 170 // return (value as UID).UUID.ToString();
171 //} 171 //}
172 172
173 return value; 173 return value;
174 } 174 }
175 } 175 }
176 176
177 public class RowMapperField<TRowMapper, TField> : FieldMapper 177 public class RowMapperField<TRowMapper, TField> : FieldMapper
178 where TRowMapper : RowMapper 178 where TRowMapper : RowMapper
179 { 179 {
180 private readonly RowMapperGetAccessor<TRowMapper, TField> m_fieldGetAccessor; 180 private readonly RowMapperGetAccessor<TRowMapper, TField> m_fieldGetAccessor;
181 private readonly RowMapperSetAccessor<TRowMapper, TField> m_fieldSetAccessor; 181 private readonly RowMapperSetAccessor<TRowMapper, TField> m_fieldSetAccessor;
182 182
183 public override object GetParamValue(object obj) 183 public override object GetParamValue(object obj)
184 { 184 {
185 return m_fieldGetAccessor((TRowMapper) obj); 185 return m_fieldGetAccessor((TRowMapper) obj);
186 } 186 }
187 187
188 public override void SetPropertyFromReader(object mapper, DataReader reader) 188 public override void SetPropertyFromReader(object mapper, DataReader reader)
189 { 189 {
190 object value; 190 object value;
191 191
192 value = GetValue(reader); 192 value = GetValue(reader);
193 193
194 if (value == null) 194 if (value == null)
195 { 195 {
196 m_fieldSetAccessor((TRowMapper) mapper, default(TField)); 196 m_fieldSetAccessor((TRowMapper) mapper, default(TField));
197 } 197 }
198 else 198 else
199 { 199 {
200 m_fieldSetAccessor((TRowMapper) mapper, (TField) value); 200 m_fieldSetAccessor((TRowMapper) mapper, (TField) value);
201 } 201 }
202 } 202 }
203 203
204 204
205 public RowMapperField(TableMapper tableMapper, string fieldName, RowMapperGetAccessor<TRowMapper, TField> rowMapperGetAccessor, 205 public RowMapperField(TableMapper tableMapper, string fieldName, RowMapperGetAccessor<TRowMapper, TField> rowMapperGetAccessor,
206 RowMapperSetAccessor<TRowMapper, TField> rowMapperSetAccessor) 206 RowMapperSetAccessor<TRowMapper, TField> rowMapperSetAccessor)
207 : base(tableMapper, fieldName, typeof(TField)) 207 : base(tableMapper, fieldName, typeof(TField))
208 { 208 {
209 m_fieldGetAccessor = rowMapperGetAccessor; 209 m_fieldGetAccessor = rowMapperGetAccessor;
210 m_fieldSetAccessor = rowMapperSetAccessor; 210 m_fieldSetAccessor = rowMapperSetAccessor;
211 } 211 }
212 } 212 }
213 213
214 public class ObjectField<TObject, TField> : FieldMapper 214 public class ObjectField<TObject, TField> : FieldMapper
215 { 215 {
216 private readonly ObjectGetAccessor<TObject, TField> m_fieldGetAccessor; 216 private readonly ObjectGetAccessor<TObject, TField> m_fieldGetAccessor;
217 private readonly ObjectSetAccessor<TObject, TField> m_fieldSetAccessor; 217 private readonly ObjectSetAccessor<TObject, TField> m_fieldSetAccessor;
218 218
219 public override object GetParamValue(object obj) 219 public override object GetParamValue(object obj)
220 { 220 {
221 return m_fieldGetAccessor((TObject) obj); 221 return m_fieldGetAccessor((TObject) obj);
222 } 222 }
223 223
224 public override void SetPropertyFromReader(object obj, DataReader reader) 224 public override void SetPropertyFromReader(object obj, DataReader reader)
225 { 225 {
226 object value; 226 object value;
227 227
228 value = GetValue(reader); 228 value = GetValue(reader);
229 229
230 if (value == null) 230 if (value == null)
231 { 231 {
232 m_fieldSetAccessor((TObject) obj, default(TField)); 232 m_fieldSetAccessor((TObject) obj, default(TField));
233 } 233 }
234 else 234 else
235 { 235 {
236 m_fieldSetAccessor((TObject) obj, (TField) value); 236 m_fieldSetAccessor((TObject) obj, (TField) value);
237 } 237 }
238 } 238 }
239 239
240 240
241 public ObjectField(TableMapper tableMapper, string fieldName, ObjectGetAccessor<TObject, TField> rowMapperGetAccessor, 241 public ObjectField(TableMapper tableMapper, string fieldName, ObjectGetAccessor<TObject, TField> rowMapperGetAccessor,
242 ObjectSetAccessor<TObject, TField> rowMapperSetAccessor) 242 ObjectSetAccessor<TObject, TField> rowMapperSetAccessor)
243 : base(tableMapper, fieldName, typeof (TField)) 243 : base(tableMapper, fieldName, typeof (TField))
244 { 244 {
245 m_fieldGetAccessor = rowMapperGetAccessor; 245 m_fieldGetAccessor = rowMapperGetAccessor;
246 m_fieldSetAccessor = rowMapperSetAccessor; 246 m_fieldSetAccessor = rowMapperSetAccessor;
247 } 247 }
248 } 248 }
249} \ No newline at end of file 249} \ No newline at end of file
diff --git a/ThirdParty/TribalMedia/TribalMedia.Framework.Data/ObjectTableMapper.cs b/ThirdParty/TribalMedia/TribalMedia.Framework.Data/ObjectTableMapper.cs
index 631a2ca..44a6542 100644
--- a/ThirdParty/TribalMedia/TribalMedia.Framework.Data/ObjectTableMapper.cs
+++ b/ThirdParty/TribalMedia/TribalMedia.Framework.Data/ObjectTableMapper.cs
@@ -1,162 +1,162 @@
1/* 1/*
2* Copyright (c) Tribal Media AB, http://tribalmedia.se/ 2* Copyright (c) Tribal Media AB, http://tribalmedia.se/
3* 3*
4* Redistribution and use in source and binary forms, with or without 4* Redistribution and use in source and binary forms, with or without
5* modification, are permitted provided that the following conditions are met: 5* modification, are permitted provided that the following conditions are met:
6* * Redistributions of source code must retain the above copyright 6* * Redistributions of source code must retain the above copyright
7* notice, this list of conditions and the following disclaimer. 7* notice, this list of conditions and the following disclaimer.
8* * Redistributions in binary form must reproduce the above copyright 8* * Redistributions in binary form must reproduce the above copyright
9* notice, this list of conditions and the following disclaimer in the 9* notice, this list of conditions and the following disclaimer in the
10* documentation and/or other materials provided with the distribution. 10* documentation and/or other materials provided with the distribution.
11* * The name of Tribal Media AB may not be used to endorse or promote products 11* * The name of Tribal Media AB may not be used to endorse or promote products
12* derived from this software without specific prior written permission. 12* derived from this software without specific prior written permission.
13* 13*
14* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY 14* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
15* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 15* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
16* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 16* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
17* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY 17* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
18* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES 18* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
19* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 19* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
20* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND 20* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
21* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 21* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
22* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS 22* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
23* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 23* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
24* 24*
25*/ 25*/
26 26
27using System; 27using System;
28using System.Collections.Generic; 28using System.Collections.Generic;
29using System.Data; 29using System.Data;
30using System.Data.Common; 30using System.Data.Common;
31using TribalMedia.Framework.Data; 31using TribalMedia.Framework.Data;
32 32
33namespace TribalMedia.Framework.Data 33namespace TribalMedia.Framework.Data
34{ 34{
35 public abstract class ObjectTableMapper<TRowMapper, TPrimaryKey> : TableMapper 35 public abstract class ObjectTableMapper<TRowMapper, TPrimaryKey> : TableMapper
36 { 36 {
37 public ObjectTableMapper(DatabaseMapper connectionPool, string tableName) 37 public ObjectTableMapper(DatabaseMapper connectionPool, string tableName)
38 : base(connectionPool, tableName) 38 : base(connectionPool, tableName)
39 { 39 {
40 } 40 }
41 41
42 public bool TryGetValue(TPrimaryKey primaryKey, out TRowMapper value) 42 public bool TryGetValue(TPrimaryKey primaryKey, out TRowMapper value)
43 { 43 {
44 TRowMapper result = default(TRowMapper); 44 TRowMapper result = default(TRowMapper);
45 bool success = false; 45 bool success = false;
46 46
47 WithConnection(delegate(DbConnection connection) 47 WithConnection(delegate(DbConnection connection)
48 { 48 {
49 using ( 49 using (
50 DbCommand command = 50 DbCommand command =
51 CreateSelectCommand(connection, KeyFieldMapper.FieldName, primaryKey)) 51 CreateSelectCommand(connection, KeyFieldMapper.FieldName, primaryKey))
52 { 52 {
53 using (IDataReader reader = command.ExecuteReader()) 53 using (IDataReader reader = command.ExecuteReader())
54 { 54 {
55 if (reader.Read()) 55 if (reader.Read())
56 { 56 {
57 result = FromReader(new DataReader(reader)); 57 result = FromReader(new DataReader(reader));
58 success = true; 58 success = true;
59 } 59 }
60 else 60 else
61 { 61 {
62 success = false; 62 success = false;
63 } 63 }
64 } 64 }
65 } 65 }
66 }); 66 });
67 67
68 value = result; 68 value = result;
69 69
70 return success; 70 return success;
71 } 71 }
72 72
73 73
74 public virtual bool Remove(TPrimaryKey id) 74 public virtual bool Remove(TPrimaryKey id)
75 { 75 {
76 int deleted = 0; 76 int deleted = 0;
77 77
78 WithConnection(delegate(DbConnection connection) 78 WithConnection(delegate(DbConnection connection)
79 { 79 {
80 using ( 80 using (
81 DbCommand command = 81 DbCommand command =
82 CreateDeleteCommand(connection, KeyFieldMapper.FieldName, id)) 82 CreateDeleteCommand(connection, KeyFieldMapper.FieldName, id))
83 { 83 {
84 deleted = command.ExecuteNonQuery(); 84 deleted = command.ExecuteNonQuery();
85 } 85 }
86 }); 86 });
87 87
88 if (deleted == 1) 88 if (deleted == 1)
89 { 89 {
90 return true; 90 return true;
91 } 91 }
92 else 92 else
93 { 93 {
94 return false; 94 return false;
95 } 95 }
96 } 96 }
97 97
98 98
99 public DbCommand CreateDeleteCommand(DbConnection connection, string fieldName, TPrimaryKey primaryKey) 99 public DbCommand CreateDeleteCommand(DbConnection connection, string fieldName, TPrimaryKey primaryKey)
100 { 100 {
101 string table = TableName; 101 string table = TableName;
102 102
103 DbCommand command = connection.CreateCommand(); 103 DbCommand command = connection.CreateCommand();
104 104
105 string conditionString = CreateCondition(command, fieldName, primaryKey); 105 string conditionString = CreateCondition(command, fieldName, primaryKey);
106 106
107 string query = 107 string query =
108 String.Format("delete from {0} where {1}", table, conditionString); 108 String.Format("delete from {0} where {1}", table, conditionString);
109 109
110 command.CommandText = query; 110 command.CommandText = query;
111 command.CommandType = CommandType.Text; 111 command.CommandType = CommandType.Text;
112 112
113 return command; 113 return command;
114 } 114 }
115 115
116 public virtual bool Update(TPrimaryKey primaryKey, TRowMapper value) 116 public virtual bool Update(TPrimaryKey primaryKey, TRowMapper value)
117 { 117 {
118 int updated = 0; 118 int updated = 0;
119 119
120 WithConnection(delegate(DbConnection connection) 120 WithConnection(delegate(DbConnection connection)
121 { 121 {
122 using (DbCommand command = CreateUpdateCommand(connection, value, primaryKey)) 122 using (DbCommand command = CreateUpdateCommand(connection, value, primaryKey))
123 { 123 {
124 updated = command.ExecuteNonQuery(); 124 updated = command.ExecuteNonQuery();
125 } 125 }
126 }); 126 });
127 127
128 if (updated == 1) 128 if (updated == 1)
129 { 129 {
130 return true; 130 return true;
131 } 131 }
132 else 132 else
133 { 133 {
134 return false; 134 return false;
135 } 135 }
136 } 136 }
137 137
138 public virtual bool Add(TRowMapper value) 138 public virtual bool Add(TRowMapper value)
139 { 139 {
140 int added = 0; 140 int added = 0;
141 141
142 WithConnection(delegate(DbConnection connection) 142 WithConnection(delegate(DbConnection connection)
143 { 143 {
144 using (DbCommand command = CreateInsertCommand(connection, value)) 144 using (DbCommand command = CreateInsertCommand(connection, value))
145 { 145 {
146 added = command.ExecuteNonQuery(); 146 added = command.ExecuteNonQuery();
147 } 147 }
148 }); 148 });
149 149
150 if (added == 1) 150 if (added == 1)
151 { 151 {
152 return true; 152 return true;
153 } 153 }
154 else 154 else
155 { 155 {
156 return false; 156 return false;
157 } 157 }
158 } 158 }
159 159
160 public abstract TRowMapper FromReader(DataReader reader); 160 public abstract TRowMapper FromReader(DataReader reader);
161 } 161 }
162} \ No newline at end of file 162} \ No newline at end of file
diff --git a/ThirdParty/TribalMedia/TribalMedia.Framework.Data/Properties/AssemblyInfo.cs b/ThirdParty/TribalMedia/TribalMedia.Framework.Data/Properties/AssemblyInfo.cs
index 4a073e9..583c310 100644
--- a/ThirdParty/TribalMedia/TribalMedia.Framework.Data/Properties/AssemblyInfo.cs
+++ b/ThirdParty/TribalMedia/TribalMedia.Framework.Data/Properties/AssemblyInfo.cs
@@ -1,40 +1,40 @@
1using System.Reflection; 1using System.Reflection;
2using System.Runtime.InteropServices; 2using System.Runtime.InteropServices;
3using System.Security; 3using System.Security;
4 4
5// General Information about an assembly is controlled through the following 5// General Information about an assembly is controlled through the following
6// set of attributes. Change these attribute values to modify the information 6// set of attributes. Change these attribute values to modify the information
7// associated with an assembly. 7// associated with an assembly.
8 8
9[assembly : AssemblyTitle("TribalMedia.Framework.Data")] 9[assembly : AssemblyTitle("TribalMedia.Framework.Data")]
10[assembly : AssemblyDescription("Generic Database Abstraction Layer")] 10[assembly : AssemblyDescription("Generic Database Abstraction Layer")]
11[assembly : AssemblyConfiguration("")] 11[assembly : AssemblyConfiguration("")]
12[assembly : AssemblyCompany("TribalMedia")] 12[assembly : AssemblyCompany("TribalMedia")]
13[assembly : AssemblyProduct("TribalMedia.Framework.Data")] 13[assembly : AssemblyProduct("TribalMedia.Framework.Data")]
14[assembly: AssemblyCopyright("Copyright © 2007 Tribal Media")] 14[assembly: AssemblyCopyright("Copyright © 2007 Tribal Media")]
15[assembly : AssemblyTrademark("")] 15[assembly : AssemblyTrademark("")]
16[assembly : AssemblyCulture("")] 16[assembly : AssemblyCulture("")]
17 17
18// Setting ComVisible to false makes the types in this assembly not visible 18// Setting ComVisible to false makes the types in this assembly not visible
19// to COM components. If you need to access a type in this assembly from 19// to COM components. If you need to access a type in this assembly from
20// COM, set the ComVisible attribute to true on that type. 20// COM, set the ComVisible attribute to true on that type.
21 21
22[assembly : ComVisible(false)] 22[assembly : ComVisible(false)]
23 23
24// The following GUID is for the ID of the typelib if this project is exposed to COM 24// The following GUID is for the ID of the typelib if this project is exposed to COM
25 25
26[assembly : Guid("9269f421-19d9-4eea-bfe3-c0ffe426fada")] 26[assembly : Guid("9269f421-19d9-4eea-bfe3-c0ffe426fada")]
27 27
28// Version information for an assembly consists of the following four values: 28// Version information for an assembly consists of the following four values:
29// 29//
30// Major Version 30// Major Version
31// Minor Version 31// Minor Version
32// Build Number 32// Build Number
33// Revision 33// Revision
34// 34//
35// You can specify all the values or you can default the Revision and Build Numbers 35// You can specify all the values or you can default the Revision and Build Numbers
36// by using the '*' as shown below: 36// by using the '*' as shown below:
37 37
38[assembly : AssemblyVersion("1.0.0.0")] 38[assembly : AssemblyVersion("1.0.0.0")]
39[assembly : AssemblyFileVersion("1.0.0.0")] 39[assembly : AssemblyFileVersion("1.0.0.0")]
40[assembly : AllowPartiallyTrustedCallers] \ No newline at end of file 40[assembly : AllowPartiallyTrustedCallers] \ No newline at end of file
diff --git a/ThirdParty/TribalMedia/TribalMedia.Framework.Data/RowMapper.cs b/ThirdParty/TribalMedia/TribalMedia.Framework.Data/RowMapper.cs
index aa22c8b..2771ec9 100644
--- a/ThirdParty/TribalMedia/TribalMedia.Framework.Data/RowMapper.cs
+++ b/ThirdParty/TribalMedia/TribalMedia.Framework.Data/RowMapper.cs
@@ -1,85 +1,85 @@
1/* 1/*
2* Copyright (c) Tribal Media AB, http://tribalmedia.se/ 2* Copyright (c) Tribal Media AB, http://tribalmedia.se/
3* 3*
4* Redistribution and use in source and binary forms, with or without 4* Redistribution and use in source and binary forms, with or without
5* modification, are permitted provided that the following conditions are met: 5* modification, are permitted provided that the following conditions are met:
6* * Redistributions of source code must retain the above copyright 6* * Redistributions of source code must retain the above copyright
7* notice, this list of conditions and the following disclaimer. 7* notice, this list of conditions and the following disclaimer.
8* * Redistributions in binary form must reproduce the above copyright 8* * Redistributions in binary form must reproduce the above copyright
9* notice, this list of conditions and the following disclaimer in the 9* notice, this list of conditions and the following disclaimer in the
10* documentation and/or other materials provided with the distribution. 10* documentation and/or other materials provided with the distribution.
11* * The name of Tribal Media AB may not be used to endorse or promote products 11* * The name of Tribal Media AB may not be used to endorse or promote products
12* derived from this software without specific prior written permission. 12* derived from this software without specific prior written permission.
13* 13*
14* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY 14* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
15* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 15* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
16* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 16* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
17* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY 17* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
18* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES 18* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
19* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 19* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
20* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND 20* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
21* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 21* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
22* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS 22* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
23* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 23* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
24* 24*
25*/ 25*/
26 26
27using TribalMedia.Framework.Data; 27using TribalMedia.Framework.Data;
28 28
29namespace TribalMedia.Framework.Data 29namespace TribalMedia.Framework.Data
30{ 30{
31 public abstract class RowMapper 31 public abstract class RowMapper
32 { 32 {
33 public abstract void FillObject(DataReader reader); 33 public abstract void FillObject(DataReader reader);
34 } 34 }
35 35
36 public class ObjectMapper<TObj> : RowMapper 36 public class ObjectMapper<TObj> : RowMapper
37 { 37 {
38 private readonly Schema m_schema; 38 private readonly Schema m_schema;
39 private readonly TObj m_obj; 39 private readonly TObj m_obj;
40 40
41 public TObj Object 41 public TObj Object
42 { 42 {
43 get { return m_obj; } 43 get { return m_obj; }
44 } 44 }
45 45
46 public ObjectMapper(Schema schema, TObj obj) 46 public ObjectMapper(Schema schema, TObj obj)
47 { 47 {
48 m_schema = schema; 48 m_schema = schema;
49 m_obj = obj; 49 m_obj = obj;
50 } 50 }
51 51
52 public override void FillObject(DataReader reader) 52 public override void FillObject(DataReader reader)
53 { 53 {
54 foreach (FieldMapper fieldMapper in m_schema.Fields.Values) 54 foreach (FieldMapper fieldMapper in m_schema.Fields.Values)
55 { 55 {
56 fieldMapper.SetPropertyFromReader(m_obj, reader); 56 fieldMapper.SetPropertyFromReader(m_obj, reader);
57 } 57 }
58 } 58 }
59 } 59 }
60 60
61 public class RowMapper<TObj> : RowMapper 61 public class RowMapper<TObj> : RowMapper
62 { 62 {
63 private readonly Schema m_schema; 63 private readonly Schema m_schema;
64 private readonly TObj m_obj; 64 private readonly TObj m_obj;
65 65
66 public TObj Object 66 public TObj Object
67 { 67 {
68 get { return m_obj; } 68 get { return m_obj; }
69 } 69 }
70 70
71 public RowMapper(Schema schema, TObj obj) 71 public RowMapper(Schema schema, TObj obj)
72 { 72 {
73 m_schema = schema; 73 m_schema = schema;
74 m_obj = obj; 74 m_obj = obj;
75 } 75 }
76 76
77 public override void FillObject(DataReader reader) 77 public override void FillObject(DataReader reader)
78 { 78 {
79 foreach (FieldMapper fieldMapper in m_schema.Fields.Values) 79 foreach (FieldMapper fieldMapper in m_schema.Fields.Values)
80 { 80 {
81 fieldMapper.SetPropertyFromReader(this, reader); 81 fieldMapper.SetPropertyFromReader(this, reader);
82 } 82 }
83 } 83 }
84 } 84 }
85} \ No newline at end of file 85} \ No newline at end of file
diff --git a/ThirdParty/TribalMedia/TribalMedia.Framework.Data/Schema.cs b/ThirdParty/TribalMedia/TribalMedia.Framework.Data/Schema.cs
index b7b8939..c6bf5d0 100644
--- a/ThirdParty/TribalMedia/TribalMedia.Framework.Data/Schema.cs
+++ b/ThirdParty/TribalMedia/TribalMedia.Framework.Data/Schema.cs
@@ -1,89 +1,89 @@
1/* 1/*
2* Copyright (c) Tribal Media AB, http://tribalmedia.se/ 2* Copyright (c) Tribal Media AB, http://tribalmedia.se/
3* 3*
4* Redistribution and use in source and binary forms, with or without 4* Redistribution and use in source and binary forms, with or without
5* modification, are permitted provided that the following conditions are met: 5* modification, are permitted provided that the following conditions are met:
6* * Redistributions of source code must retain the above copyright 6* * Redistributions of source code must retain the above copyright
7* notice, this list of conditions and the following disclaimer. 7* notice, this list of conditions and the following disclaimer.
8* * Redistributions in binary form must reproduce the above copyright 8* * Redistributions in binary form must reproduce the above copyright
9* notice, this list of conditions and the following disclaimer in the 9* notice, this list of conditions and the following disclaimer in the
10* documentation and/or other materials provided with the distribution. 10* documentation and/or other materials provided with the distribution.
11* * The name of Tribal Media AB may not be used to endorse or promote products 11* * The name of Tribal Media AB may not be used to endorse or promote products
12* derived from this software without specific prior written permission. 12* derived from this software without specific prior written permission.
13* 13*
14* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY 14* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
15* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 15* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
16* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 16* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
17* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY 17* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
18* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES 18* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
19* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 19* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
20* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND 20* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
21* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 21* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
22* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS 22* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
23* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 23* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
24* 24*
25*/ 25*/
26 26
27using System.Collections.Generic; 27using System.Collections.Generic;
28using TribalMedia.Framework.Data; 28using TribalMedia.Framework.Data;
29 29
30namespace TribalMedia.Framework.Data 30namespace TribalMedia.Framework.Data
31{ 31{
32 public class Schema 32 public class Schema
33 { 33 {
34 protected TableMapper m_tableMapper; 34 protected TableMapper m_tableMapper;
35 protected Dictionary<string, FieldMapper> m_mappings; 35 protected Dictionary<string, FieldMapper> m_mappings;
36 36
37 public Dictionary<string, FieldMapper> Fields 37 public Dictionary<string, FieldMapper> Fields
38 { 38 {
39 get { return m_mappings; } 39 get { return m_mappings; }
40 } 40 }
41 41
42 public Schema(TableMapper tableMapper) 42 public Schema(TableMapper tableMapper)
43 { 43 {
44 m_mappings = new Dictionary<string, FieldMapper>(); 44 m_mappings = new Dictionary<string, FieldMapper>();
45 m_tableMapper = tableMapper; 45 m_tableMapper = tableMapper;
46 } 46 }
47 } 47 }
48 48
49 public class ObjectSchema<TObj> : Schema 49 public class ObjectSchema<TObj> : Schema
50 { 50 {
51 public ObjectSchema(TableMapper tableMapper) : base(tableMapper) 51 public ObjectSchema(TableMapper tableMapper) : base(tableMapper)
52 { 52 {
53 } 53 }
54 54
55 public ObjectField<TObj, TField> AddMapping<TField>(string fieldName, 55 public ObjectField<TObj, TField> AddMapping<TField>(string fieldName,
56 ObjectGetAccessor<TObj, TField> rowMapperGetAccessor, 56 ObjectGetAccessor<TObj, TField> rowMapperGetAccessor,
57 ObjectSetAccessor<TObj, TField> rowMapperSetAccessor) 57 ObjectSetAccessor<TObj, TField> rowMapperSetAccessor)
58 { 58 {
59 ObjectField<TObj, TField> rowMapperField = 59 ObjectField<TObj, TField> rowMapperField =
60 new ObjectField<TObj, TField>(m_tableMapper, fieldName, rowMapperGetAccessor, rowMapperSetAccessor); 60 new ObjectField<TObj, TField>(m_tableMapper, fieldName, rowMapperGetAccessor, rowMapperSetAccessor);
61 61
62 m_mappings.Add(fieldName, rowMapperField); 62 m_mappings.Add(fieldName, rowMapperField);
63 63
64 return rowMapperField; 64 return rowMapperField;
65 } 65 }
66 } 66 }
67 67
68 public class RowMapperSchema<TRowMapper> : Schema 68 public class RowMapperSchema<TRowMapper> : Schema
69 where TRowMapper : RowMapper 69 where TRowMapper : RowMapper
70 { 70 {
71 public RowMapperSchema(TableMapper tableMapper) : base(tableMapper) 71 public RowMapperSchema(TableMapper tableMapper) : base(tableMapper)
72 { 72 {
73 } 73 }
74 74
75 public RowMapperField<TRowMapper, TField> AddMapping<TField>(string fieldName, 75 public RowMapperField<TRowMapper, TField> AddMapping<TField>(string fieldName,
76 RowMapperGetAccessor<TRowMapper, TField> 76 RowMapperGetAccessor<TRowMapper, TField>
77 rowMapperGetAccessor, 77 rowMapperGetAccessor,
78 RowMapperSetAccessor<TRowMapper, TField> 78 RowMapperSetAccessor<TRowMapper, TField>
79 rowMapperSetAccessor) 79 rowMapperSetAccessor)
80 { 80 {
81 RowMapperField<TRowMapper, TField> rowMapperField = 81 RowMapperField<TRowMapper, TField> rowMapperField =
82 new RowMapperField<TRowMapper, TField>(m_tableMapper, fieldName, rowMapperGetAccessor, rowMapperSetAccessor); 82 new RowMapperField<TRowMapper, TField>(m_tableMapper, fieldName, rowMapperGetAccessor, rowMapperSetAccessor);
83 83
84 m_mappings.Add(fieldName, rowMapperField); 84 m_mappings.Add(fieldName, rowMapperField);
85 85
86 return rowMapperField; 86 return rowMapperField;
87 } 87 }
88 } 88 }
89} \ No newline at end of file 89} \ No newline at end of file
diff --git a/ThirdParty/TribalMedia/TribalMedia.Framework.Data/TableMapper.cs b/ThirdParty/TribalMedia/TribalMedia.Framework.Data/TableMapper.cs
index f041e79..15005f8 100644
--- a/ThirdParty/TribalMedia/TribalMedia.Framework.Data/TableMapper.cs
+++ b/ThirdParty/TribalMedia/TribalMedia.Framework.Data/TableMapper.cs
@@ -1,108 +1,108 @@
1/* 1/*
2* Copyright (c) Tribal Media AB, http://tribalmedia.se/ 2* Copyright (c) Tribal Media AB, http://tribalmedia.se/
3* 3*
4* Redistribution and use in source and binary forms, with or without 4* Redistribution and use in source and binary forms, with or without
5* modification, are permitted provided that the following conditions are met: 5* modification, are permitted provided that the following conditions are met:
6* * Redistributions of source code must retain the above copyright 6* * Redistributions of source code must retain the above copyright
7* notice, this list of conditions and the following disclaimer. 7* notice, this list of conditions and the following disclaimer.
8* * Redistributions in binary form must reproduce the above copyright 8* * Redistributions in binary form must reproduce the above copyright
9* notice, this list of conditions and the following disclaimer in the 9* notice, this list of conditions and the following disclaimer in the
10* documentation and/or other materials provided with the distribution. 10* documentation and/or other materials provided with the distribution.
11* * The name of Tribal Media AB may not be used to endorse or promote products 11* * The name of Tribal Media AB may not be used to endorse or promote products
12* derived from this software without specific prior written permission. 12* derived from this software without specific prior written permission.
13* 13*
14* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY 14* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
15* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 15* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
16* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 16* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
17* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY 17* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
18* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES 18* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
19* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 19* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
20* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND 20* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
21* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 21* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
22* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS 22* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
23* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 23* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
24* 24*
25*/ 25*/
26 26
27using System; 27using System;
28using System.Data; 28using System.Data;
29using System.Data.Common; 29using System.Data.Common;
30using TribalMedia.Framework.Data; 30using TribalMedia.Framework.Data;
31 31
32namespace TribalMedia.Framework.Data 32namespace TribalMedia.Framework.Data
33{ 33{
34 public abstract class TableMapper 34 public abstract class TableMapper
35 { 35 {
36 private readonly DatabaseMapper m_connectionPool; 36 private readonly DatabaseMapper m_connectionPool;
37 private readonly object m_syncRoot = new object(); 37 private readonly object m_syncRoot = new object();
38 38
39 protected void WithConnection(Action<DbConnection> action) 39 protected void WithConnection(Action<DbConnection> action)
40 { 40 {
41 lock (m_syncRoot) 41 lock (m_syncRoot)
42 { 42 {
43 DbConnection m_connection = m_connectionPool.GetNewConnection(); 43 DbConnection m_connection = m_connectionPool.GetNewConnection();
44 44
45 if (m_connection.State != ConnectionState.Open) 45 if (m_connection.State != ConnectionState.Open)
46 { 46 {
47 m_connection.Open(); 47 m_connection.Open();
48 } 48 }
49 49
50 action(m_connection); 50 action(m_connection);
51 51
52 if (m_connection.State == ConnectionState.Open) 52 if (m_connection.State == ConnectionState.Open)
53 { 53 {
54 m_connection.Close(); 54 m_connection.Close();
55 } 55 }
56 } 56 }
57 } 57 }
58 58
59 private readonly string m_tableName; 59 private readonly string m_tableName;
60 public string TableName 60 public string TableName
61 { 61 {
62 get { return m_tableName; } 62 get { return m_tableName; }
63 } 63 }
64 64
65 private Schema m_schema; 65 private Schema m_schema;
66 public Schema Schema 66 public Schema Schema
67 { 67 {
68 get { return m_schema; } 68 get { return m_schema; }
69 } 69 }
70 70
71 private FieldMapper m_keyFieldMapper; 71 private FieldMapper m_keyFieldMapper;
72 public FieldMapper KeyFieldMapper 72 public FieldMapper KeyFieldMapper
73 { 73 {
74 get { return m_keyFieldMapper; } 74 get { return m_keyFieldMapper; }
75 } 75 }
76 76
77 public TableMapper(DatabaseMapper connectionPool, string tableName) 77 public TableMapper(DatabaseMapper connectionPool, string tableName)
78 { 78 {
79 m_connectionPool = connectionPool; 79 m_connectionPool = connectionPool;
80 m_tableName = tableName.ToLower(); // Stupid MySQL hack. 80 m_tableName = tableName.ToLower(); // Stupid MySQL hack.
81 } 81 }
82 82
83 public string CreateParamName(string fieldName) 83 public string CreateParamName(string fieldName)
84 { 84 {
85 return m_connectionPool.CreateParamName(fieldName); 85 return m_connectionPool.CreateParamName(fieldName);
86 } 86 }
87 87
88 protected DbCommand CreateSelectCommand(DbConnection connection, string fieldName, object primaryKey) 88 protected DbCommand CreateSelectCommand(DbConnection connection, string fieldName, object primaryKey)
89 { 89 {
90 return m_connectionPool.CreateSelectCommand(this, connection, fieldName, primaryKey); 90 return m_connectionPool.CreateSelectCommand(this, connection, fieldName, primaryKey);
91 } 91 }
92 92
93 public string CreateCondition(DbCommand command, string fieldName, object key) 93 public string CreateCondition(DbCommand command, string fieldName, object key)
94 { 94 {
95 return m_connectionPool.CreateCondition(this, command, fieldName, key); 95 return m_connectionPool.CreateCondition(this, command, fieldName, key);
96 } 96 }
97 97
98 public DbCommand CreateInsertCommand(DbConnection connection, object obj) 98 public DbCommand CreateInsertCommand(DbConnection connection, object obj)
99 { 99 {
100 return m_connectionPool.CreateInsertCommand(this, connection, obj); 100 return m_connectionPool.CreateInsertCommand(this, connection, obj);
101 } 101 }
102 102
103 public DbCommand CreateUpdateCommand(DbConnection connection, object rowMapper, object primaryKey) 103 public DbCommand CreateUpdateCommand(DbConnection connection, object rowMapper, object primaryKey)
104 { 104 {
105 return m_connectionPool.CreateUpdateCommand(this, connection, rowMapper, primaryKey); 105 return m_connectionPool.CreateUpdateCommand(this, connection, rowMapper, primaryKey);
106 } 106 }
107 } 107 }
108} \ No newline at end of file 108} \ No newline at end of file
generated by cgit v1.1 at 2024-11-16 11:47:17 +0000