diff options
Diffstat (limited to 'OpenSim/Data/Migration.cs')
-rw-r--r-- | OpenSim/Data/Migration.cs | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/OpenSim/Data/Migration.cs b/OpenSim/Data/Migration.cs index 8fbf789..332b8ec 100644 --- a/OpenSim/Data/Migration.cs +++ b/OpenSim/Data/Migration.cs | |||
@@ -82,6 +82,7 @@ namespace OpenSim.Data | |||
82 | // private static readonly string _migrations_init = "insert into migrations values('migrations', 1)"; | 82 | // private static readonly string _migrations_init = "insert into migrations values('migrations', 1)"; |
83 | // private static readonly string _migrations_find = "select version from migrations where name='migrations'"; | 83 | // private static readonly string _migrations_find = "select version from migrations where name='migrations'"; |
84 | 84 | ||
85 | |||
85 | public Migration(DbConnection conn, Assembly assem, string type) | 86 | public Migration(DbConnection conn, Assembly assem, string type) |
86 | { | 87 | { |
87 | _type = type; | 88 | _type = type; |
@@ -112,6 +113,7 @@ namespace OpenSim.Data | |||
112 | DbCommand cmd = _conn.CreateCommand(); | 113 | DbCommand cmd = _conn.CreateCommand(); |
113 | cmd.CommandText = _migrations_create; | 114 | cmd.CommandText = _migrations_create; |
114 | cmd.ExecuteNonQuery(); | 115 | cmd.ExecuteNonQuery(); |
116 | cmd.Dispose(); | ||
115 | 117 | ||
116 | InsertVersion("migrations", 1); | 118 | InsertVersion("migrations", 1); |
117 | } | 119 | } |
@@ -135,7 +137,7 @@ namespace OpenSim.Data | |||
135 | int newversion = kvp.Key; | 137 | int newversion = kvp.Key; |
136 | cmd.CommandText = kvp.Value; | 138 | cmd.CommandText = kvp.Value; |
137 | // we need to up the command timeout to infinite as we might be doing long migrations. | 139 | // we need to up the command timeout to infinite as we might be doing long migrations. |
138 | cmd.CommandTimeout = 0; | 140 | //cmd.CommandTimeout = 0; |
139 | cmd.ExecuteNonQuery(); | 141 | cmd.ExecuteNonQuery(); |
140 | 142 | ||
141 | if (version == 0) | 143 | if (version == 0) |
@@ -147,6 +149,7 @@ namespace OpenSim.Data | |||
147 | UpdateVersion(_type, newversion); | 149 | UpdateVersion(_type, newversion); |
148 | } | 150 | } |
149 | version = newversion; | 151 | version = newversion; |
152 | cmd.Dispose(); | ||
150 | } | 153 | } |
151 | } | 154 | } |
152 | 155 | ||
@@ -189,7 +192,7 @@ namespace OpenSim.Data | |||
189 | DbCommand cmd = conn.CreateCommand(); | 192 | DbCommand cmd = conn.CreateCommand(); |
190 | try | 193 | try |
191 | { | 194 | { |
192 | cmd.CommandText = "select version from migrations where name='" + type + "' limit 1"; | 195 | cmd.CommandText = "select version from migrations where name='" + type +"' order by version desc"; |
193 | using (IDataReader reader = cmd.ExecuteReader()) | 196 | using (IDataReader reader = cmd.ExecuteReader()) |
194 | { | 197 | { |
195 | if (reader.Read()) | 198 | if (reader.Read()) |
@@ -203,6 +206,7 @@ namespace OpenSim.Data | |||
203 | { | 206 | { |
204 | // Something went wrong, so we're version 0 | 207 | // Something went wrong, so we're version 0 |
205 | } | 208 | } |
209 | cmd.Dispose(); | ||
206 | return version; | 210 | return version; |
207 | } | 211 | } |
208 | 212 | ||
@@ -212,6 +216,7 @@ namespace OpenSim.Data | |||
212 | cmd.CommandText = "insert into migrations(name, version) values('" + type + "', " + version + ")"; | 216 | cmd.CommandText = "insert into migrations(name, version) values('" + type + "', " + version + ")"; |
213 | m_log.InfoFormat("[MIGRATIONS]: Creating {0} at version {1}", type, version); | 217 | m_log.InfoFormat("[MIGRATIONS]: Creating {0} at version {1}", type, version); |
214 | cmd.ExecuteNonQuery(); | 218 | cmd.ExecuteNonQuery(); |
219 | cmd.Dispose(); | ||
215 | } | 220 | } |
216 | 221 | ||
217 | private void UpdateVersion(string type, int version) | 222 | private void UpdateVersion(string type, int version) |
@@ -220,6 +225,7 @@ namespace OpenSim.Data | |||
220 | cmd.CommandText = "update migrations set version=" + version + " where name='" + type + "'"; | 225 | cmd.CommandText = "update migrations set version=" + version + " where name='" + type + "'"; |
221 | m_log.InfoFormat("[MIGRATIONS]: Updating {0} to version {1}", type, version); | 226 | m_log.InfoFormat("[MIGRATIONS]: Updating {0} to version {1}", type, version); |
222 | cmd.ExecuteNonQuery(); | 227 | cmd.ExecuteNonQuery(); |
228 | cmd.Dispose(); | ||
223 | } | 229 | } |
224 | 230 | ||
225 | // private SortedList<int, string> GetAllMigrations() | 231 | // private SortedList<int, string> GetAllMigrations() |