diff options
author | Sean Dague | 2007-08-08 19:48:11 +0000 |
---|---|---|
committer | Sean Dague | 2007-08-08 19:48:11 +0000 |
commit | 6ec523d5e6a3edfa665b9c2a7f1120b3aa3b1970 (patch) | |
tree | 1e723eb1ae53d3bf138eceedb6b1d03a06a5fbf2 /OpenSim/Region/Storage/OpenSim.DataStore.Sqlite | |
parent | This chunk of code actually properly saves out some parameters of (diff) | |
download | opensim-SC_OLD-6ec523d5e6a3edfa665b9c2a7f1120b3aa3b1970.zip opensim-SC_OLD-6ec523d5e6a3edfa665b9c2a7f1120b3aa3b1970.tar.gz opensim-SC_OLD-6ec523d5e6a3edfa665b9c2a7f1120b3aa3b1970.tar.bz2 opensim-SC_OLD-6ec523d5e6a3edfa665b9c2a7f1120b3aa3b1970.tar.xz |
moving to new namespace as this is mono only
Diffstat (limited to 'OpenSim/Region/Storage/OpenSim.DataStore.Sqlite')
-rw-r--r-- | OpenSim/Region/Storage/OpenSim.DataStore.Sqlite/SqliteDataStore.cs | 213 |
1 files changed, 0 insertions, 213 deletions
diff --git a/OpenSim/Region/Storage/OpenSim.DataStore.Sqlite/SqliteDataStore.cs b/OpenSim/Region/Storage/OpenSim.DataStore.Sqlite/SqliteDataStore.cs deleted file mode 100644 index 5c17620..0000000 --- a/OpenSim/Region/Storage/OpenSim.DataStore.Sqlite/SqliteDataStore.cs +++ /dev/null | |||
@@ -1,213 +0,0 @@ | |||
1 | using System; | ||
2 | using System.Collections.Generic; | ||
3 | using System.Text; | ||
4 | |||
5 | using OpenSim.Region.Environment.Scenes; | ||
6 | using OpenSim.Region.Environment.LandManagement; | ||
7 | using OpenSim.Region.Environment; | ||
8 | using OpenSim.Region.Interfaces; | ||
9 | using OpenSim.Framework.Console; | ||
10 | using libsecondlife; | ||
11 | |||
12 | using System.Data; | ||
13 | // Yes, this won't compile on MS, need to deal with that later | ||
14 | using Mono.Data.SqliteClient; | ||
15 | using Primitive = OpenSim.Region.Environment.Scenes.Primitive; | ||
16 | |||
17 | namespace OpenSim.DataStore.SqliteStorage | ||
18 | { | ||
19 | |||
20 | public class SqliteDataStore : IRegionDataStore | ||
21 | { | ||
22 | private const string primSelect = "select * from prims"; | ||
23 | private const string shapeSelect = "select * from primshapes"; | ||
24 | |||
25 | private DataSet ds; | ||
26 | private SqliteDataAdapter primDa; | ||
27 | private SqliteDataAdapter shapeDa; | ||
28 | |||
29 | public void Initialise(string dbfile, string dbname) | ||
30 | { | ||
31 | // for us, dbfile will be the connect string | ||
32 | MainLog.Instance.Verbose("DATASTORE", "Sqlite - connecting: " + dbfile); | ||
33 | SqliteConnection conn = new SqliteConnection(dbfile); | ||
34 | |||
35 | SqliteCommand primSelectCmd = new SqliteCommand(primSelect, conn); | ||
36 | primDa = new SqliteDataAdapter(primSelectCmd); | ||
37 | // SqliteCommandBuilder primCb = new SqliteCommandBuilder(primDa); | ||
38 | |||
39 | SqliteCommand shapeSelectCmd = new SqliteCommand(shapeSelect, conn); | ||
40 | shapeDa = new SqliteDataAdapter(shapeSelectCmd); | ||
41 | // SqliteCommandBuilder shapeCb = new SqliteCommandBuilder(shapeDa); | ||
42 | |||
43 | ds = new DataSet(); | ||
44 | |||
45 | // We fill the data set, now we've got copies in memory for the information | ||
46 | // TODO: see if the linkage actually holds. | ||
47 | // primDa.FillSchema(ds, SchemaType.Source, "PrimSchema"); | ||
48 | primDa.Fill(ds, "prims"); | ||
49 | ds.AcceptChanges(); | ||
50 | |||
51 | DataTable prims = ds.Tables["prims"]; | ||
52 | prims.PrimaryKey = new DataColumn[] { prims.Columns["UUID"] }; | ||
53 | setupPrimCommands(primDa, conn); | ||
54 | |||
55 | // shapeDa.FillSchema(ds, SchemaType.Source, "ShapeSchema"); | ||
56 | shapeDa.Fill(ds, "primshapes"); | ||
57 | |||
58 | return; | ||
59 | } | ||
60 | |||
61 | private SqliteParameter createSqliteParameter(string name, DbType type) | ||
62 | { | ||
63 | SqliteParameter param = new SqliteParameter(); | ||
64 | param.ParameterName = ":" + name; | ||
65 | param.DbType = type; | ||
66 | param.SourceColumn = name; | ||
67 | param.SourceVersion = DataRowVersion.Current; | ||
68 | return param; | ||
69 | } | ||
70 | |||
71 | private void setupPrimCommands(SqliteDataAdapter da, SqliteConnection conn) | ||
72 | { | ||
73 | SqliteParameter UUID = createSqliteParameter("UUID", DbType.String); | ||
74 | SqliteParameter Name = createSqliteParameter("Name", DbType.String); | ||
75 | SqliteParameter CreationDate = createSqliteParameter("CreationDate", DbType.Int32); | ||
76 | SqliteParameter PositionX = createSqliteParameter("PositionX", DbType.Double); | ||
77 | SqliteParameter PositionY = createSqliteParameter("PositionY", DbType.Double); | ||
78 | SqliteParameter PositionZ = createSqliteParameter("PositionZ", DbType.Double); | ||
79 | |||
80 | |||
81 | SqliteCommand delete = new SqliteCommand("delete from prims where UUID = :UUID"); | ||
82 | delete.Connection = conn; | ||
83 | |||
84 | SqliteCommand insert = | ||
85 | new SqliteCommand("insert into prims(" + | ||
86 | "UUID, CreationDate, Name, PositionX, PositionY, PositionZ" + | ||
87 | ") values(:UUID, :CreationDate, :Name, :PositionX, :PositionY, :PositionZ)"); | ||
88 | insert.Connection = conn; | ||
89 | |||
90 | SqliteCommand update = | ||
91 | new SqliteCommand("update prims set " + | ||
92 | "UUID = :UUID, CreationDate = :CreationDate, Name = :Name, PositionX = :PositionX, " + | ||
93 | "PositionY = :PositionY, PositionZ = :PositionZ where UUID = :UUID"); | ||
94 | update.Connection = conn; | ||
95 | |||
96 | delete.Parameters.Add(UUID); | ||
97 | |||
98 | insert.Parameters.Add(UUID); | ||
99 | insert.Parameters.Add(Name); | ||
100 | insert.Parameters.Add(CreationDate); | ||
101 | insert.Parameters.Add(PositionX); | ||
102 | insert.Parameters.Add(PositionY); | ||
103 | insert.Parameters.Add(PositionZ); | ||
104 | |||
105 | update.Parameters.Add(UUID); | ||
106 | update.Parameters.Add(Name); | ||
107 | update.Parameters.Add(CreationDate); | ||
108 | update.Parameters.Add(PositionX); | ||
109 | update.Parameters.Add(PositionY); | ||
110 | update.Parameters.Add(PositionZ); | ||
111 | |||
112 | da.DeleteCommand = delete; | ||
113 | da.InsertCommand = insert; | ||
114 | da.UpdateCommand = update; | ||
115 | } | ||
116 | |||
117 | private void StoreSceneObject(SceneObject obj) | ||
118 | { | ||
119 | |||
120 | } | ||
121 | |||
122 | public void StoreObject(AllNewSceneObjectPart2 obj) | ||
123 | { | ||
124 | // TODO: Serializing code | ||
125 | DataTable prims = ds.Tables["prims"]; | ||
126 | DataTable shapes = ds.Tables["shapes"]; | ||
127 | |||
128 | |||
129 | |||
130 | } | ||
131 | |||
132 | private void fillPrimRow(DataRow row, Primitive prim) | ||
133 | { | ||
134 | row["UUID"] = prim.UUID; | ||
135 | row["CreationDate"] = prim.CreationDate; | ||
136 | row["Name"] = prim.Name; | ||
137 | row["PositionX"] = prim.Pos.X; | ||
138 | row["PositionY"] = prim.Pos.Y; | ||
139 | row["PositionZ"] = prim.Pos.Z; | ||
140 | } | ||
141 | |||
142 | private void addPrim(Primitive prim) | ||
143 | { | ||
144 | DataTable prims = ds.Tables["prims"]; | ||
145 | DataTable shapes = ds.Tables["shapes"]; | ||
146 | |||
147 | DataRow row = prims.Rows.Find(prim.UUID); | ||
148 | if (row == null) { | ||
149 | row = prims.NewRow(); | ||
150 | fillPrimRow(row, prim); | ||
151 | prims.Rows.Add(row); | ||
152 | } else { | ||
153 | fillPrimRow(row, prim); | ||
154 | } | ||
155 | } | ||
156 | |||
157 | public void StoreObject(SceneObject obj) | ||
158 | { | ||
159 | foreach (Primitive prim in obj.Children.Values) | ||
160 | { | ||
161 | addPrim(prim); | ||
162 | } | ||
163 | |||
164 | MainLog.Instance.Verbose("Attempting to do update...."); | ||
165 | primDa.Update(ds, "prims"); | ||
166 | MainLog.Instance.Verbose("Dump of prims:", ds.GetXml()); | ||
167 | } | ||
168 | |||
169 | public void RemoveObject(LLUUID obj) | ||
170 | { | ||
171 | // TODO: remove code | ||
172 | } | ||
173 | |||
174 | public List<SceneObject> LoadObjects() | ||
175 | { | ||
176 | List<SceneObject> retvals = new List<SceneObject>(); | ||
177 | |||
178 | MainLog.Instance.Verbose("DATASTORE", "Sqlite - LoadObjects found " + " objects"); | ||
179 | |||
180 | return retvals; | ||
181 | } | ||
182 | |||
183 | public void StoreTerrain(double[,] ter) | ||
184 | { | ||
185 | |||
186 | } | ||
187 | |||
188 | public double[,] LoadTerrain() | ||
189 | { | ||
190 | return null; | ||
191 | } | ||
192 | |||
193 | public void RemoveLandObject(uint id) | ||
194 | { | ||
195 | |||
196 | } | ||
197 | |||
198 | public void StoreParcel(Land parcel) | ||
199 | { | ||
200 | |||
201 | } | ||
202 | |||
203 | public List<Land> LoadLandObjects() | ||
204 | { | ||
205 | return new List<Land>(); | ||
206 | } | ||
207 | |||
208 | public void Shutdown() | ||
209 | { | ||
210 | // TODO: DataSet commit | ||
211 | } | ||
212 | } | ||
213 | } | ||