screwed up the move, removing this file to give us proper history tracking
Sean Dague
parent
ad1a8ac381
commit
238fe86bc7
|
|
@ -1,213 +0,0 @@
|
||||||
using System;
|
|
||||||
using System.Collections.Generic;
|
|
||||||
using System.Text;
|
|
||||||
|
|
||||||
using OpenSim.Region.Environment.Scenes;
|
|
||||||
using OpenSim.Region.Environment.LandManagement;
|
|
||||||
using OpenSim.Region.Environment;
|
|
||||||
using OpenSim.Region.Interfaces;
|
|
||||||
using OpenSim.Framework.Console;
|
|
||||||
using libsecondlife;
|
|
||||||
|
|
||||||
using System.Data;
|
|
||||||
// Yes, this won't compile on MS, need to deal with that later
|
|
||||||
using Mono.Data.SqliteClient;
|
|
||||||
using Primitive = OpenSim.Region.Environment.Scenes.Primitive;
|
|
||||||
|
|
||||||
namespace OpenSim.DataStore.SqliteStorage
|
|
||||||
{
|
|
||||||
|
|
||||||
public class SqliteDataStore : IRegionDataStore
|
|
||||||
{
|
|
||||||
private const string primSelect = "select * from prims";
|
|
||||||
private const string shapeSelect = "select * from primshapes";
|
|
||||||
|
|
||||||
private DataSet ds;
|
|
||||||
private SqliteDataAdapter primDa;
|
|
||||||
private SqliteDataAdapter shapeDa;
|
|
||||||
|
|
||||||
public void Initialise(string dbfile, string dbname)
|
|
||||||
{
|
|
||||||
// for us, dbfile will be the connect string
|
|
||||||
MainLog.Instance.Verbose("DATASTORE", "Sqlite - connecting: " + dbfile);
|
|
||||||
SqliteConnection conn = new SqliteConnection(dbfile);
|
|
||||||
|
|
||||||
SqliteCommand primSelectCmd = new SqliteCommand(primSelect, conn);
|
|
||||||
primDa = new SqliteDataAdapter(primSelectCmd);
|
|
||||||
// SqliteCommandBuilder primCb = new SqliteCommandBuilder(primDa);
|
|
||||||
|
|
||||||
SqliteCommand shapeSelectCmd = new SqliteCommand(shapeSelect, conn);
|
|
||||||
shapeDa = new SqliteDataAdapter(shapeSelectCmd);
|
|
||||||
// SqliteCommandBuilder shapeCb = new SqliteCommandBuilder(shapeDa);
|
|
||||||
|
|
||||||
ds = new DataSet();
|
|
||||||
|
|
||||||
// We fill the data set, now we've got copies in memory for the information
|
|
||||||
// TODO: see if the linkage actually holds.
|
|
||||||
// primDa.FillSchema(ds, SchemaType.Source, "PrimSchema");
|
|
||||||
primDa.Fill(ds, "prims");
|
|
||||||
ds.AcceptChanges();
|
|
||||||
|
|
||||||
DataTable prims = ds.Tables["prims"];
|
|
||||||
prims.PrimaryKey = new DataColumn[] { prims.Columns["UUID"] };
|
|
||||||
setupPrimCommands(primDa, conn);
|
|
||||||
|
|
||||||
// shapeDa.FillSchema(ds, SchemaType.Source, "ShapeSchema");
|
|
||||||
shapeDa.Fill(ds, "primshapes");
|
|
||||||
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
private SqliteParameter createSqliteParameter(string name, DbType type)
|
|
||||||
{
|
|
||||||
SqliteParameter param = new SqliteParameter();
|
|
||||||
param.ParameterName = ":" + name;
|
|
||||||
param.DbType = type;
|
|
||||||
param.SourceColumn = name;
|
|
||||||
param.SourceVersion = DataRowVersion.Current;
|
|
||||||
return param;
|
|
||||||
}
|
|
||||||
|
|
||||||
private void setupPrimCommands(SqliteDataAdapter da, SqliteConnection conn)
|
|
||||||
{
|
|
||||||
SqliteParameter UUID = createSqliteParameter("UUID", DbType.String);
|
|
||||||
SqliteParameter Name = createSqliteParameter("Name", DbType.String);
|
|
||||||
SqliteParameter CreationDate = createSqliteParameter("CreationDate", DbType.Int32);
|
|
||||||
SqliteParameter PositionX = createSqliteParameter("PositionX", DbType.Double);
|
|
||||||
SqliteParameter PositionY = createSqliteParameter("PositionY", DbType.Double);
|
|
||||||
SqliteParameter PositionZ = createSqliteParameter("PositionZ", DbType.Double);
|
|
||||||
|
|
||||||
|
|
||||||
SqliteCommand delete = new SqliteCommand("delete from prims where UUID = :UUID");
|
|
||||||
delete.Connection = conn;
|
|
||||||
|
|
||||||
SqliteCommand insert =
|
|
||||||
new SqliteCommand("insert into prims(" +
|
|
||||||
"UUID, CreationDate, Name, PositionX, PositionY, PositionZ" +
|
|
||||||
") values(:UUID, :CreationDate, :Name, :PositionX, :PositionY, :PositionZ)");
|
|
||||||
insert.Connection = conn;
|
|
||||||
|
|
||||||
SqliteCommand update =
|
|
||||||
new SqliteCommand("update prims set " +
|
|
||||||
"UUID = :UUID, CreationDate = :CreationDate, Name = :Name, PositionX = :PositionX, " +
|
|
||||||
"PositionY = :PositionY, PositionZ = :PositionZ where UUID = :UUID");
|
|
||||||
update.Connection = conn;
|
|
||||||
|
|
||||||
delete.Parameters.Add(UUID);
|
|
||||||
|
|
||||||
insert.Parameters.Add(UUID);
|
|
||||||
insert.Parameters.Add(Name);
|
|
||||||
insert.Parameters.Add(CreationDate);
|
|
||||||
insert.Parameters.Add(PositionX);
|
|
||||||
insert.Parameters.Add(PositionY);
|
|
||||||
insert.Parameters.Add(PositionZ);
|
|
||||||
|
|
||||||
update.Parameters.Add(UUID);
|
|
||||||
update.Parameters.Add(Name);
|
|
||||||
update.Parameters.Add(CreationDate);
|
|
||||||
update.Parameters.Add(PositionX);
|
|
||||||
update.Parameters.Add(PositionY);
|
|
||||||
update.Parameters.Add(PositionZ);
|
|
||||||
|
|
||||||
da.DeleteCommand = delete;
|
|
||||||
da.InsertCommand = insert;
|
|
||||||
da.UpdateCommand = update;
|
|
||||||
}
|
|
||||||
|
|
||||||
private void StoreSceneObject(SceneObject obj)
|
|
||||||
{
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
public void StoreObject(AllNewSceneObjectPart2 obj)
|
|
||||||
{
|
|
||||||
// TODO: Serializing code
|
|
||||||
DataTable prims = ds.Tables["prims"];
|
|
||||||
DataTable shapes = ds.Tables["shapes"];
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
private void fillPrimRow(DataRow row, Primitive prim)
|
|
||||||
{
|
|
||||||
row["UUID"] = prim.UUID;
|
|
||||||
row["CreationDate"] = prim.CreationDate;
|
|
||||||
row["Name"] = prim.Name;
|
|
||||||
row["PositionX"] = prim.Pos.X;
|
|
||||||
row["PositionY"] = prim.Pos.Y;
|
|
||||||
row["PositionZ"] = prim.Pos.Z;
|
|
||||||
}
|
|
||||||
|
|
||||||
private void addPrim(Primitive prim)
|
|
||||||
{
|
|
||||||
DataTable prims = ds.Tables["prims"];
|
|
||||||
DataTable shapes = ds.Tables["shapes"];
|
|
||||||
|
|
||||||
DataRow row = prims.Rows.Find(prim.UUID);
|
|
||||||
if (row == null) {
|
|
||||||
row = prims.NewRow();
|
|
||||||
fillPrimRow(row, prim);
|
|
||||||
prims.Rows.Add(row);
|
|
||||||
} else {
|
|
||||||
fillPrimRow(row, prim);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public void StoreObject(SceneObject obj)
|
|
||||||
{
|
|
||||||
foreach (Primitive prim in obj.Children.Values)
|
|
||||||
{
|
|
||||||
addPrim(prim);
|
|
||||||
}
|
|
||||||
|
|
||||||
MainLog.Instance.Verbose("Attempting to do update....");
|
|
||||||
primDa.Update(ds, "prims");
|
|
||||||
MainLog.Instance.Verbose("Dump of prims:", ds.GetXml());
|
|
||||||
}
|
|
||||||
|
|
||||||
public void RemoveObject(LLUUID obj)
|
|
||||||
{
|
|
||||||
// TODO: remove code
|
|
||||||
}
|
|
||||||
|
|
||||||
public List<SceneObject> LoadObjects()
|
|
||||||
{
|
|
||||||
List<SceneObject> retvals = new List<SceneObject>();
|
|
||||||
|
|
||||||
MainLog.Instance.Verbose("DATASTORE", "Sqlite - LoadObjects found " + " objects");
|
|
||||||
|
|
||||||
return retvals;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void StoreTerrain(double[,] ter)
|
|
||||||
{
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
public double[,] LoadTerrain()
|
|
||||||
{
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void RemoveLandObject(uint id)
|
|
||||||
{
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
public void StoreParcel(Land parcel)
|
|
||||||
{
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
public List<Land> LoadLandObjects()
|
|
||||||
{
|
|
||||||
return new List<Land>();
|
|
||||||
}
|
|
||||||
|
|
||||||
public void Shutdown()
|
|
||||||
{
|
|
||||||
// TODO: DataSet commit
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
Reference in New Issue