В моем приложении c # я использую базу данных sqlite. Моё приложение c # работает как служба на другом компьютере. Я выполняю операции CRUD с локального компьютера, чтобы выполнять операции CRUD с базой данных, которую мы разработали, приложение flex.
Теперь проблема заключается в том, что когда я пытаюсь удалить или добавить элементы в базу данных из внешнего интерфейса, иногда я получаю сообщение об ошибке, поскольку база данных заблокирована. Ниже приведен фрагмент кода для удаления данных.
строка подключения
public ThingzDatabase(string dataFile)
{
_dataFile = dataFile;
conn = new SQLiteConnection("data source=" + dataFile+";Version=3;");
}
для выполнения команд используются следующие методы.
public SQLiteDataReader ExecuteSQL(String sqlExpr)
{
if (conn.State != ConnectionState.Open)
Open(DataFile);
SQLiteCommand cmd = conn.CreateCommand();
cmd.CommandText = sqlExpr;
cmd.CommandType = CommandType.Text;
return cmd.ExecuteReader();
}
public int ExecuteNonQuerySQL(String sqlExpr)
{
if (conn.State != ConnectionState.Open)
Open(DataFile);
int ireturn = 0;
using (SQLiteTransaction dbtrans = conn.BeginTransaction())
{
SQLiteCommand cmd = conn.CreateCommand();
cmd.CommandText = sqlExpr;
ireturn = cmd.ExecuteNonQuery();
dbtrans.Commit();
}
return ireturn;
}
Ниже приведен код, используемый для удаления отношения,
OrderedRelationSet orderedRelationSet = new OrderedRelationSet(SessionDatabase, relation.RelationTypeId, relation.SourceThingId);
public OrderedRelationSet(ThingzDatabase db, int relationTypeId, int parentItemId)
{
this.db = db;
this.relationTypeId = relationTypeId;
this.parentItemId = parentItemId;
childId = ThingzDatabase.thingsId;
relations = new List<Relation>();
SQLiteDataReader relationsReader = db.ExecuteSQL(
@"SELECT *
FROM relation
WHERE parent_itemid = " + this.parentItemId.ToString() + @" and child_itemid=" + childId + @" and
relation_typeid = " + this.relationTypeId.ToString()
);
while (relationsReader.Read())
{
Relation relation = new Relation();
relation.db = db;
relation.SourceThingId = Convert.ToInt32(relationsReader["parent_itemid"]);
relation.ThingId = Convert.ToInt32(relationsReader["child_itemid"]);
relation.Id = Convert.ToInt32(relationsReader["id"]);
relation.RelationTypeId = Convert.ToInt32(relationsReader["relation_typeid"]);
relation.ordinal = Utilities.OptionalIntFieldFromSQLReader("ordinal", relationsReader);
relation.thingIsChild = true;
relations.Add(relation);
}
relationsReader.Close();
reorder();
}
----------
case "remove":
try
{
if (orderedRelationSet.RemoveRelation(relation) != true)
{
TouchServer.Log(Logger.MessageType.Error, 0, "Remove relation operation failed");
throw new Exception("remove relation failed");
}
}
catch (Exception)
{
if (orderedRelationSet.RemoveRelation(relation) != true)
{
TouchServer.Log(Logger.MessageType.Error, 0, "Remove relation operation failed");
throw new Exception("remove relation failed");
Это мой код .... пожалуйста, дайте мне знать, как решить эту проблему с блокировкой.
Спасибо заранее
}
}