public class DataAccess
{
public static object obj = new object();
string pwd = "xxoooxxxoo";
public void AddData(string path,string Id, byte[] data)
{
string sqlStr = "insert into Resource(ID,Data) values(@id,@data)";// Id, data
string connStr = string.Format("Data Source={0};Password={1};Pooling=false",path,pwd);
SQLiteConnection conn = null;
try
{
conn = new SQLiteConnection(connStr);
if(conn.State != System.Data.ConnectionState.Open)
{
conn.Open();
}
lock (obj)
{
SQLiteCommand cmd = new SQLiteCommand(sqlStr, conn);
cmd.Parameters.Add("@id",System.Data.DbType.String).Value = System.Guid.NewGuid();
cmd.Parameters.Add("@data", System.Data.DbType.Binary).Value = data;
cmd.ExecuteNonQuery();
}
}
catch
{
throw;
}
}
} |
|
转播
