Leahnaya/pkmn-classic-framework
1
0
Fork 0
mirror of https://github.com/mm201/pkmn-classic-framework.git synced 2026-09-13 04:35:15 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Added usings around mysql transactions.

Browse Source
This commit is contained in:
Greg Edwards
2014-05-16 18:37:01 -04:00
parent 095ee08c00
commit 15fcdd6e64
1 changed files with 90 additions and 80 deletions
Download Patch File Download Diff File Expand all files Collapse all files

170
library/Data/DataMysql.cs
View File

@@ -68,10 +68,12 @@ namespace PkmnFoundations.Data
using (MySqlConnection db = CreateConnection())
{
db.Open();
MySqlTransaction tran = db.BeginTransaction();
GtsRecord4 result = GtsDataForUser4(tran, pid);
tran.Commit();
return result;
using (MySqlTransaction tran = db.BeginTransaction())
{
GtsRecord4 result = GtsDataForUser4(tran, pid);
tran.Commit();
return result;
}
}
}
@@ -118,16 +120,17 @@ namespace PkmnFoundations.Data
using (MySqlConnection db = CreateConnection())
{
db.Open();
MySqlTransaction tran = db.BeginTransaction();
if (!GtsDepositPokemon4(tran, record))
using (MySqlTransaction tran = db.BeginTransaction())
{
tran.Rollback();
return false;
}
if (!GtsDepositPokemon4(tran, record))
{
tran.Rollback();
return false;
}
tran.Commit();
return true;
tran.Commit();
return true;
}
}
}
@@ -155,16 +158,17 @@ namespace PkmnFoundations.Data
using (MySqlConnection db = CreateConnection())
{
db.Open();
MySqlTransaction tran = db.BeginTransaction();
if (!GtsDeletePokemon4(tran, pid))
using (MySqlTransaction tran = db.BeginTransaction())
{
tran.Rollback();
return false;
}
if (!GtsDeletePokemon4(tran, pid))
{
tran.Rollback();
return false;
}
tran.Commit();
return true;
tran.Commit();
return true;
}
}
}
@@ -182,30 +186,31 @@ namespace PkmnFoundations.Data
using (MySqlConnection db = CreateConnection())
{
db.Open();
MySqlTransaction tran = db.BeginTransaction();
GtsRecord4 resultOrig = GtsDataForUser4(tran, result.PID);
if (resultOrig == null || resultOrig != result)
using (MySqlTransaction tran = db.BeginTransaction())
{
// looks like the pokemon was ninja'd between the Exchange and Exchange_finish
tran.Rollback();
return false;
}
GtsRecord4 resultOrig = GtsDataForUser4(tran, result.PID);
if (resultOrig == null || resultOrig != result)
{
// looks like the pokemon was ninja'd between the Exchange and Exchange_finish
tran.Rollback();
return false;
}
if (!GtsDeletePokemon4(tran, result.PID))
{
tran.Rollback();
return false;
}
if (!GtsDeletePokemon4(tran, result.PID))
{
tran.Rollback();
return false;
}
if (!GtsDepositPokemon4(tran, traded))
{
tran.Rollback();
return false;
}
if (!GtsDepositPokemon4(tran, traded))
{
tran.Rollback();
return false;
}
tran.Commit();
return true;
tran.Commit();
return true;
}
}
}
@@ -394,10 +399,12 @@ namespace PkmnFoundations.Data
using (MySqlConnection db = CreateConnection())
{
db.Open();
MySqlTransaction tran = db.BeginTransaction();
GtsRecord5 result = GtsDataForUser5(tran, pid);
tran.Commit();
return result;
using (MySqlTransaction tran = db.BeginTransaction())
{
GtsRecord5 result = GtsDataForUser5(tran, pid);
tran.Commit();
return result;
}
}
}
@@ -446,16 +453,17 @@ namespace PkmnFoundations.Data
using (MySqlConnection db = CreateConnection())
{
db.Open();
MySqlTransaction tran = db.BeginTransaction();
if (!GtsDepositPokemon5(tran, record))
using (MySqlTransaction tran = db.BeginTransaction())
{
tran.Rollback();
return false;
}
if (!GtsDepositPokemon5(tran, record))
{
tran.Rollback();
return false;
}
tran.Commit();
return true;
tran.Commit();
return true;
}
}
}
@@ -483,16 +491,17 @@ namespace PkmnFoundations.Data
using (MySqlConnection db = CreateConnection())
{
db.Open();
MySqlTransaction tran = db.BeginTransaction();
if (!GtsDeletePokemon5(tran, pid))
using (MySqlTransaction tran = db.BeginTransaction())
{
tran.Rollback();
return false;
}
if (!GtsDeletePokemon5(tran, pid))
{
tran.Rollback();
return false;
}
tran.Commit();
return true;
tran.Commit();
return true;
}
}
}
@@ -510,30 +519,31 @@ namespace PkmnFoundations.Data
using (MySqlConnection db = CreateConnection())
{
db.Open();
MySqlTransaction tran = db.BeginTransaction();
GtsRecord5 resultOrig = GtsDataForUser5(tran, result.PID);
if (resultOrig == null || resultOrig != result)
using (MySqlTransaction tran = db.BeginTransaction())
{
// looks like the pokemon was ninja'd between the Exchange and Exchange_finish
tran.Rollback();
return false;
}
GtsRecord5 resultOrig = GtsDataForUser5(tran, result.PID);
if (resultOrig == null || resultOrig != result)
{
// looks like the pokemon was ninja'd between the Exchange and Exchange_finish
tran.Rollback();
return false;
}
if (!GtsDeletePokemon5(tran, result.PID))
{
tran.Rollback();
return false;
}
if (!GtsDeletePokemon5(tran, result.PID))
{
tran.Rollback();
return false;
}
if (!GtsDepositPokemon5(tran, traded))
{
tran.Rollback();
return false;
}
if (!GtsDepositPokemon5(tran, traded))
{
tran.Rollback();
return false;
}
tran.Commit();
return true;
tran.Commit();
return true;
}
}
}