Updated to a better check

This commit is contained in:
William Burns 2015-12-18 18:16:20 +00:00
parent e7243d4b9c
commit 13cfc0e12a
1 changed files with 12 additions and 22 deletions

View File

@ -73,30 +73,20 @@ public class CustomDataRepository extends RepositoryBase
for (CustomData cd : data.getDataMap().keySet())
{
executeInsert(UPDATE_DATA, new ResultSetCallable()
{
@Override
public void processResultSet(ResultSet resultSet) throws SQLException
{
if (!resultSet.isBeforeFirst())
{
// Not already in the DB
executeUpdate(
INSERT_DATA,
new ColumnInt("account", accountId),
new ColumnInt("customData", cd.getId()),
new ColumnInt("data", data.getDataMap().get(cd))
);
}
}
},
if (executeUpdate(
UPDATE_DATA,
new ColumnInt("data", data.getDataMap().get(cd)),
new ColumnInt("account", accountId),
new ColumnInt("customData", cd.getId())
);
new ColumnInt("customData", cd.getId())) < 1)
{
// Not already in the DB
executeUpdate(
INSERT_DATA,
new ColumnInt("account", accountId),
new ColumnInt("customData", cd.getId()),
new ColumnInt("data", data.getDataMap().get(cd))
);
}
}
}