【发布时间】:2012-03-09 10:27:35
【问题描述】:
在我的 c# 应用程序中,我使用 sqlite 数据库。我的 c# 应用程序在另一台机器上作为服务运行。我从本地机器执行 CRUD 操作,以对我们开发的 flex 应用程序的数据库执行 CRUD 操作。 现在的问题是当我尝试从前端删除或添加项目到数据库时,有时我会因为数据库被锁定而出错。请在下面找到代码sn-p删除数据。
连接字符串
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");
这是我的代码....请让我知道解决此锁定问题的解决方案是什么。 提前谢谢
} }
【问题讨论】: