package com.planet_ink.coffee_mud.core.database;
import com.planet_ink.coffee_mud.core.interfaces.*;
import com.planet_ink.coffee_mud.core.*;
import com.planet_ink.coffee_mud.Abilities.interfaces.*;
import com.planet_ink.coffee_mud.Areas.interfaces.*;
import com.planet_ink.coffee_mud.Behaviors.interfaces.*;
import com.planet_ink.coffee_mud.CharClasses.interfaces.*;
import com.planet_ink.coffee_mud.Commands.interfaces.*;
import com.planet_ink.coffee_mud.Common.interfaces.*;
import com.planet_ink.coffee_mud.Exits.interfaces.*;
import com.planet_ink.coffee_mud.Items.interfaces.*;
import com.planet_ink.coffee_mud.Locales.interfaces.*;
import com.planet_ink.coffee_mud.MOBS.interfaces.*;
import com.planet_ink.coffee_mud.Races.interfaces.*;
import java.sql.*;
import java.util.*;
import com.planet_ink.coffee_mud.Libraries.interfaces.*;
/*
Copyright 2000-2006 Bo Zimmerman
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
public class RoomLoader
{
protected DBConnector DB=null;
public RoomLoader(DBConnector newDB)
{
DB=newDB;
}
private int recordCount=1;
private int currentRecordPos=1;
private int updateBreak=1;
private final static String zeroes="000000000000";
public Vector DBReadAreaData(String areaID, boolean reportStatus)
{
DBConnection D=null;
Vector areas=new Vector();
try
{
D=DB.DBFetch();
if(reportStatus)
CMProps.setUpLowVar(CMProps.SYSTEM_MUDSTATUS,"Booting: Counting Areas");
ResultSet R=D.query("SELECT * FROM CMAREA"+((areaID==null)?"":" WHERE CMAREA='"+areaID+"'"));
recordCount=DB.getRecordCount(D,R);
updateBreak=CMath.s_int("1"+zeroes.substring(0,(""+(recordCount/100)).length()-1));
while(R.next())
{
currentRecordPos=R.getRow();
String areaName=DBConnections.getRes(R,"CMAREA");
String areaType=DBConnections.getRes(R,"CMTYPE");
Area A=CMClass.getAreaType(areaType);
if(A==null) A=CMClass.getAreaType("StdArea");
if(A==null)
{
Log.errOut("Could not create area: "+areaName);
continue;
}
A.setName(areaName);
A.setClimateType((int)DBConnections.getLongRes(R,"CMCLIM"));
A.setSubOpList(DBConnections.getRes(R,"CMSUBS"));
A.setDescription(DBConnections.getRes(R,"CMDESC"));
A.setMiscText(DBConnections.getRes(R,"CMROTX"));
A.setTechLevel((int)DBConnections.getLongRes(R,"CMTECH"));
A.tickControl(true);
if(((currentRecordPos%updateBreak)==0)&&(reportStatus))
CMProps.setUpLowVar(CMProps.SYSTEM_MUDSTATUS,"Booting: Loading Areas ("+currentRecordPos+" of "+recordCount+")");
areas.addElement(A);
}
DB.DBDone(D);
}
catch(SQLException sqle)
{
Log.errOut("Area",sqle);
if(D!=null) DB.DBDone(D);
return null;
}
return areas;
}
public void addRoom(Vector rooms, Room R)
{
Room R2=null;
for(int i=0;i<rooms.size();i++)
{
R2=(Room)rooms.elementAt(i);
if(R2.roomID().compareToIgnoreCase(R.roomID())>=0)
{
if(R2.roomID().compareToIgnoreCase(R.roomID())==0)
rooms.setElementAt(R,i);
else
rooms.insertElementAt(R,i);
return;
}
}
rooms.addElement(R);
}
public Room getRoom(Vector rooms, String roomID)
{
if(rooms.size()==0) return null;
int start=0;
int end=rooms.size()-1;
while(start<=end)
{
int mid=(end+start)/2;
int comp=((Room)rooms.elementAt(mid)).roomID().compareToIgnoreCase(roomID);
if(comp==0)
return (Room)rooms.elementAt(mid);
else
if(comp>0)
end=mid-1;
else
start=mid+1;
}
return null;
}
public RoomnumberSet DBReadAreaRoomList(String areaName, boolean reportStatus)
{
RoomnumberSet roomSet=(RoomnumberSet)CMClass.getCommon("DefaultRoomnumberSet");
DBConnection D=null;
try
{
D=DB.DBFetch();
if(reportStatus)
CMProps.setUpLowVar(CMProps.SYSTEM_MUDSTATUS,"Booting: Fetching roomnums for "+areaName);
ResultSet R=D.query("SELECT * FROM CMROOM"+((areaName==null)?"":" WHERE CMAREA='"+areaName+"'"));
while(R.next())
roomSet.add(DBConnections.getRes(R,"CMROID"));
DB.DBDone(D);
}
catch(SQLException sqle)
{
Log.errOut("RoomSet",sqle);
if(D!=null) DB.DBDone(D);
return null;
}
return roomSet;
}
public Vector DBReadRoomData(String singleRoomIDtoLoad, boolean reportStatus)
{
return DBReadRoomData(singleRoomIDtoLoad,null,reportStatus,null,null);
}
public Vector DBReadRoomData(String singleRoomIDtoLoad,
RoomnumberSet roomsToLoad,
boolean reportStatus,
Vector unknownAreas,
RoomnumberSet unloadedRooms)
{
Vector rooms=new Vector();
DBConnection D=null;
try
{
D=DB.DBFetch();
if(reportStatus)
CMProps.setUpLowVar(CMProps.SYSTEM_MUDSTATUS,"Booting: Counting Rooms");
ResultSet R=D.query("SELECT * FROM CMROOM"+((singleRoomIDtoLoad==null)?"":" WHERE CMROID='"+singleRoomIDtoLoad+"'"));
recordCount=DB.getRecordCount(D,R);
updateBreak=CMath.s_int("1"+zeroes.substring(0,(""+(recordCount/100)).length()-1));
String roomID=null;
while(R.next())
{
currentRecordPos=R.getRow();
roomID=DBConnections.getRes(R,"CMROID");
if((roomsToLoad!=null)&&(!roomsToLoad.contains(roomID)))
continue;
String localeID=DBConnections.getRes(R,"CMLOID");
String areaName=DBConnections.getRes(R,"CMAREA");
Area myArea=CMLib.map().getArea(areaName);
if(myArea==null)
{
myArea=(Area)CMClass.getAreaType("StdArea").copyOf();
myArea.setName(areaName);
if((unknownAreas!=null)
&&(!unknownAreas.contains(areaName)))
unknownAreas.addElement(areaName);
}
myArea.addProperRoomnumber(roomID);
if(CMath.bset(myArea.flags(),Area.FLAG_THIN))
{
if(unloadedRooms!=null)
{
if(!unloadedRooms.contains(roomID))
unloadedRooms.add(roomID);
continue;
}
}
Room newRoom=CMClass.getLocale(localeID);
if(newRoom==null)
Log.errOut("Room","Couldn't load room '"+roomID+"', localeID '"+localeID+"'.");
else
{
newRoom.setRoomID(roomID);
newRoom.setArea(myArea);
newRoom.setDisplayText(DBConnections.getRes(R,"CMDESC1"));
if(CMProps.getBoolVar(CMProps.SYSTEMB_ROOMDNOCACHE))
newRoom.setDescription("");
else
newRoom.setDescription(DBConnections.getRes(R,"CMDESC2"));
newRoom.setMiscText(DBConnections.getRes(R,"CMROTX"));
addRoom(rooms,newRoom);
}
if(((currentRecordPos%updateBreak)==0)&&(reportStatus))
CMProps.setUpLowVar(CMProps.SYSTEM_MUDSTATUS,"Booting: Loading Rooms ("+currentRecordPos+" of "+recordCount+")");
}
}
catch(SQLException sqle)
{
Log.errOut("Room",sqle);
rooms=null;
}
finally
{
if(D!=null) DB.DBDone(D);
}
return rooms;
}
public void DBReadRoomExits(String roomID, Vector allRooms, boolean reportStatus)
{ DBReadRoomExits(roomID,allRooms,reportStatus,null);}
public void DBReadRoomExits(String roomID, Vector allRooms, boolean reportStatus, RoomnumberSet unloadedRooms)
{
DBConnection D=null;
// now grab the exits
try
{
D=DB.DBFetch();
if(reportStatus)
CMProps.setUpLowVar(CMProps.SYSTEM_MUDSTATUS,"Booting: Counting Exits");
ResultSet R=D.query("SELECT * FROM CMROEX"+((roomID==null)?"":" WHERE CMROID='"+roomID+"'"));
Room thisRoom=null;
Room newRoom=null;
recordCount=DB.getRecordCount(D,R);
updateBreak=CMath.s_int("1"+zeroes.substring(0,(""+(recordCount/100)).length()-1));
while(R.next())
{
currentRecordPos=R.getRow();
roomID=DBConnections.getRes(R,"CMROID");
int direction=(int)DBConnections.getLongRes(R,"CMDIRE");
thisRoom=getRoom(allRooms,roomID);
if(thisRoom==null)
{
if(!unloadedRooms.contains(roomID))
Log.errOut("Room","Couldn't set "+direction+" exit for unknown room '"+roomID+"'");
}
else
{
String exitID=DBConnections.getRes(R,"CMEXID");
String exitMiscText=DBConnections.getResQuietly(R,"CMEXTX");
String nextRoomID=DBConnections.getRes(R,"CMNRID");
newRoom=getRoom(allRooms,nextRoomID);
Exit newExit=CMClass.getExit(exitID);
if(newRoom==null)
{
if(((unloadedRooms!=null)&&(unloadedRooms.contains(nextRoomID)))
||(CMath.bset(thisRoom.getArea().flags(),Area.FLAG_THIN)))
{
newRoom=CMClass.getLocale("ThinRoom");
newRoom.setRoomID(nextRoomID);
newRoom.setArea(thisRoom.getArea());
}
}
if((newExit==null)&&(newRoom==null))
Log.errOut("Room",roomID+":no room&exit to '"+nextRoomID+"', exit type '"+exitID+"', direction: "+direction);
else
if((direction>255)&&(!(thisRoom instanceof GridLocale)))
Log.errOut("Room","Not GridLocale, tried "+direction+" exit for room '"+roomID+"'");
else
if(direction>255)
{
Vector CEs=CMParms.parseSemicolons(exitMiscText.trim(),true);
for(int ces=0;ces<CEs.size();ces++)
{
Vector SCE=CMParms.parse(((String)CEs.elementAt(ces)).trim());
WorldMap.CrossExit CE=new WorldMap.CrossExit();
if(SCE.size()<3) continue;
CE.x=CMath.s_int((String)SCE.elementAt(0));
CE.y=CMath.s_int((String)SCE.elementAt(1));
int codeddir=CMath.s_int((String)SCE.elementAt(2));
if(SCE.size()>=4)
CE.destRoomID=newRoom.roomID()+(String)SCE.elementAt(3);
else
CE.destRoomID=newRoom.roomID();
CE.out=(codeddir&256)==256;
CE.dir=codeddir&255;
((GridLocale)thisRoom).addOuterExit(CE);
if((!CE.out)&&(!(newRoom instanceof GridLocale)))
{
newRoom.rawDoors()[CE.dir]=thisRoom;
newRoom.rawExits()[CE.dir]=CMClass.getExit("Open");
}
}
}
else
{
if(newExit!=null)
newExit.setMiscText(exitMiscText);
if(direction>=Directions.NUM_DIRECTIONS)
Log.errOut("RoomLoader",CMLib.map().getExtendedRoomID(thisRoom)+" has an invalid direction #"+direction);
else
{
thisRoom.rawDoors()[direction]=newRoom;
thisRoom.rawExits()[direction]=newExit;
}
}
}
if(reportStatus&&((currentRecordPos%updateBreak)==0))
CMProps.setUpLowVar(CMProps.SYSTEM_MUDSTATUS,"Booting: Loading Exits ("+currentRecordPos+" of "+recordCount+")");
}
}
catch(SQLException sqle)
{
Log.errOut("Room",sqle);
}
finally
{
if(D!=null) DB.DBDone(D);
}
}
public void DBReadAllRooms(RoomnumberSet set)
{
Vector areas=null;
Vector newAreasToCreate=new Vector();
if(set==null)
{
while(CMLib.map().numAreas()>0)CMLib.map().delArea(CMLib.map().getFirstArea());
areas=DBReadAreaData(null,true);
if(areas==null) return;
for(int a=0;a<areas.size();a++)
CMLib.map().addArea((Area)areas.elementAt(a));
areas.clear();
}
RoomnumberSet unloadedRooms=(RoomnumberSet)CMClass.getCommon("DefaultRoomnumberSet");
Vector rooms=DBReadRoomData(null,set,set==null,newAreasToCreate,unloadedRooms);
// handle stray areas
for(Enumeration e=newAreasToCreate.elements();e.hasMoreElements();)
{
String areaName=(String)e.nextElement();
Log.sysOut("Area","Creating unhandled area: "+areaName);
Area realArea=DBCreate(areaName,"StdArea");
for(Enumeration r=rooms.elements();r.hasMoreElements();)
{
Room R=(Room)r.nextElement();
if(R.getArea().Name().equals(areaName))
R.setArea(realArea);
}
}
DBReadRoomExits(null,rooms,set==null,unloadedRooms);
DBReadContent(null,rooms,unloadedRooms,set==null);
if(set==null)
CMProps.setUpLowVar(CMProps.SYSTEM_MUDSTATUS,"Booting: Finalizing room data)");
for(Enumeration r=rooms.elements();r.hasMoreElements();)
{
Room thisRoom=(Room)r.nextElement();
thisRoom.startItemRejuv();
thisRoom.recoverRoomStats();
}
if(set==null)
for(Enumeration a=CMLib.map().areas();a.hasMoreElements();)
((Area)a.nextElement()).getAreaStats();
}
public String DBReadRoomDesc(String roomID)
{
DBConnection D=null;
// now grab the items
try
{
D=DB.DBFetch();
ResultSet R=D.query("SELECT * FROM CMROOM WHERE CMROID='"+roomID+"'");
if(R.next())
{
String txt=DBConnections.getRes(R,"CMDESC2");
DB.DBDone(D);
return txt;
}
DB.DBDone(D);
}
catch(SQLException sqle)
{
Log.errOut("Room",sqle);
if(D!=null) DB.DBDone(D);
}
return null;
}
public String DBReadRoomMOBData(String roomID, String mobID)
{
DBConnection D=null;
// now grab the items
try
{
D=DB.DBFetch();
ResultSet R=D.query("SELECT * FROM CMROCH WHERE CMROID='"+roomID+"'");
while(R.next())
{
String NUMID=DBConnections.getRes(R,"CMCHNM");
if(NUMID.equalsIgnoreCase(mobID))
{
String txt=DBConnections.getRes(R,"CMCHTX");
DB.DBDone(D);
return txt;
}
}
DB.DBDone(D);
}
catch(SQLException sqle)
{
Log.errOut("Room",sqle);
if(D!=null) DB.DBDone(D);
}
return null;
}
private void fixItemKeys(Hashtable itemLocs, Hashtable itemNums)
{
for(Enumeration e=itemLocs.keys();e.hasMoreElements();)
{
Item keyItem=(Item)e.nextElement();
String location=(String)itemLocs.get(keyItem);
Environmental container=(Environmental)itemNums.get(location);
if((container instanceof Container)&&(((Container)container).capacity()>0))
keyItem.setContainer((Container)container);
else
if(container instanceof Rideable)
keyItem.setRiding((Rideable)container);
else
if(container instanceof Item)
keyItem.setContainer((Item)container);
}
}
private void fixMOBRides(Hashtable mobRides, Hashtable itemNums)
{
for(Enumeration e=mobRides.keys();e.hasMoreElements();)
{
MOB M=(MOB)e.nextElement();
String ride=(String)mobRides.get(M);
if(ride!=null)
{
Environmental E=(Environmental)itemNums.get(ride);
if(E!=null)
{
if(E instanceof Rideable)
M.setRiding((Rideable)E);
else
if(E instanceof MOB)
M.setFollowing((MOB)E);
}
}
}
}
public void DBReadContent(Room thisRoom, Vector rooms, RoomnumberSet unloadedRooms, boolean setStatus)
{
boolean debug=Log.debugChannelOn()&&(CMSecurity.isDebugging("DBROOMPOP"));
if(debug||(Log.debugChannelOn()&&(CMSecurity.isDebugging("DBROOMS"))))
Log.debugOut("RoomLoader","Reading content of "+((thisRoom!=null)?thisRoom.roomID():"ALL"));
Hashtable stuff=new Hashtable();
Hashtable itemNums=null;
Hashtable itemLocs=null;
Hashtable mobRides=null;
DBConnection D=null;
// now grab the items
try
{
D=DB.DBFetch();
if(setStatus)
CMProps.setUpLowVar(CMProps.SYSTEM_MUDSTATUS,"Booting: Counting Items");
ResultSet R=D.query("SELECT * FROM CMROIT"+((thisRoom==null)?"":" WHERE CMROID='"+thisRoom.roomID()+"'"));
if(setStatus) recordCount=DB.getRecordCount(D,R);
updateBreak=CMath.s_int("1"+zeroes.substring(0,(""+(recordCount/100)).length()-1));
while(R.next())
{
currentRecordPos=R.getRow();
String roomID=DBConnections.getRes(R,"CMROID");
if((unloadedRooms!=null)&&(unloadedRooms.contains(roomID)))
continue;
itemNums=(Hashtable)stuff.get("NUMSFOR"+roomID);
if(itemNums==null)
{
itemNums=new Hashtable();
stuff.put("NUMSFOR"+roomID,itemNums);
}
itemLocs=(Hashtable)stuff.get("LOCSFOR"+roomID);
if(itemLocs==null)
{
itemLocs=new Hashtable();
stuff.put("LOCSFOR"+roomID,itemLocs);
}
String itemNum=DBConnections.getRes(R,"CMITNM");
String itemID=DBConnections.getRes(R,"CMITID");
Item newItem=CMClass.getItem(itemID);
if(newItem==null)
Log.errOut("Room","Couldn't find item '"+itemID+"'");
else
{
itemNums.put(itemNum,newItem);
String loc=DBConnections.getResQuietly(R,"CMITLO");
if(loc.length()>0)
{
Item container=(Item)itemNums.get(loc);
if(container!=null)
newItem.setContainer(container);
else
itemLocs.put(newItem,loc);
}
newItem.setMiscText(DBConnections.getResQuietly(R,"CMITTX"));
newItem.baseEnvStats().setRejuv((int)DBConnections.getLongRes(R,"CMITRE"));
newItem.setUsesRemaining((int)DBConnections.getLongRes(R,"CMITUR"));
newItem.baseEnvStats().setLevel((int)DBConnections.getLongRes(R,"CMITLV"));
newItem.baseEnvStats().setAbility((int)DBConnections.getLongRes(R,"CMITAB"));
newItem.baseEnvStats().setHeight((int)DBConnections.getLongRes(R,"CMHEIT"));
newItem.recoverEnvStats();
}
if(((currentRecordPos%updateBreak)==0)&&(setStatus))
CMProps.setUpLowVar(CMProps.SYSTEM_MUDSTATUS,"Booting: Loading Items ("+currentRecordPos+" of "+recordCount+")");
}
}
catch(SQLException sqle)
{
Log.errOut("Room",sqle);
}
finally
{
if(D!=null) DB.DBDone(D);
}
// now grab the inhabitants
try
{
D=DB.DBFetch();
if(setStatus)
CMProps.setUpLowVar(CMProps.SYSTEM_MUDSTATUS,"Booting: Counting MOBS");
ResultSet R=D.query("SELECT * FROM CMROCH"+((thisRoom==null)?"":" WHERE CMROID='"+thisRoom.roomID()+"'"));
if(setStatus) recordCount=DB.getRecordCount(D,R);
updateBreak=CMath.s_int("1"+zeroes.substring(0,(""+(recordCount/100)).length()-1));
while(R.next())
{
currentRecordPos=R.getRow();
String roomID=DBConnections.getRes(R,"CMROID");
if((unloadedRooms!=null)&&(unloadedRooms.contains(roomID)))
continue;
String NUMID=DBConnections.getRes(R,"CMCHNM");
String MOBID=DBConnections.getRes(R,"CMCHID");
itemNums=(Hashtable)stuff.get("NUMSFOR"+roomID);
if(itemNums==null)
{
itemNums=new Hashtable();
stuff.put("NUMSFOR"+roomID,itemNums);
}
mobRides=(Hashtable)stuff.get("RIDESFOR"+roomID);
if(mobRides==null)
{
mobRides=new Hashtable();
stuff.put("RIDESFOR"+roomID,mobRides);
}
MOB newMOB=CMClass.getMOB(MOBID);
if(newMOB==null)
Log.errOut("Room","Couldn't find MOB '"+MOBID+"'");
else
{
itemNums.put(NUMID,newMOB);
if(thisRoom!=null)
{
newMOB.setStartRoom(thisRoom);
newMOB.setLocation(thisRoom);
}
if((CMProps.getBoolVar(CMProps.SYSTEMB_MOBNOCACHE))
&&(NUMID.indexOf(MOBID+"@")>=0))
newMOB.setMiscText("%DBID>"+roomID+NUMID.substring(NUMID.indexOf("@")));
else
newMOB.setMiscText(DBConnections.getResQuietly(R,"CMCHTX"));
newMOB.baseEnvStats().setLevel(((int)DBConnections.getLongRes(R,"CMCHLV")));
newMOB.baseEnvStats().setAbility((int)DBConnections.getLongRes(R,"CMCHAB"));
newMOB.baseEnvStats().setRejuv((int)DBConnections.getLongRes(R,"CMCHRE"));
String ride=DBConnections.getRes(R,"CMCHRI");
if((ride!=null)&&(ride.length()>0))
mobRides.put(newMOB,ride);
newMOB.recoverCharStats();
newMOB.recoverEnvStats();
newMOB.recoverMaxState();
newMOB.resetToMaxState();
}
if(((currentRecordPos%updateBreak)==0)&&(setStatus))
CMProps.setUpLowVar(CMProps.SYSTEM_MUDSTATUS,"Booting: Loading MOBs ("+currentRecordPos+" of "+recordCount+")");
}
}
catch(SQLException sqle)
{
Log.errOut("Room",sqle);
}
finally
{
if(D!=null) DB.DBDone(D);
}
if(thisRoom!=null)
{
rooms=new Vector();
rooms.addElement(thisRoom);
}
recordCount=rooms.size();
updateBreak=CMath.s_int("1"+zeroes.substring(0,(""+(recordCount/100)).length()-1));
currentRecordPos=0;
for(Enumeration e=rooms.elements();e.hasMoreElements();)
{
if((((++currentRecordPos)%updateBreak)==0)&&(setStatus))
CMProps.setUpLowVar(CMProps.SYSTEM_MUDSTATUS,"Booting: Populating Rooms ("+(currentRecordPos)+" of "+recordCount+")");
Room room=(Room)e.nextElement();
if(debug) Log.debugOut("RoomLoader","Populating room: "+room.roomID());
itemNums=(Hashtable)stuff.get("NUMSFOR"+room.roomID());
if(itemNums!=null)
{
String lastName=null;
for(Enumeration i=itemNums.elements();i.hasMoreElements();)
{
Environmental E=(Environmental)i.nextElement();
if((debug)&&((lastName==null)||(!lastName.equals(E.Name()))))
{lastName=E.Name(); Log.debugOut("RoomLoader","Loading object(s): "+E.Name());}
if(E instanceof Item)
room.addItem((Item)E);
else
{
((MOB)E).setStartRoom(room);
((MOB)E).bringToLife(room,true);
}
}
itemLocs=(Hashtable)stuff.get("LOCSFOR"+room.roomID());
mobRides=(Hashtable)stuff.get("RIDESFOR"+room.roomID());
if(itemLocs!=null)
{
fixItemKeys(itemLocs,itemNums);
room.recoverRoomStats();
room.recoverRoomStats();
}
if(mobRides!=null)
fixMOBRides(mobRides,itemNums);
}
}
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Done reading content of "+((thisRoom!=null)?thisRoom.roomID():"ALL"));
}
private Vector DBGetContents(Room room)
{
if((!room.savable())||(room.amDestroyed())) return new Vector();
Vector contents=new Vector();
for(int i=0;i<room.numItems();i++)
{
Item thisItem=room.fetchItem(i);
if((thisItem!=null)&&(!contents.contains(thisItem))&&thisItem.savable())
contents.addElement(thisItem);
}
return contents;
}
public void DBUpdateTheseItems(Room room, Vector items)
{
if((!room.savable())||(room.amDestroyed())) return;
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROIT")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Start item update for room "+room.roomID());
DB.update("DELETE FROM CMROIT WHERE CMROID='"+room.roomID()+"'");
try{Thread.sleep(room.numItems());}catch(Exception e){}
if(DB.queryRows("SELECT * FROM CMROIT WHERE CMROID='"+room.roomID()+"'")>0)
Log.errOut("Failed to update items for room "+room.roomID()+".");
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROIT")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Continue item update for room "+room.roomID());
for(int i=0;i<items.size();i++)
{
Item thisItem=(Item)items.elementAt(i);
thisItem.setExpirationDate(0); // saved items won't clear!
Environmental container=thisItem.container();
if((container==null)
&&(thisItem.riding()!=null)
&&(thisItem.riding().savable())
&&(room.isHere(thisItem.riding())))
container=thisItem.riding();
DB.update(
"INSERT INTO CMROIT ("
+"CMROID, "
+"CMITNM, "
+"CMITID, "
+"CMITLO, "
+"CMITTX, "
+"CMITRE, "
+"CMITUR, "
+"CMITLV, "
+"CMITAB, "
+"CMHEIT"
+") values ("
+"'"+room.roomID()+"',"
+"'"+thisItem+"',"
+"'"+thisItem.ID()+"',"
+"'"+((container!=null)?(""+container):"")+"',"
+"'"+thisItem.text()+" ',"
+thisItem.baseEnvStats().rejuv()+","
+thisItem.usesRemaining()+","
+thisItem.baseEnvStats().level()+","
+thisItem.baseEnvStats().ability()+","
+thisItem.baseEnvStats().height()+")");
}
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROIT")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Finished item update for room "+room.roomID());
}
public void DBUpdateItems(Room room)
{
if((!room.savable())||(room.amDestroyed())) return;
DBUpdateTheseItems(room,DBGetContents(room));
}
public void DBUpdateExits(Room room)
{
if((!room.savable())||(room.amDestroyed())) return;
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROEX")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Starting exit update for room "+room.roomID());
DB.update("DELETE FROM CMROEX WHERE CMROID='"+room.roomID()+"'");
if(DB.queryRows("SELECT * FROM CMROEX WHERE CMROID='"+room.roomID()+"'")>0)
Log.errOut("Failed to update exits for room "+room.roomID()+".");
for(int e=0;e<Directions.NUM_DIRECTIONS;e++)
{
Exit thisExit=room.rawExits()[e];
Room thisRoom=room.rawDoors()[e];
if(((thisRoom!=null)||(thisExit!=null))
&&((thisRoom==null)||(thisRoom.savable())))
{
DB.update(
"INSERT INTO CMROEX ("
+"CMROID, "
+"CMDIRE, "
+"CMEXID, "
+"CMEXTX, "
+"CMNRID"
+") values ("
+"'"+room.roomID()+"',"
+e+","
+"'"+((thisExit==null)?" ":thisExit.ID())+"',"
+"'"+((thisExit==null)?" ":thisExit.text())+" ',"
+"'"+((thisRoom==null)?" ":thisRoom.roomID())+"')");
}
}
if(room instanceof GridLocale)
{
Vector exits=((GridLocale)room).outerExits();
HashSet done=new HashSet();
int ordinal=0;
for(int v=0;v<exits.size();v++)
{
WorldMap.CrossExit CE=(WorldMap.CrossExit)exits.elementAt(v);
Room R=CMLib.map().getRoom(CE.destRoomID);
if(R==null) continue;
if(R.getGridParent()!=null) R=R.getGridParent();
if((R.savable())&&(!done.contains(R.roomID())))
{
done.add(R.roomID());
HashSet oldStrs=new HashSet();
for(int v2=0;v2<exits.size();v2++)
{
WorldMap.CrossExit CE2=(WorldMap.CrossExit)exits.elementAt(v2);
if((CE2.destRoomID.equals(R.roomID())
||(CE2.destRoomID.startsWith(R.roomID()+"#("))))
{
String str=CE2.x+" "+CE2.y+" "+((CE2.out?256:512)|CE2.dir)+" "+CE2.destRoomID.substring(R.roomID().length())+";";
if(!oldStrs.contains(str))
oldStrs.add(str);
}
}
StringBuffer exitStr=new StringBuffer("");
for(Iterator a=oldStrs.iterator();a.hasNext();)
exitStr.append((String)a.next());
DB.update(
"INSERT INTO CMROEX ("
+"CMROID, "
+"CMDIRE, "
+"CMEXID, "
+"CMEXTX, "
+"CMNRID"
+") values ("
+"'"+room.roomID()+"',"
+(256+(++ordinal))+","
+"'Open',"
+"'"+exitStr.toString()+"',"
+"'"+R.roomID()+"')");
}
}
}
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROEX")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Finished exit update for room "+room.roomID());
}
private void DBCreateThisMOB(Room room, MOB thisMOB)
{
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROCH")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Creating mob "+thisMOB.name()+" for room "+room.roomID());
String ride=null;
if(thisMOB.riding()!=null)
ride=""+thisMOB.riding();
else
if(thisMOB.amFollowing()!=null)
ride=""+thisMOB.amFollowing();
else
ride="";
String mobID=""+thisMOB;
DB.update(
"INSERT INTO CMROCH ("
+"CMROID, "
+"CMCHNM, "
+"CMCHID, "
+"CMCHTX, "
+"CMCHLV, "
+"CMCHAB, "
+"CMCHRE, "
+"CMCHRI "
+") values ("
+"'"+room.roomID()+"',"
+"'"+mobID+"',"
+"'"+CMClass.classID(thisMOB)+"',"
+"'"+thisMOB.text()+" ',"
+thisMOB.baseEnvStats().level()+","
+thisMOB.baseEnvStats().ability()+","
+thisMOB.baseEnvStats().rejuv()+","
+"'"+ride+"'"
+")");
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROCH")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Created mob "+thisMOB.name()+" for room "+room.roomID());
if(CMProps.getBoolVar(CMProps.SYSTEMB_MOBNOCACHE))
thisMOB.setMiscText("%DBID>"+room.roomID()+mobID.substring(mobID.indexOf("@")));
}
public void DBUpdateTheseMOBs(Room room, Vector mobs)
{
if((!room.savable())||(room.amDestroyed())) return;
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROCH")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Updating mobs for room "+room.roomID());
if(mobs==null) mobs=new Vector();
DB.update("DELETE FROM CMROCH WHERE CMROID='"+room.roomID()+"'");
if(DB.queryRows("SELECT * FROM CMROCH WHERE CMROID='"+room.roomID()+"'")>0)
Log.errOut("Failed to update mobs for room "+room.roomID()+".");
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROCH")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Continue updating mobs for room "+room.roomID());
for(int m=0;m<mobs.size();m++)
{
MOB thisMOB=(MOB)mobs.elementAt(m);
DBCreateThisMOB(room,thisMOB);
}
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROCH")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Done updating mobs for room "+room.roomID());
}
public void DBUpdateMOBs(Room room)
{
if((!room.savable())||(room.amDestroyed())) return;
Vector mobs=new Vector();
for(int m=0;m<room.numInhabitants();m++)
{
MOB thisMOB=room.fetchInhabitant(m);
if((thisMOB!=null)&&(thisMOB.savable()))
mobs.addElement(thisMOB);
}
DBUpdateTheseMOBs(room,mobs);
}
public void DBUpdateAll(Room room)
{
if((!room.savable())||(room.amDestroyed())) return;
DBUpdateRoom(room);
DBUpdateMOBs(room);
DBUpdateExits(room);
DBUpdateItems(room);
}
public void DBUpdateRoom(Room room)
{
if((!room.savable())||(room.amDestroyed())) return;
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROOM")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Start updating room "+room.roomID());
DB.update(
"UPDATE CMROOM SET "
+"CMLOID='"+CMClass.classID(room)+"',"
+"CMAREA='"+room.getArea().Name()+"',"
+"CMDESC1='"+room.displayText()+" ',"
+"CMDESC2='"+room.description()+" ',"
+"CMROTX='"+room.text()+" '"
+"WHERE CMROID='"+room.roomID()+"'");
if(CMProps.getBoolVar(CMProps.SYSTEMB_ROOMDNOCACHE))
room.setDescription("");
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROOM")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Done updating room "+room.roomID());
}
public void DBReCreate(Room room, String oldID)
{
if((!room.savable())||(room.amDestroyed())) return;
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROOM")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Recreating room "+room.roomID());
DB.update(
"UPDATE CMROOM SET "
+"CMROID='"+room.roomID()+"', "
+"CMAREA='"+room.getArea().Name()+"' "
+"WHERE CMROID='"+oldID+"'");
if(CMProps.getBoolVar(CMProps.SYSTEMB_MOBNOCACHE))
for(int m=0;m<room.numInhabitants();m++)
{
MOB M=room.fetchInhabitant(m);
if((M!=null)&&(M.savable()))
M.setMiscText(M.text());
}
DB.update(
"UPDATE CMROCH SET "
+"CMROID='"+room.roomID()+"' "
+"WHERE CMROID='"+oldID+"'");
DB.update(
"UPDATE CMROEX SET "
+"CMROID='"+room.roomID()+"' "
+"WHERE CMROID='"+oldID+"'");
DB.update(
"UPDATE CMROEX SET "
+"CMNRID='"+room.roomID()+"' "
+"WHERE CMNRID='"+oldID+"'");
DB.update(
"UPDATE CMROIT SET "
+"CMROID='"+room.roomID()+"' "
+"WHERE CMROID='"+oldID+"'");
DB.update(
"UPDATE CMCHAR SET "
+"CMROID='"+room.roomID()+"' "
+"WHERE CMROID='"+oldID+"'");
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROOM")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Done recreating room "+room.roomID());
}
public Area DBCreate(String areaName, String areaType)
{
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMAREA")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Creating area "+areaName);
Area A=CMClass.getAreaType(areaType);
if(A==null) A=CMClass.getAreaType("StdArea");
if((A==null)||(areaName.length()==0)) return null;
A=(Area)A.copyOf();
A.setName(areaName);
CMLib.map().addArea(A);
DB.update(
"INSERT INTO CMAREA ("
+"CMAREA,"
+"CMTYPE,"
+"CMCLIM,"
+"CMSUBS,"
+"CMDESC,"
+"CMROTX,"
+"CMTECH"
+") values ("
+"'"+A.Name()+"',"
+"'"+A.ID()+"',"
+""+A.climateType()+","
+"'"+A.getSubOpList()+"',"
+"'"+A.description()+" ',"
+"'"+A.text()+" ',"
+A.getTechLevel()+")");
if(A==null) return null;
A.tickControl(true);
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMAREA")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Done creating area "+areaName);
return A;
}
public void DBUpdate(String keyName,Area A)
{
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMAREA")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Updating area "+A.name());
DB.update(
"UPDATE CMAREA SET "
+"CMAREA='"+A.Name()+"',"
+"CMTYPE='"+A.ID()+"',"
+"CMCLIM="+A.climateType()+","
+"CMSUBS='"+A.getSubOpList()+"',"
+"CMDESC='"+A.description()+" ',"
+"CMROTX='"+A.text()+" ',"
+"CMTECH="+A.getTechLevel()+" "
+"WHERE CMAREA='"+keyName+"'");
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMAREA")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Done updating area "+A.name());
}
public void DBUpdateRoomMOB(String keyName, Room room, MOB mob)
{
if((room==null)||(!room.savable())||(room.amDestroyed())) return;
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROCH")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Done updating mob "+mob.name()+" in room "+room.roomID());
DB.update(
"DELETE FROM CMROCH "
+"WHERE CMROID='"+room.roomID()+"' "
+"AND CMCHNM='"+keyName+"'");
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROCH")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Continue updating mob "+mob.name()+" in room "+room.roomID());
DBCreateThisMOB(room,mob);
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROCH")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Done updating mob "+mob.name()+" in room "+room.roomID());
}
public void DBDelete(Area A)
{
if(A==null) return;
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMAREA")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Destroying area "+A.name());
A.tickControl(false);
DB.update("DELETE FROM CMAREA WHERE CMAREA='"+A.Name()+"'");
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMAREA")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Done destroying area "+A.name()+".");
}
public void DBCreate(Room room, String LocaleID)
{
if(!room.savable()) return;
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROOM")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Creating new room "+room.roomID());
DB.update(
"INSERT INTO CMROOM ("
+"CMROID,"
+"CMLOID,"
+"CMAREA,"
+"CMDESC1,"
+"CMDESC2,"
+"CMROTX"
+") values ("
+"'"+room.roomID()+"',"
+"'"+LocaleID+"',"
+"'"+room.getArea().Name()+"',"
+"'"+room.displayText()+" ',"
+"'"+room.description()+" ',"
+"'"+room.text()+" ')");
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROOM")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Done creating new room "+room.roomID());
}
public void DBDelete(Room room)
{
if(!room.savable()) return;
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROCH")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Destroying room "+room.roomID());
room.destroy();
DB.update("DELETE FROM CMROCH WHERE CMROID='"+room.roomID()+"'");
DB.update("DELETE FROM CMROIT WHERE CMROID='"+room.roomID()+"'");
DB.update("DELETE FROM CMROEX WHERE CMROID='"+room.roomID()+"'");
DB.update("DELETE FROM CMROOM WHERE CMROID='"+room.roomID()+"'");
room.destroy();
if(Log.debugChannelOn()&&(CMSecurity.isDebugging("CMROCH")||CMSecurity.isDebugging("DBROOMS")))
Log.debugOut("RoomLoader","Done gestroying room "+room.roomID());
}
}
