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.core.CMSecurity.SecFlag;
import com.planet_ink.coffee_mud.core.CMSecurity.SecGroup;
import com.planet_ink.coffee_mud.core.collections.*;
import com.planet_ink.coffee_mud.core.database.DBConnector.DBPreparedBatchEntry;
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.Common.interfaces.Clan.MemberRecord;
import com.planet_ink.coffee_mud.Common.interfaces.PlayerAccount.AccountFlag;
import com.planet_ink.coffee_mud.Common.interfaces.PlayerStats.PlayerFlag;
import com.planet_ink.coffee_mud.Exits.interfaces.*;
import com.planet_ink.coffee_mud.Items.interfaces.*;
import com.planet_ink.coffee_mud.Libraries.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 java.util.Map.Entry;
/*
Copyright 2002-2019 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 MOBloader
{
protected DBConnector DB=null;
public MOBloader(final DBConnector newDB)
{
DB=newDB;
}
protected Room emptyRoom=null;
public MOB DBReadUserOnly(String name, final String[] locationID)
{
if((name==null)||(name.length()==0))
return null;
DBConnection D=null;
MOB mob=null;
name = DB.injectionClean(name);
int oldDisposition=0;
try
{
D=DB.DBFetch();
ResultSet R=D.query("SELECT * FROM CMCHAR WHERE CMUSERID='"+name+"'");
if(R.next())
{
mob=CMClass.getMOB(DBConnections.getRes(R,"CMCHID"));
if(mob == null)
{
mob=CMClass.getMOB("StdMOB");
if(mob == null)
return null;
}
oldDisposition=mob.basePhyStats().disposition();
mob.basePhyStats().setDisposition(PhyStats.IS_NOT_SEEN|PhyStats.IS_SNEAKING);
mob.phyStats().setDisposition(PhyStats.IS_NOT_SEEN|PhyStats.IS_SNEAKING);
mob.setDisplayText(""); // for centaur
final CharStats stats=mob.baseCharStats();
final CharState state=mob.baseState();
final PlayerStats pstats=(PlayerStats)CMClass.getCommon("DefaultPlayerStats");
mob.setPlayerStats(pstats);
final String username=DBConnections.getRes(R,"CMUSERID");
final String password=DBConnections.getRes(R,"CMPASS");
mob.setName(username);
pstats.setPassword(password);
stats.setMyClasses(DBConnections.getRes(R,"CMCLAS"));
stats.setStat(CharStats.STAT_STRENGTH,CMath.s_int(DBConnections.getRes(R,"CMSTRE")));
stats.setMyRace(CMClass.getRace(DBConnections.getRes(R,"CMRACE")));
stats.setStat(CharStats.STAT_DEXTERITY,CMath.s_int(DBConnections.getRes(R,"CMDEXT")));
stats.setStat(CharStats.STAT_CONSTITUTION,CMath.s_int(DBConnections.getRes(R,"CMCONS")));
stats.setStat(CharStats.STAT_GENDER,DBConnections.getRes(R,"CMGEND").charAt(0));
stats.setStat(CharStats.STAT_WISDOM,CMath.s_int(DBConnections.getRes(R,"CMWISD")));
stats.setStat(CharStats.STAT_INTELLIGENCE,CMath.s_int(DBConnections.getRes(R,"CMINTE")));
stats.setStat(CharStats.STAT_CHARISMA,CMath.s_int(DBConnections.getRes(R,"CMCHAR")));
state.setHitPoints(CMath.s_int(DBConnections.getRes(R,"CMHITP")));
stats.setMyLevels(DBConnections.getRes(R,"CMLEVL"));
int level=0;
for(int i=0;i<mob.baseCharStats().numClasses();i++)
level+=stats.getClassLevel(mob.baseCharStats().getMyClass(i));
mob.basePhyStats().setLevel(level);
state.setMana(CMath.s_int(DBConnections.getRes(R,"CMMANA")));
state.setMovement(CMath.s_int(DBConnections.getRes(R,"CMMOVE")));
mob.setDescription(DBConnections.getRes(R,"CMDESC"));
final int align=(CMath.s_int(DBConnections.getRes(R,"CMALIG")));
if((CMLib.factions().getFaction(CMLib.factions().getAlignmentID())!=null)&&(align>=0))
CMLib.factions().setAlignmentOldRange(mob,align);
mob.setExperience(CMath.s_int(DBConnections.getRes(R,"CMEXPE")));
//mob.setExpNextLevel(CMath.s_int(DBConnections.getRes(R,"CMEXLV")));
mob.setWorshipCharID(DBConnections.getRes(R,"CMWORS"));
mob.setPractices(CMath.s_int(DBConnections.getRes(R,"CMPRAC")));
mob.setTrains(CMath.s_int(DBConnections.getRes(R,"CMTRAI")));
mob.setAgeMinutes(CMath.s_long(DBConnections.getRes(R,"CMAGEH")));
mob.setMoney(CMath.s_int(DBConnections.getRes(R,"CMGOLD")));
mob.setWimpHitPoint(CMath.s_int(DBConnections.getRes(R,"CMWIMP")));
mob.setQuestPoint(CMath.s_int(DBConnections.getRes(R,"CMQUES")));
String roomID=DBConnections.getRes(R,"CMROID");
if(roomID==null)
roomID="";
final int x=roomID.indexOf("||");
if(x>=0)
{
locationID[0]=roomID.substring(x+2);
mob.setLocation(CMLib.map().getRoom(locationID[0]));
roomID=roomID.substring(0,x);
}
mob.setStartRoom(CMLib.map().getRoom(roomID));
pstats.setLastDateTime(CMath.s_long(DBConnections.getRes(R,"CMDATE")));
pstats.setChannelMask((int)DBConnections.getLongRes(R,"CMCHAN"));
mob.basePhyStats().setAttackAdjustment(CMath.s_int(DBConnections.getRes(R,"CMATTA")));
mob.basePhyStats().setArmor(CMath.s_int(DBConnections.getRes(R,"CMAMOR")));
mob.basePhyStats().setDamage(CMath.s_int(DBConnections.getRes(R,"CMDAMG")));
mob.setAttributesBitmap(CMath.s_int(DBConnections.getRes(R,"CMBTMP")));
mob.setLiegeID(DBConnections.getRes(R,"CMLEIG"));
mob.basePhyStats().setHeight((int)DBConnections.getLongRes(R,"CMHEIT"));
mob.basePhyStats().setWeight((int)DBConnections.getLongRes(R,"CMWEIT"));
pstats.setPrompt(DBConnections.getRes(R,"CMPRPT"));
final String colorStr=DBConnections.getRes(R,"CMCOLR");
if((colorStr!=null)&&(colorStr.length()>0)&&(!colorStr.equalsIgnoreCase("NULL")))
pstats.setColorStr(colorStr);
pstats.setLastIP(DBConnections.getRes(R,"CMLSIP"));
mob.setClan("", Integer.MIN_VALUE); // delete all sequence
pstats.setEmail(DBConnections.getRes(R,"CMEMAL"));
final String buf=DBConnections.getRes(R,"CMPFIL");
pstats.setXML(buf);
stats.setNonBaseStatsFromString(DBConnections.getRes(R,"CMSAVE"));
List<String> V9=CMParms.parseSemicolons(CMLib.xml().returnXMLValue(buf,"TATTS"),true);
for(final Enumeration<Tattoo> e=mob.tattoos();e.hasMoreElements();)
mob.delTattoo(e.nextElement());
for(final String tatt : V9)
mob.addTattoo(((Tattoo)CMClass.getCommon("DefaultTattoo")).parse(tatt));
V9=CMParms.parseSemicolons(CMLib.xml().returnXMLValue(buf,"EDUS"),true);
mob.delAllExpertises();
for(int v=0;v<V9.size();v++)
mob.addExpertise(V9.get(v));
// check for a non-existant birthday and fix it
if(pstats.getBirthday()==null)
{
stats.setStat(CharStats.STAT_AGE,
pstats.initializeBirthday(CMLib.time().localClock(mob.getStartRoom()),(int)Math.round(CMath.div(mob.getAgeMinutes(),60.0)),stats.getMyRace()));
}
final TimeClock C=CMLib.time().localClock(mob.getStartRoom());
// check for a messed up/reset birthday and fix it
if((pstats.getBirthday()[PlayerStats.BIRTHDEX_YEAR]==1)
||(pstats.getBirthday()[PlayerStats.BIRTHDEX_YEAR]>C.getYear()))
{
final int age = mob.baseCharStats().getStat(CharStats.STAT_AGE);
if((pstats.getBirthday()[PlayerStats.BIRTHDEX_MONTH]==1)
&&(pstats.getBirthday()[PlayerStats.BIRTHDEX_DAY]==1))
{
if((age > 1)&&(C.getYear() > age))
pstats.initializeBirthday(C,(int)Math.round(CMath.div(mob.getAgeMinutes(),60.0)),stats.getMyRace());
Log.warnOut("MOBloader","Reset the birthday of player '"+mob.Name()+"' (Might have been holdover from being first-year player)");
}
if((age > 1)&&(C.getYear() > age))
{
pstats.getBirthday()[PlayerStats.BIRTHDEX_YEAR]=C.getYear()-age;
pstats.getBirthday()[PlayerStats.BIRTHDEX_LASTYEARCELEBRATED]=C.getYear();
}
}
mob.setImage(CMLib.xml().returnXMLValue(buf,"IMG"));
final List<XMLLibrary.XMLTag> CleanXML=CMLib.xml().parseAllXML(DBConnections.getRes(R,"CMMXML"));
R.close();
if(pstats.getSavedPose().length()>0)
mob.setDisplayText(pstats.getSavedPose());
CMLib.coffeeMaker().setFactionFromXML(mob,CleanXML);
if((CMProps.isUsingAccountSystem())&&(pstats.getAccount()==null))
{
// yes, this can happen when you wiggle in and out of the account system.
for(final Enumeration<PlayerAccount> a = CMLib.players().accounts(); a.hasMoreElements();)
{
final PlayerAccount pA=a.nextElement();
if(pA.findPlayer(mob.Name())!=null)
{
pstats.setAccount(pA);
break;
}
}
}
CMLib.achievements().loadPlayerSkillAwards(mob, pstats);
}
R.close();
R=D.query("SELECT * FROM CMCHCL WHERE CMUSERID='"+name+"'");
while(R.next() && (mob!=null))
{
final String clanID=DBConnections.getRes(R,"CMCLAN");
final int clanRole = this.BuildClanMemberRole(R);
final Clan C=CMLib.clans().getClan(clanID);
if(C!=null)
mob.setClan(C.clanID(), clanRole);
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
if(mob != null)
{
mob.basePhyStats().setDisposition(oldDisposition);
mob.recoverPhyStats();
}
return mob;
}
public int DBReadPlayerBitmap(String name)
{
if((name==null)||(name.length()==0))
return -1;
DBConnection D=null;
name = DB.injectionClean(name);
int bitmap=-1;
try
{
D=DB.DBFetch();
final ResultSet R=D.query("SELECT CMBTMP FROM CMCHAR WHERE CMUSERID='"+name+"'");
if(R.next())
bitmap = CMath.s_int(DBConnections.getRes(R,"CMBTMP"));
R.close();
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return bitmap;
}
public PairList<String,String> DBReadPlayerItemData(String name, final String searchStr)
{
final PairList<String,String> items=new PairVector<String,String>();
if((name==null)||(name.length()==0))
return items;
name=CMStrings.capitalizeAndLower(DB.injectionClean(name));
DBConnection D=null;
// now grab the items
try
{
D=DB.DBFetch();
final ResultSet R=D.query("SELECT * FROM CMCHIT WHERE CMUSERID='"+name+"'");
while(R.next())
{
final String itemID=DBConnections.getRes(R,"CMITID");
final Item newItem=CMClass.getItemPrototype(itemID);
if(newItem==null)
Log.errOut("MOB","Couldn't find item '"+itemID+"'");
else
{
final String text=DBConnections.getResQuietly(R,"CMITTX");
if(text != null)
{
if((searchStr == null)
||(text.indexOf(searchStr)>=0))
items.add(itemID, text);
}
}
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return items;
}
public MOB DBRead(final String name)
{
if((name==null)||(name.length()==0))
return null;
if(emptyRoom==null)
emptyRoom=CMClass.getLocale("StdRoom");
final String[] oldLocID=new String[1];
if(CMLib.players().getPlayer(name)!=null) // super important to stay this t-group
return CMLib.players().getPlayer(name);
final MOB mob=DBReadUserOnly(name,oldLocID);
if(mob == null)
return null;
final int oldDisposition=mob.basePhyStats().disposition();
mob.basePhyStats().setDisposition(PhyStats.IS_NOT_SEEN|PhyStats.IS_SNEAKING);
mob.phyStats().setDisposition(PhyStats.IS_NOT_SEEN|PhyStats.IS_SNEAKING);
CMLib.players().addPlayer(mob);
mob.recoverPhyStats();
mob.recoverCharStats();
Room prevRoom=mob.location();
boolean inhab=false;
if(prevRoom!=null)
inhab=prevRoom.isInhabitant(mob);
mob.setLocation(mob.getStartRoom());
DBConnection D=null;
// now grab the items
try
{
D=DB.DBFetch();
final ResultSet R=D.query("SELECT * FROM CMCHIT WHERE CMUSERID='"+mob.Name()+"'");
final Map<String,Item> itemNums=new HashMap<String,Item>();
final Map<Item,String> itemLocs=new HashMap<Item,String>();
while(R.next())
{
final String itemNum=DBConnections.getRes(R,"CMITNM");
final String itemID=DBConnections.getRes(R,"CMITID");
final Item newItem=CMClass.getItem(itemID);
if(newItem==null)
Log.errOut("MOB","Couldn't find item '"+itemID+"'");
else
{
itemNums.put(itemNum,newItem);
boolean addToMOB=true;
String text=DBConnections.getResQuietly(R,"CMITTX");
int roomX;
if(text.startsWith("<ROOM") && ((roomX=text.indexOf("/>"))>=0))
{
final String roomXML=text.substring(0,roomX+2);
text=text.substring(roomX+2);
newItem.setMiscText(text);
final List<XMLLibrary.XMLTag> xml=CMLib.xml().parseAllXML(roomXML);
if((xml!=null)&&(xml.size()>0))
{
final String roomID=xml.get(0).parms().get("ID");
final long expirationDate=CMath.s_long(xml.get(0).parms().get("EXPIRE"));
if(roomID.startsWith("SPACE.") && (newItem instanceof SpaceObject))
{
CMLib.map().addObjectToSpace((SpaceObject)newItem,CMParms.toLongArray(CMParms.parseCommas(roomID.substring(6), true)));
addToMOB=false;
}
else
{
final Room itemR=CMLib.map().getRoom(roomID);
if(itemR!=null)
{
if(newItem instanceof BoardableShip)
((BoardableShip)newItem).dockHere(itemR);
else
itemR.addItem(newItem);
newItem.setExpirationDate(expirationDate);
addToMOB=false;
}
else
if(newItem instanceof BoardableShip)
{
Log.errOut("Destroying "+newItem.name()+" on "+name+" because it has an invalid location '"+roomID+"'.");
newItem.destroy();
continue;
}
}
}
}
else
{
newItem.setMiscText(text);
}
if((prevRoom==null)
&&(newItem instanceof BoardableShip))
{
final Area area=((BoardableShip)newItem).getShipArea();
if(area != null)
prevRoom=area.getRoom(oldLocID[0]);
}
final String loc=DBConnections.getResQuietly(R,"CMITLO");
if(loc.length()>0)
{
final Item container=itemNums.get(loc);
if(container instanceof Container)
newItem.setContainer((Container)container);
else
itemLocs.put(newItem,loc);
}
newItem.wearAt((int)DBConnections.getLongRes(R,"CMITWO"));
newItem.setUsesRemaining((int)DBConnections.getLongRes(R,"CMITUR"));
newItem.basePhyStats().setLevel((int)DBConnections.getLongRes(R,"CMITLV"));
newItem.basePhyStats().setAbility((int)DBConnections.getLongRes(R,"CMITAB"));
newItem.basePhyStats().setHeight((int)DBConnections.getLongRes(R,"CMHEIT"));
newItem.recoverPhyStats();
if(addToMOB)
{
mob.addItem(newItem);
if(newItem instanceof BoardableShip)
CMLib.map().registerWorldObjectLoaded(null, null, newItem);
}
else
{
CMLib.map().registerWorldObjectLoaded(null, null, newItem);
mob.playerStats().getExtItems().addItem(newItem);
if((newItem instanceof DeadBody) // legacy fix
&&(((DeadBody)newItem).isPlayerCorpse())
&&(newItem.isSavable()))
newItem.setSavable(false); // so the rooms dont save it.
}
}
}
for(final Item keyItem : itemLocs.keySet())
{
final String location=itemLocs.get(keyItem);
final Item container=itemNums.get(location);
if(container instanceof Container)
{
keyItem.setContainer((Container)container);
keyItem.recoverPhyStats();
container.recoverPhyStats();
}
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
D=null;
if(prevRoom!=null)
{
mob.setLocation(prevRoom);
if(inhab&&(!prevRoom.isInhabitant(mob)))
prevRoom.addInhabitant(mob);
}
else
if((mob.location()!=null)
&&((inhab&&(!mob.location().isInhabitant(mob)))))
mob.location().addInhabitant(mob);
// now grab the abilities
try
{
D=DB.DBFetch();
final ResultSet R=D.query("SELECT * FROM CMCHAB WHERE CMUSERID='"+mob.Name()+"'");
while(R.next())
{
final String abilityID=DBConnections.getRes(R,"CMABID");
int proficiency=(int)DBConnections.getLongRes(R,"CMABPF");
if((proficiency==Integer.MIN_VALUE)||(proficiency==Integer.MIN_VALUE+1))
{
if(abilityID.equalsIgnoreCase("ScriptingEngine"))
{
if(CMClass.getCommon("DefaultScriptingEngine")==null)
Log.errOut("MOB","Couldn't find scripting engine!");
else
{
final String xml=DBConnections.getRes(R,"CMABTX");
if(xml.length()>0)
CMLib.coffeeMaker().setGenScripts(mob,CMLib.xml().parseAllXML(xml),true);
}
}
else
{
final Behavior newBehavior=CMClass.getBehavior(abilityID);
if(newBehavior==null)
Log.errOut("MOB","Couldn't find behavior '"+abilityID+"'");
else
{
newBehavior.setParms(DBConnections.getRes(R,"CMABTX"));
mob.addBehavior(newBehavior);
}
}
}
else
{
final Ability newAbility=CMClass.getAbility(abilityID);
if(newAbility==null)
Log.errOut("MOB","Couldn't find ability '"+abilityID+"'");
else
{
if((proficiency<0)||(proficiency==Integer.MAX_VALUE))
{
if(proficiency==Integer.MAX_VALUE)
{
newAbility.setProficiency(CMLib.ableMapper().getMaxProficiency(newAbility.ID()));
mob.addNonUninvokableEffect(newAbility);
newAbility.setMiscText(DBConnections.getRes(R,"CMABTX"));
}
else
{
proficiency=proficiency+200;
newAbility.setProficiency(proficiency);
newAbility.setMiscText(DBConnections.getRes(R,"CMABTX"));
final Ability newAbility2=(Ability)newAbility.copyOf();
mob.addNonUninvokableEffect(newAbility);
mob.addAbility(newAbility2);
}
}
else
{
newAbility.setProficiency(proficiency);
newAbility.setMiscText(DBConnections.getRes(R,"CMABTX"));
mob.addAbility(newAbility);
}
}
}
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
D=null;
mob.basePhyStats().setDisposition(oldDisposition);
mob.recoverPhyStats();
if(mob.baseCharStats()!=null)
{
mob.baseCharStats().getCurrentClass().startCharacter(mob,false,true);
final int oldWeight=mob.basePhyStats().weight();
final int oldHeight=mob.basePhyStats().height();
mob.baseCharStats().getMyRace().startRacing(mob,true);
if(oldWeight>0)
mob.basePhyStats().setWeight(oldWeight);
if(oldHeight>0)
mob.basePhyStats().setHeight(oldHeight);
}
mob.recoverCharStats();
mob.recoverPhyStats();
mob.recoverMaxState();
mob.resetToMaxState();
CMLib.threads().suspendResumeRecurse(mob, false, true);
return mob;
}
public List<String> getUserList()
{
DBConnection D=null;
final Vector<String> V=new Vector<String>();
try
{
D=DB.DBFetch();
final ResultSet R=D.query("SELECT * FROM CMCHAR");
if(R!=null) while(R.next())
{
final String username=DBConnections.getRes(R,"CMUSERID");
V.addElement(username);
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return V;
}
protected PlayerLibrary.ThinPlayer parseThinUser(final ResultSet R)
{
try
{
final String name=DBConnections.getRes(R,"CMUSERID");
String cclass=DBConnections.getRes(R,"CMCLAS");
final int x=cclass.lastIndexOf(';');
CharClass C=null;
if((x>0)&&(x<cclass.length()-2))
{
C=CMClass.getCharClass(cclass.substring(x+1));
if(C!=null)
{
if(C.nameSet().length>1)
cclass=C.ID();
else
cclass=C.name();
}
}
final String charClass=(cclass);
final String rrace=DBConnections.getRes(R,"CMRACE");
final Race R2=CMClass.getRace(rrace);
final String race;
if(R2!=null)
race=(R2.name());
else
race=rrace;
final List<String> lvls=CMParms.parseSemicolons(DBConnections.getRes(R,"CMLEVL"), true);
int calcLevel=0;
for(final String lvl : lvls)
calcLevel+=CMath.s_int(lvl);
final int level = calcLevel;
final int age=(int)DBConnections.getLongRes(R,"CMAGEH");
final MOB M=CMLib.players().getPlayer(name);
final long last;
if((M!=null)&&(M.lastTickedDateTime()>0))
last=M.lastTickedDateTime();
else
last=DBConnections.getLongRes(R,"CMDATE");
final String lsIP=DBConnections.getRes(R,"CMLSIP");
final String email=DBConnections.getRes(R,"CMEMAL");
final String ip=lsIP;
final int exp=CMath.s_int(DBConnections.getRes(R,"CMEXPE"));
final int expLvl=CMath.s_int(DBConnections.getRes(R,"CMEXLV"));
final String leigeID=DBConnections.getRes(R,"CMLEIG");
final String worshipID=DBConnections.getRes(R,"CMWORS");
return new PlayerLibrary.ThinPlayer()
{
@Override
public String name()
{
return name;
}
@Override
public String charClass()
{
return charClass;
}
@Override
public String race()
{
return race;
}
@Override
public int level()
{
return level;
}
@Override
public int age()
{
return age;
}
@Override
public long last()
{
return last;
}
@Override
public String email()
{
return email;
}
@Override
public String ip()
{
return ip;
}
@Override
public int exp()
{
return exp;
}
@Override
public int expLvl()
{
return expLvl;
}
@Override
public String liege()
{
return leigeID;
}
@Override
public String worship()
{
return worshipID;
}
};
}
catch(final Exception e)
{
Log.errOut("MOBloader",e);
}
return null;
}
public PlayerLibrary.ThinPlayer getThinUser(String name)
{
DBConnection D=null;
PlayerLibrary.ThinPlayer thisUser=null;
name=DB.injectionClean(name);
try
{
D=DB.DBFetch();
final ResultSet R=D.query("SELECT * FROM CMCHAR WHERE CMUSERID='"+name+"'");
if(R!=null) while(R.next())
thisUser=parseThinUser(R);
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return thisUser;
}
public List<PlayerLibrary.ThinPlayer> getExtendedUserList()
{
DBConnection D=null;
final Vector<PlayerLibrary.ThinPlayer> allUsers=new Vector<PlayerLibrary.ThinPlayer>();
try
{
D=DB.DBFetch();
final ResultSet R=D.query("SELECT * FROM CMCHAR");
if(R!=null) while(R.next())
{
final PlayerLibrary.ThinPlayer thisUser=parseThinUser(R);
if(thisUser != null)
allUsers.addElement(thisUser);
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return allUsers;
}
public List<PlayerLibrary.ThinPlayer> vassals(String liegeName)
{
DBConnection D=null;
final List<PlayerLibrary.ThinPlayer> list=new ArrayList<PlayerLibrary.ThinPlayer>();
liegeName=DB.injectionClean(liegeName);
try
{
D=DB.DBFetch();
final ResultSet R=D.query("SELECT * FROM CMCHAR WHERE CMLEIG='"+liegeName+"'");
if(R!=null)
{
while(R.next())
list.add(this.parseThinUser(R));
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return list;
}
public List<PlayerLibrary.ThinPlayer> worshippers(String deityID)
{
DBConnection D=null;
final List<PlayerLibrary.ThinPlayer> DV=new Vector<PlayerLibrary.ThinPlayer>();
try
{
D=DB.DBFetch();
deityID=DB.injectionClean(deityID);
final ResultSet R=D.query("SELECT * FROM CMCHAR WHERE CMWORS='"+deityID+"'");
if(R!=null) while(R.next())
{
DV.add(parseThinUser(R));
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return DV;
}
public List<MOB> DBScanFollowers(String name)
{
DBConnection D=null;
final Vector<MOB> V=new Vector<MOB>();
// now grab the followers
try
{
D=DB.DBFetch();
name=DB.injectionClean(name);
final ResultSet R=D.query("SELECT * FROM CMCHFO WHERE CMUSERID='"+name+"'");
while(R.next())
{
final String MOBID=DBConnections.getRes(R,"CMFOID");
final MOB newMOB=CMClass.getMOB(MOBID);
if(newMOB==null)
Log.errOut("MOB","Couldn't find MOB '"+MOBID+"'");
else
{
newMOB.setMiscText(DBConnections.getResQuietly(R,"CMFOTX"));
newMOB.basePhyStats().setLevel(((int)DBConnections.getLongRes(R,"CMFOLV")));
newMOB.basePhyStats().setAbility((int)DBConnections.getLongRes(R,"CMFOAB"));
newMOB.basePhyStats().setRejuv(PhyStats.NO_REJUV);
newMOB.recoverPhyStats();
newMOB.recoverCharStats();
newMOB.recoverMaxState();
newMOB.resetToMaxState();
V.addElement(newMOB);
}
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return V;
}
public void DBReadFollowers(final MOB mob, final boolean bringToLife)
{
Room location=mob.location();
if(location==null)
location=mob.getStartRoom();
final List<MOB> V=DBScanFollowers(mob.Name());
for(int v=0;v<V.size();v++)
{
final MOB newMOB=V.get(v);
final Room room=(location==null)?newMOB.getStartRoom():location;
newMOB.setStartRoom(room);
newMOB.setLocation(room);
newMOB.setFollowing(mob);
if((newMOB.getStartRoom()!=null)
&&(CMLib.law().doesHavePriviledgesHere(mob,newMOB.getStartRoom()))
&&((newMOB.location()==null)
||(!CMLib.law().doesHavePriviledgesHere(mob,newMOB.location()))))
{
newMOB.setLocation(newMOB.getStartRoom());
}
if(bringToLife)
{
newMOB.bringToLife(mob.location(),true);
mob.location().showOthers(newMOB,null,CMMsg.MSG_OK_ACTION,CMLib.lang().L("<S-NAME> appears!"));
}
}
}
public void DBUpdateEmail(final MOB mob)
{
final PlayerStats pstats=mob.playerStats();
if(pstats==null)
return;
final String name=DB.injectionClean(mob.Name());
final String email=DB.injectionClean(pstats.getEmail());
DB.update("UPDATE CMCHAR SET CMEMAL='"+email+"' WHERE CMUSERID='"+name+"'");
}
private int BuildClanMemberRole(final ResultSet R)
{
return (int)DBConnections.getLongRes(R,"CMCLRO");
}
private MemberRecord BuildClanMemberRecord(final ResultSet R)
{
final String username=DB.getRes(R,"CMUSERID");
final int clanRole = BuildClanMemberRole(R);
int mobpvps=0;
int playerpvps=0;
long donatedXP=0;
long joinDate=0;
double donatedGold=0;
final String stats=DB.getRes(R,"CMCLSTS");
if(stats!=null)
{
final String[] splitstats=stats.split(";");
if(splitstats.length>0)
mobpvps=CMath.s_int(splitstats[0]);
if(splitstats.length>1)
playerpvps=CMath.s_int(splitstats[1]);
if(splitstats.length>2)
donatedGold=CMath.s_double(splitstats[2]);
if(splitstats.length>3)
donatedXP=CMath.s_long(splitstats[3]);
if(splitstats.length>4)
joinDate=CMath.s_long(splitstats[4]);
}
final Clan.MemberRecord mR=new Clan.MemberRecord(username,clanRole);
mR.mobpvps=mobpvps;
mR.playerpvps=playerpvps;
mR.donatedGold=donatedGold;
mR.donatedXP=donatedXP;
mR.joinDate=joinDate;
return mR;
}
public MemberRecord DBGetClanMember(String clan, String name)
{
DBConnection D=null;
try
{
D=DB.DBFetch();
name=DB.injectionClean(name);
clan=DB.injectionClean(clan);
final ResultSet R=D.query("SELECT * FROM CMCHCL where CMCLAN='"+clan+"' and CMUSERID='"+name+"'");
if(R!=null) while(R.next())
{
return BuildClanMemberRecord(R);
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return null;
}
public List<Clan.MemberRecord> DBClanMembers(String clan)
{
final List<Clan.MemberRecord> members = new Vector<Clan.MemberRecord>();
DBConnection D=null;
try
{
D=DB.DBFetch();
clan=DB.injectionClean(clan);
final ResultSet R=D.query("SELECT * FROM CMCHCL where CMCLAN='"+clan+"'");
if(R!=null) while(R.next())
{
members.add(BuildClanMemberRecord(R));
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return members;
}
public Clan.MemberRecord DBClanMember(String clan, String memberName)
{
Clan.MemberRecord member = null;
DBConnection D=null;
try
{
D=DB.DBFetch();
clan=DB.injectionClean(clan);
memberName=DB.injectionClean(CMStrings.capitalizeAndLower(memberName));
final ResultSet R=D.query("SELECT * FROM CMCHCL where CMCLAN='"+clan+"' AND CMUSERID='"+memberName+"'");
if(R!=null)
{
member = BuildClanMemberRecord(R);
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return member;
}
public void DBUpdateClanMembership(String name, String clan, final int role)
{
final MOB M=CMLib.players().getPlayer(name);
if(M!=null)
{
M.setClan(clan, role);
}
DBConnection D=null;
try
{
name=DB.injectionClean(name);
clan=DB.injectionClean(clan);
D=DB.DBFetch();
if(role<0)
{
DB.update("DELETE FROM CMCHCL WHERE CMUSERID='"+name+"' AND CMCLAN='"+clan+"'");
if(CMSecurity.isDebugging(CMSecurity.DbgFlag.CLANMEMBERS))
Log.debugOut("User '"+name+"' was deleted from clan '"+clan+"'");
}
else
{
final ResultSet R=D.query("SELECT * FROM CMCHCL where CMCLAN='"+clan+"' and CMUSERID='"+name+"'");
if((R!=null) && (R.next()))
{
final int clanRole = BuildClanMemberRole(R);
R.close();
if(clanRole == role)
return;
D.update("UPDATE CMCHCL SET CMCLRO="+role+" where CMCLAN='"+clan+"' and CMUSERID='"+name+"'", 0);
if(CMSecurity.isDebugging(CMSecurity.DbgFlag.CLANMEMBERS))
Log.debugOut("User '"+name+"' had role in clan '"+clan+"' changed from "+clanRole+" to "+role);
}
else
{
D.update("INSERT INTO CMCHCL (CMUSERID, CMCLAN, CMCLRO, CMCLSTS) values ('"+name+"','"+clan+"',"+role+",'0;0')",0);
if(CMSecurity.isDebugging(CMSecurity.DbgFlag.CLANMEMBERS))
Log.debugOut("User '"+name+"' was inserted into clan '"+clan+"' as role "+role);
}
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
}
public void DBUpdateClanKills(String clan, String name, final int adjMobKills, final int adjPlayerKills)
{
if(((adjMobKills==0)&&(adjPlayerKills==0))
||(clan==null)
||(name==null))
return;
name=DB.injectionClean(name);
clan=DB.injectionClean(clan);
DBConnection D=null;
try
{
D=DB.DBFetch();
final ResultSet R=D.query("SELECT * FROM CMCHCL where CMCLAN='"+clan+"' and CMUSERID='"+name+"'");
MemberRecord M=null;
if(R!=null)
{
if(R.next())
{
M=BuildClanMemberRecord(R);
R.close();
M.mobpvps+=adjMobKills;
M.playerpvps+=adjPlayerKills;
final String newStats=M.mobpvps+";"+M.playerpvps+";"+M.donatedGold+";"+M.donatedXP;
D.update("UPDATE CMCHCL SET CMCLSTS='"+newStats+"' where CMCLAN='"+clan+"' and CMUSERID='"+name+"'", 0);
}
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
}
public void DBUpdateClanDonates(String clan, String name, final double adjGold, final int adjXP)
{
if(((adjGold==0)&&(adjXP==0))
||(clan==null)
||(name==null))
return;
name=DB.injectionClean(name);
clan=DB.injectionClean(clan);
DBConnection D=null;
try
{
D=DB.DBFetch();
final ResultSet R=D.query("SELECT * FROM CMCHCL where CMCLAN='"+clan+"' and CMUSERID='"+name+"'");
MemberRecord M=null;
if(R!=null)
{
if(R.next())
{
M=BuildClanMemberRecord(R);
R.close();
M.donatedGold+=adjGold;
M.donatedXP+=adjXP;
final String newStats=M.mobpvps+";"+M.playerpvps+";"+M.donatedGold+";"+M.donatedXP+";"+M.joinDate;
D.update("UPDATE CMCHCL SET CMCLSTS='"+newStats+"' where CMCLAN='"+clan+"' and CMUSERID='"+name+"'", 0);
}
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
}
public void DBUpdate(final MOB mob)
{
final PlayerStats pStats = mob.playerStats();
if((pStats==null)||(!pStats.isSavable()))
return;
DBUpdateJustMOB(mob);
if(mob.Name().length()==0)
return;
DBUpdateItems(mob);
DBUpdateAbilities(mob);
pStats.setLastUpdated(System.currentTimeMillis());
final PlayerAccount account = pStats.getAccount();
if(account != null)
{
DBUpdateAccount(account);
account.setLastUpdated(System.currentTimeMillis());
}
}
public void DBUpdatePassword(String name, String password)
{
name=CMStrings.capitalizeAndLower(DB.injectionClean(name));
password=DB.injectionClean(password);
DB.update("UPDATE CMCHAR SET CMPASS='"+password+"' WHERE CMUSERID='"+name+"'");
}
private String getPlayerStatsXML(final MOB mob)
{
final PlayerStats pstats=mob.playerStats();
if(pstats==null)
return "";
final StringBuilder pfxml=new StringBuilder(pstats.getXML());
if(mob.tattoos().hasMoreElements())
{
pfxml.append("<TATTS>");
for(final Enumeration<Tattoo> e=mob.tattoos();e.hasMoreElements();)
pfxml.append(e.nextElement().toString()+";");
pfxml.append("</TATTS>");
}
if(mob.expertises().hasMoreElements())
{
pfxml.append("<EDUS>");
for(final Enumeration<String> x=mob.expertises();x.hasMoreElements();)
pfxml.append(x.nextElement()).append(';');
pfxml.append("</EDUS>");
}
pfxml.append(CMLib.xml().convertXMLtoTag("IMG",mob.rawImage()));
return pfxml.toString();
}
public void DBUpdateJustPlayerStats(final MOB mob)
{
if(mob.Name().length()==0)
{
DBCreateCharacter(mob);
return;
}
final PlayerStats pstats=mob.playerStats();
if((pstats==null)||(!pstats.isSavable()))
return;
final String pfxml=getPlayerStatsXML(mob);
final String name=DB.injectionClean(mob.Name());
DB.updateWithClobs("UPDATE CMCHAR SET CMPFIL=? WHERE CMUSERID='"+name+"'", pfxml.toString());
}
public void DBUpdateJustMOB(final MOB mob)
{
if(mob.Name().length()==0)
{
DBCreateCharacter(mob);
return;
}
final PlayerStats pstats=mob.playerStats();
if((pstats==null)||(!pstats.isSavable()))
return;
final String strStartRoomID=(mob.getStartRoom()!=null)?CMLib.map().getExtendedRoomID(mob.getStartRoom()):"";
String strOtherRoomID=(mob.location()!=null)?CMLib.map().getExtendedRoomID(mob.location()):"";
if((mob.location()!=null)
&&(mob.location().getArea()!=null)
&&(CMath.bset(mob.location().getArea().flags(),Area.FLAG_INSTANCE_PARENT)
||CMath.bset(mob.location().getArea().flags(),Area.FLAG_INSTANCE_CHILD)))
strOtherRoomID=strStartRoomID;
final String playerStatsXML=getPlayerStatsXML(mob);
final String factionDataXML=CMLib.coffeeMaker().getFactionXML(mob).toString();
DB.updateWithClobs(
"UPDATE CMCHAR SET CMPASS='"+pstats.getPasswordStr()+"'"
+", CMCHID='"+mob.ID()+"'"
+", CMCLAS='"+mob.baseCharStats().getMyClassesStr()+"'"
+", CMSTRE="+mob.baseCharStats().getStat(CharStats.STAT_STRENGTH)
+", CMRACE='"+mob.baseCharStats().getMyRace().ID()+"'"
+", CMDEXT="+mob.baseCharStats().getStat(CharStats.STAT_DEXTERITY)
+", CMCONS="+mob.baseCharStats().getStat(CharStats.STAT_CONSTITUTION)
+", CMGEND='"+((char)mob.baseCharStats().getStat(CharStats.STAT_GENDER))+"'"
+", CMWISD="+mob.baseCharStats().getStat(CharStats.STAT_WISDOM)
+", CMINTE="+mob.baseCharStats().getStat(CharStats.STAT_INTELLIGENCE)
+", CMCHAR="+mob.baseCharStats().getStat(CharStats.STAT_CHARISMA)
+", CMHITP="+mob.baseState().getHitPoints()
+", CMLEVL='"+mob.baseCharStats().getMyLevelsStr()+"'"
+", CMMANA="+mob.baseState().getMana()
+", CMMOVE="+mob.baseState().getMovement()
+", CMALIG=-1"
+", CMEXPE="+mob.getExperience()
+", CMEXLV="+mob.getExpNextLevel()
+", CMWORS='"+mob.getWorshipCharID()+"'"
+", CMPRAC="+mob.getPractices()
+", CMTRAI="+mob.getTrains()
+", CMAGEH="+mob.getAgeMinutes()
+", CMGOLD="+mob.getMoney()
+", CMWIMP="+mob.getWimpHitPoint()
+", CMQUES="+mob.getQuestPoint()
+", CMROID='"+strStartRoomID+"||"+strOtherRoomID+"'"
+", CMDATE='"+pstats.getLastDateTime()+"'"
+", CMCHAN="+pstats.getChannelMask()
+", CMATTA="+mob.basePhyStats().attackAdjustment()
+", CMAMOR="+mob.basePhyStats().armor()
+", CMDAMG="+mob.basePhyStats().damage()
+", CMBTMP="+mob.getAttributesBitmap()
+", CMLEIG='"+mob.getLiegeID()+"'"
+", CMHEIT="+mob.basePhyStats().height()
+", CMWEIT="+mob.basePhyStats().weight()
+", CMPRPT=?"
+", CMCOLR=?"
+", CMLSIP='"+pstats.getLastIP()+"'"
+", CMEMAL=?"
+", CMPFIL=?"
+", CMSAVE=?"
+", CMMXML=?"
+", CMDESC=?"
+" WHERE CMUSERID='"+mob.Name()+"'"
,new String[][]{{
pstats.getPrompt(),
pstats.getColorStr(),
pstats.getEmail(),
playerStatsXML,
mob.baseCharStats().getNonBaseStatsAsString(),
factionDataXML,
mob.description()+" "
}}
);
final List<String> clanStatements=new LinkedList<String>();
DBConnection D=null;
try
{
D=DB.DBFetch();
final ResultSet R=D.query("SELECT * FROM CMCHCL WHERE CMUSERID='"+mob.Name()+"'");
final Set<String> savedClans=new HashSet<String>();
if(R!=null)
{
while(R.next())
{
final String clanID=DB.getRes(R,"CMCLAN");
final Pair<Clan,Integer> role=mob.getClanRole(clanID);
if(role==null)
{
clanStatements.add("DELETE FROM CMCHCL WHERE CMUSERID='"+mob.Name()+"' AND CMCLAN='"+clanID+"'");
if(CMSecurity.isDebugging(CMSecurity.DbgFlag.CLANMEMBERS))
Log.debugOut("User '"+mob.Name()+"' was deleted from clan '"+clanID+"'");
}
else
{
final MemberRecord M=BuildClanMemberRecord(R);
if(role.second.intValue()!=M.role)
{
clanStatements.add("UPDATE CMCHCL SET CMCLRO="+role.second.intValue()+" where CMCLAN='"+clanID+"' and CMUSERID='"+mob.Name()+"'");
if(CMSecurity.isDebugging(CMSecurity.DbgFlag.CLANMEMBERS))
Log.debugOut("User '"+mob.Name()+"' had role in clan '"+clanID+"' changed from "+M.role+" to role "+role.second.intValue());
}
}
savedClans.add(clanID.toUpperCase());
}
R.close();
}
for(final Pair<Clan,Integer> p : mob.clans())
{
if(!savedClans.contains(p.first.clanID().toUpperCase()))
{
clanStatements.add("INSERT INTO CMCHCL (CMUSERID, CMCLAN, CMCLRO, CMCLSTS) values ('"+mob.Name()+"','"+p.first.clanID()+"',"+p.second.intValue()+",'0;0')");
if(CMSecurity.isDebugging(CMSecurity.DbgFlag.CLANMEMBERS))
Log.debugOut("User '"+mob.Name()+"' was added to clan '"+p.first.clanID()+"' as role "+p.second.intValue());
}
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
if(clanStatements.size()>0)
DB.update(clanStatements.toArray(new String[0]));
}
protected String getShortID(final Environmental E)
{
final String classID = ""+E;
final int x=classID.indexOf('@');
if(x<0)
return E.ID()+"@"+classID.hashCode()+Math.random();
else
return E.ID()+classID.substring(0, x).hashCode()+classID.substring(x);
}
protected String getDBItemUpdateString(final MOB mob, final Item thisItem)
{
CMLib.catalog().updateCatalogIntegrity(thisItem);
final String container=((thisItem.container()!=null)?(""+getShortID(thisItem.container())):"");
final String name=DB.injectionClean(mob.Name());
final String itemID=getShortID(thisItem);
return "INSERT INTO CMCHIT (CMUSERID, CMITNM, CMITID, CMITTX, CMITLO, CMITWO, "
+"CMITUR, CMITLV, CMITAB, CMHEIT"
+") values ('"+name+"','"+(itemID)+"','"+thisItem.ID()+"',?,'"+container+"',"+thisItem.rawWornCode()+","
+thisItem.usesRemaining()+","+thisItem.basePhyStats().level()+","+thisItem.basePhyStats().ability()+","
+thisItem.basePhyStats().height()+")";
}
protected DBPreparedBatchEntry doBulkInsert(final StringBuilder str, final List<String> clobs, final String sql, final String clob)
{
if(str.length()==0)
{
str.append(sql);
clobs.add(clob+" ");
}
else
if(str.length()<512000)
{
final int x=sql.indexOf(" values ");
str.append(", ").append(sql.substring(x+7));
clobs.add(clob+" ");
}
else
{
final DBPreparedBatchEntry entry = new DBPreparedBatchEntry(str.toString(),clobs.toArray(new String[0]));
str.setLength(0);
return entry;
}
return null;
}
private List<DBPreparedBatchEntry> getDBItemUpdateStrings(final MOB mob)
{
final HashSet<Item> done=new HashSet<Item>();
final List<DBPreparedBatchEntry> strings=new LinkedList<DBPreparedBatchEntry>();
final StringBuilder bulkSQL=new StringBuilder("");
final List<String> bulkClobs=new ArrayList<String>();
final boolean useBulkInserts = DB.useBulkInserts();
for(int i=0;i<mob.numItems();i++)
{
final Item thisItem=mob.getItem(i);
if((thisItem!=null)
&&(!done.contains(thisItem))
&&(thisItem.isSavable()))
{
CMLib.catalog().updateCatalogIntegrity(thisItem);
final String sql=getDBItemUpdateString(mob,thisItem);
if(!useBulkInserts)
strings.add(new DBPreparedBatchEntry(sql,thisItem.text()+" "));
else
{
final DBPreparedBatchEntry entry = doBulkInsert(bulkSQL,bulkClobs,sql,thisItem.text()+" ");
if(entry != null)
strings.add(entry);
}
done.add(thisItem);
}
}
final PlayerStats pStats=mob.playerStats();
if(pStats !=null)
{
final ItemCollection coll=pStats.getExtItems();
final List<Item> finalCollection=new LinkedList<Item>();
final List<Item> extraItems=new LinkedList<Item>();
for(int i=coll.numItems()-1;i>=0;i--)
{
final Item thisItem=coll.getItem(i);
if(thisItem!=null)
{
if(!thisItem.amDestroyed())
{
final Item cont=thisItem.ultimateContainer(null);
if(cont.owner() instanceof Room)
finalCollection.add(thisItem);
else
if((thisItem instanceof SpaceObject)
&&(CMLib.map().isObjectInSpace((SpaceObject)thisItem)))
finalCollection.add(thisItem);
}
}
}
for(int i=finalCollection.size()-1;i>=0;i--)
{
final Item thisItem = finalCollection.get(i);
if(thisItem instanceof Container)
{
final List<Item> contents=((Container)thisItem).getDeepContents();
if(thisItem instanceof DeadBody)
{
if((contents.size()==0)
&&(thisItem.container()==null)
&&(((DeadBody)thisItem).getMobName().equalsIgnoreCase(mob.Name())))
{
finalCollection.remove(i);
continue;
}
}
for(final Item I : contents)
{
if(!finalCollection.contains(I))
extraItems.add(I);
}
}
}
finalCollection.addAll(extraItems);
for(final Item thisItem : finalCollection)
{
if(!done.contains(thisItem))
{
CMLib.catalog().updateCatalogIntegrity(thisItem);
final Item cont=thisItem.ultimateContainer(null);
final String sql=getDBItemUpdateString(mob,thisItem);
final String roomID;
if((cont.owner()==null)
&&(thisItem instanceof SpaceObject)
&&(CMLib.map().isObjectInSpace((SpaceObject)thisItem)))
roomID="SPACE."+CMParms.toListString(((SpaceObject)thisItem).coordinates());
else
if(cont.owner() instanceof Room)
roomID=CMLib.map().getApproximateExtendedRoomID((Room)cont.owner());
else
if((thisItem instanceof SpaceObject)
&&(CMLib.map().isObjectInSpace((SpaceObject)thisItem)))
roomID="SPACE."+CMParms.toListString(((SpaceObject)thisItem).coordinates());
else
roomID="";
final String text="<ROOM ID=\""+roomID+"\" EXPIRE="+thisItem.expirationDate()+" />"+thisItem.text();
if(!useBulkInserts)
strings.add(new DBPreparedBatchEntry(sql,text+" "));
else
{
final DBPreparedBatchEntry entry = doBulkInsert(bulkSQL,bulkClobs,sql,text+" ");
if(entry != null)
strings.add(entry);
}
done.add(thisItem);
}
}
}
if((bulkSQL.length()>0) && useBulkInserts)
strings.add(new DBPreparedBatchEntry(bulkSQL.toString(),bulkClobs.toArray(new String[0])));
return strings;
}
public void DBUpdateItems(final MOB mob)
{
if(mob.Name().length()==0)
return;
final List<DBPreparedBatchEntry> statements=new LinkedList<DBPreparedBatchEntry>();
final String name=DB.injectionClean(mob.Name());
statements.add(new DBPreparedBatchEntry("DELETE FROM CMCHIT WHERE CMUSERID='"+name+"'"));
statements.addAll(getDBItemUpdateStrings(mob));
DB.updateWithClobs(statements);
}
protected List<Pair<String,Integer>>[][] DBFindPrideWinners(final int topThisMany, final short scanCPUPercent, final boolean players)
{
@SuppressWarnings("unchecked")
final List<Pair<String,Integer>>[][] top=new Vector[TimeClock.TimePeriod.values().length][AccountStats.PrideStat.values().length];
for(int x=0;x<top.length;x++)
{
for(int y=0;y<top[x].length;y++)
top[x][y]=new Vector<Pair<String,Integer>>(topThisMany+1);
}
DBConnection D=null;
final long msWait=Math.round(1000.0 * CMath.div(scanCPUPercent, 100));
final long sleepAmount=1000 - msWait;
try
{
long nextWaitAfter=System.currentTimeMillis() + msWait;
final long now=System.currentTimeMillis();
D=DB.DBFetch();
ResultSet R;
if(players)
R=D.query("SELECT CMUSERID,CMPFIL FROM CMCHAR");
else
R=D.query("SELECT CMANAM,CMAXML FROM CMACCT");
while((R!=null)&&(R.next()))
{
final String userID=DB.getRes(R, players?"CMUSERID":"CMANAM");
String pxml;
final MOB M=CMLib.players().getPlayer(userID);
if((M!=null)&&(M.playerStats()!=null)&&(players))
pxml=M.playerStats().getXML();
else
if((M!=null)&&(M.playerStats()!=null)&&(!players)&&(M.playerStats().getAccount()!=null))
pxml=M.playerStats().getAccount().getXML();
else
if(players)
pxml=DB.getRes(R, "CMPFIL");
else
pxml=DB.getRes(R, "CMAXML");
final String[] pridePeriods=CMLib.xml().returnXMLValue(pxml, "NEXTPRIDEPERIODS").split(",");
final String[] prideStats=CMLib.xml().returnXMLValue(pxml, "PRIDESTATS").split(";");
final String[] prideExceptions=CMLib.xml().returnXMLValue(pxml, "FLAGS").split(",");
if(CMParms.contains(prideExceptions, PlayerFlag.NOSTATS.toString())
||CMParms.contains(prideExceptions, PlayerFlag.NOTOP.toString()))
continue;
final Pair<Long,int[]>[] allData = CMLib.players().parsePrideStats(pridePeriods, prideStats);
for(final TimeClock.TimePeriod period : TimeClock.TimePeriod.values())
{
if(allData.length > period.ordinal())
{
final Pair<Long,int[]> p=allData[period.ordinal()];
final List<Pair<String,Integer>>[] topPeriods=top[period.ordinal()];
if((period==TimeClock.TimePeriod.ALLTIME)||(now < p.first.longValue()))
{
for(final AccountStats.PrideStat pride : AccountStats.PrideStat.values())
{
if((p.second.length>pride.ordinal())&&(p.second[pride.ordinal()]>0))
{
final int val=p.second[pride.ordinal()];
final List<Pair<String,Integer>> topPrides=topPeriods[pride.ordinal()];
final int oldSize=topPrides.size();
for(int i=0;i<topPrides.size();i++)
{
if(val >= topPrides.get(i).second.intValue())
{
topPrides.add(i, new Pair<String,Integer>(userID,Integer.valueOf(val)));
while(topPrides.size()>topThisMany)
topPrides.remove(topPrides.size()-1);
break;
}
}
if((oldSize==topPrides.size())&&(topPrides.size()<topThisMany))
topPrides.add(new Pair<String,Integer>(userID,Integer.valueOf(val)));
}
}
}
}
}
if((sleepAmount>0)&&(System.currentTimeMillis() > nextWaitAfter))
{
CMLib.s_sleep(sleepAmount);
nextWaitAfter=System.currentTimeMillis() + msWait;
}
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return top;
}
public List<Pair<String,Integer>>[][] DBScanPridePlayerWinners(final int topThisMany, final short scanCPUPercent)
{
return DBFindPrideWinners(topThisMany,scanCPUPercent,true);
}
public List<Pair<String,Integer>>[][] DBScanPrideAccountWinners(final int topThisMany, final short scanCPUPercent)
{
return DBFindPrideWinners(topThisMany,scanCPUPercent,false);
}
// this method is unused, but is a good idea of how to collect riders, followers, carts, etc.
protected void addFollowerDependent(final PhysicalAgent P, final PairList<PhysicalAgent,String> list, final String parent)
{
if(P==null)
return;
if(list.containsFirst(P))
return;
if((P instanceof MOB)
&&((!((MOB)P).isMonster())||(((MOB)P).isPossessing())))
return;
CMLib.catalog().updateCatalogIntegrity(P);
final String myCode=""+(list.size()-1);
list.add(P,CMClass.classID(P)+"#"+myCode+parent);
if(P instanceof Rideable)
{
final Rideable R=(Rideable)P;
for(int r=0;r<R.numRiders();r++)
addFollowerDependent(R.fetchRider(r),list,"@"+myCode+"R");
}
if(P instanceof Container)
{
final Container C=(Container)P;
final List<Item> contents=C.getDeepContents();
for(int c=0;c<contents.size();c++)
addFollowerDependent(contents.get(c),list,"@"+myCode+"C");
}
}
public void DBUpdateFollowers(final MOB mob)
{
if((mob==null)||(mob.Name().length()==0))
return;
final List<DBPreparedBatchEntry> statements=new LinkedList<DBPreparedBatchEntry>();
final String name=DB.injectionClean(mob.Name());
statements.add(new DBPreparedBatchEntry("DELETE FROM CMCHFO WHERE CMUSERID='"+name+"'"));
if(mob.numFollowers()==0)
{
DB.updateWithClobs(statements);
return;
}
final boolean useBulkInserts = DB.useBulkInserts();
final StringBuilder bulkSQL = new StringBuilder("");
final List<String> bulkClobs = new ArrayList<String>();
// make a list of the valid savable followers
final List<MOB> followers=new ArrayList<MOB>(mob.numFollowers());
for(int f=0;f<mob.numFollowers();f++)
{
final MOB followM=mob.fetchFollower(f);
if((followM!=null)
&&(followM.isMonster())
&&(!followM.isPossessing()))
{
if(CMLib.flags().isSavable(followM))
followers.add(followM);
else
{
// check if the room's to blame
final Room R=followM.location();
if((R!=null)
&&(!CMLib.flags().isSavable(R))
&&(!CMLib.flags().isSavable(R.getArea())))
followers.add(followM);
}
}
}
for(int f=0;f<followers.size();f++)
{
MOB followM = followers.get(f);
// prevent rejuving map mobs from getting text() called and wiping
// out their original specs
if((followM.basePhyStats().rejuv()>0)
&&(followM.basePhyStats().rejuv()!=PhyStats.NO_REJUV))
{
final Room loc=followM.location();
final Integer order = Integer.valueOf(mob.fetchFollowerOrder(followM));
followM.setFollowing(null);
mob.delFollower(followM);
final MOB newFol = (MOB) followM.copyOf();
newFol.basePhyStats().setRejuv(PhyStats.NO_REJUV);
newFol.phyStats().setRejuv(PhyStats.NO_REJUV);
newFol.text();
followM.killMeDead(false);
mob.addFollower(newFol, order.intValue());
if(CMLib.flags().isInTheGame(mob, true)
&&(!CMLib.flags().isInTheGame(newFol, true))
&&(loc!=null))
newFol.bringToLife(loc, false);
followM=newFol;
}
CMLib.catalog().updateCatalogIntegrity(followM);
final String sql="INSERT INTO CMCHFO (CMUSERID, CMFONM, CMFOID, CMFOTX, CMFOLV, CMFOAB"
+") values ('"+name+"',"+f+",'"+CMClass.classID(followM)+"',?,"
+followM.basePhyStats().level()+","+followM.basePhyStats().ability()+")";
if(!useBulkInserts)
statements.add(new DBPreparedBatchEntry(sql,followM.text()+" "));
else
{
final DBPreparedBatchEntry entry = doBulkInsert(bulkSQL,bulkClobs,sql,followM.text()+" ");
if(entry != null)
statements.add(entry);
}
}
if((bulkSQL.length()>0) && useBulkInserts)
statements.add(new DBPreparedBatchEntry(bulkSQL.toString(),bulkClobs.toArray(new String[0])));
DB.updateWithClobs(statements);
}
public void DBNameChange(String oldName, String newName)
{
if((oldName==null)
||(oldName.trim().length()==0)
||(newName==null)
||(newName.trim().length()==0))
return;
oldName=DB.injectionClean(oldName);
newName=DB.injectionClean(newName);
DB.update("UPDATE CMCHAB SET CMUSERID='"+newName+"' WHERE CMUSERID='"+oldName+"'");
DB.update("UPDATE CMCHAR SET CMUSERID='"+newName+"' WHERE CMUSERID='"+oldName+"'");
DB.update("UPDATE CMCHAR SET CMWORS='"+newName+"' WHERE CMWORS='"+oldName+"'");
DB.update("UPDATE CMCHAR SET CMLEIG='"+newName+"' WHERE CMLEIG='"+oldName+"'");
DB.update("UPDATE CMCHCL SET CMUSERID='"+newName+"' WHERE CMUSERID='"+oldName+"'");
DB.update("UPDATE CMCHFO SET CMUSERID='"+newName+"' WHERE CMUSERID='"+oldName+"'");
DB.update("UPDATE CMCHIT SET CMUSERID='"+newName+"' WHERE CMUSERID='"+oldName+"'");
DB.update("UPDATE CMJRNL SET CMFROM='"+newName+"' WHERE CMFROM='"+oldName+"'");
DB.update("UPDATE CMJRNL SET CMTONM='"+newName+"' WHERE CMTONM='"+oldName+"'");
DB.update("UPDATE CMPDAT SET CMPLID='"+newName+"' WHERE CMPLID='"+oldName+"'");
}
public void DBDeleteCharOnly(String mobName)
{
mobName=DB.injectionClean(mobName);
DB.update("DELETE FROM CMCHAR WHERE CMUSERID='"+mobName+"'");
DB.update("DELETE FROM CMCHCL WHERE CMUSERID='"+mobName+"'");
}
public void DBUpdateAbilities(final MOB mob)
{
if(mob.Name().length()==0)
return;
final List<DBPreparedBatchEntry> statements=new LinkedList<DBPreparedBatchEntry>();
statements.add(new DBPreparedBatchEntry("DELETE FROM CMCHAB WHERE CMUSERID='"+mob.Name()+"'"));
final HashSet<String> H=new HashSet<String>();
final boolean useBulkInserts = DB.useBulkInserts();
final StringBuilder bulkSQL = new StringBuilder("");
final List<String> bulkClobs = new ArrayList<String>();
for(int a=0;a<mob.numAbilities();a++)
{
final Ability thisAbility=mob.fetchAbility(a);
if((thisAbility!=null)&&(thisAbility.isSavable()))
{
int proficiency=thisAbility.proficiency();
final Ability effectA=mob.fetchEffect(thisAbility.ID());
if(effectA!=null)
{
if((effectA.isSavable())&&(!effectA.canBeUninvoked())&&(!effectA.isAutoInvoked()))
proficiency=proficiency-200;
}
H.add(thisAbility.ID());
final String sql="INSERT INTO CMCHAB (CMUSERID, CMABID, CMABPF,CMABTX"
+") values ('"+mob.Name()+"','"+thisAbility.ID()+"',"+proficiency+",?)";
if(!useBulkInserts)
statements.add(new DBPreparedBatchEntry(sql,thisAbility.text()));
else
{
final DBPreparedBatchEntry entry = doBulkInsert(bulkSQL,bulkClobs,sql,thisAbility.text());
if(entry != null)
statements.add(entry);
}
}
}
for(final Enumeration<Ability> a=mob.personalEffects();a.hasMoreElements();)
{
final Ability A=a.nextElement();
if((A!=null)&&(!H.contains(A.ID()))&&(A.isSavable())&&(!A.canBeUninvoked()))
{
final String sql="INSERT INTO CMCHAB (CMUSERID, CMABID, CMABPF,CMABTX"
+") values ('"+mob.Name()+"','"+A.ID()+"',"+Integer.MAX_VALUE+",?)";
if(!useBulkInserts)
statements.add(new DBPreparedBatchEntry(sql,A.text()));
else
{
final DBPreparedBatchEntry entry = doBulkInsert(bulkSQL,bulkClobs,sql,A.text());
if(entry != null)
statements.add(entry);
}
}
}
for(final Enumeration<Behavior> e=mob.behaviors();e.hasMoreElements();)
{
final Behavior B=e.nextElement();
if((B!=null)&&(B.isSavable()))
{
final String sql="INSERT INTO CMCHAB (CMUSERID, CMABID, CMABPF,CMABTX"
+") values ('"+mob.Name()+"','"+B.ID()+"',"+(Integer.MIN_VALUE+1)+",?"
+")";
if(!useBulkInserts)
statements.add(new DBPreparedBatchEntry(sql,B.getParms()));
else
{
final DBPreparedBatchEntry entry = doBulkInsert(bulkSQL,bulkClobs,sql,B.getParms());
if(entry != null)
statements.add(entry);
}
}
}
final String scriptStuff = CMLib.coffeeMaker().getGenScripts(mob,true);
if(scriptStuff.length()>0)
{
final String sql="INSERT INTO CMCHAB (CMUSERID, CMABID, CMABPF,CMABTX"
+") values ('"+mob.Name()+"','ScriptingEngine',"+(Integer.MIN_VALUE+1)+",?"
+")";
if(!useBulkInserts)
statements.add(new DBPreparedBatchEntry(sql,scriptStuff));
else
{
final DBPreparedBatchEntry entry = doBulkInsert(bulkSQL,bulkClobs,sql,scriptStuff);
if(entry != null)
statements.add(entry);
}
}
if((bulkSQL.length()>0) && useBulkInserts)
statements.add(new DBPreparedBatchEntry(bulkSQL.toString(),bulkClobs.toArray(new String[0])));
DB.updateWithClobs(statements);
}
public void DBCreateCharacter(final MOB mob)
{
if(mob.Name().length()==0)
return;
final PlayerStats pstats=mob.playerStats();
if(pstats==null)
return;
DB.update("INSERT INTO CMCHAR (CMCHID, CMUSERID, CMPASS, CMCLAS, CMRACE, CMGEND "
+") VALUES ('"+mob.ID()+"','"+mob.Name()+"','"+pstats.getPasswordStr()+"','"+mob.baseCharStats().getMyClassesStr()
+"','"+mob.baseCharStats().getMyRace().ID()+"','"+((char)mob.baseCharStats().getStat(CharStats.STAT_GENDER))
+"')");
final PlayerAccount account = pstats.getAccount();
if(account != null)
{
account.addNewPlayer(mob);
DBUpdateAccount(account);
account.setLastUpdated(System.currentTimeMillis());
}
}
public void DBUpdateAccount(final PlayerAccount account)
{
if(account == null)
return;
final String characters = CMParms.toSemicolonListString(account.getPlayers());
DB.updateWithClobs("UPDATE CMACCT SET CMPASS='"+account.getPasswordStr()+"', CMCHRS=?, CMAXML=? WHERE CMANAM='"+account.getAccountName()+"'",
new String[][]{{characters,account.getXML()}});
}
public void DBDeleteAccount(final PlayerAccount account)
{
if(account == null)
return;
final String login=DB.injectionClean(account.getAccountName());
DB.update("DELETE FROM CMACCT WHERE CMANAM='"+login+"'");
}
public void DBCreateAccount(final PlayerAccount account)
{
if(account == null)
return;
account.setAccountName(CMStrings.capitalizeAndLower(account.getAccountName()));
final String characters = CMParms.toSemicolonListString(account.getPlayers());
final String login=DB.injectionClean(account.getAccountName());
DB.updateWithClobs("INSERT INTO CMACCT (CMANAM, CMPASS, CMCHRS, CMAXML) "
+"VALUES ('"+login+"','"+account.getPasswordStr()+"',?,?)",new String[][]{{characters,account.getXML()}});
}
public PlayerAccount MakeAccount(final String username, final ResultSet R) throws SQLException
{
PlayerAccount account = null;
account = (PlayerAccount)CMClass.getCommon("DefaultPlayerAccount");
final String password=DB.getRes(R,"CMPASS");
final String chrs=DB.getRes(R,"CMCHRS");
final String xml=DB.getRes(R,"CMAXML");
final Vector<String> names = new Vector<String>();
if(chrs!=null)
names.addAll(CMParms.parseSemicolons(chrs,true));
account.setAccountName(CMStrings.capitalizeAndLower(username));
account.setPassword(password);
account.setPlayerNames(names);
account.setXML(xml);
return account;
}
public PlayerAccount DBReadAccount(String login)
{
DBConnection D=null;
PlayerAccount account = null;
try
{
// why in the hell is this a memory scan?
// case insensitivity from databases configured almost
// certainly by amateurs is the answer. That, and fakedb
// doesn't understand 'LIKE'
D=DB.DBFetch();
login=CMStrings.capitalizeAndLower(DB.injectionClean(login));
final ResultSet R=D.query("SELECT * FROM CMACCT WHERE CMANAM='"+login+"'");
if(R!=null) while(R.next())
{
final String username=DB.getRes(R,"CMANAM");
if(login.equalsIgnoreCase(username))
account = MakeAccount(username,R);
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return account;
}
public List<PlayerAccount> DBListAccounts(String mask)
{
DBConnection D=null;
PlayerAccount account = null;
final Vector<PlayerAccount> accounts = new Vector<PlayerAccount>();
if(mask!=null)
mask=mask.toLowerCase();
try
{
// why in the hell is this a memory scan?
// case insensitivity from databases configured almost
// certainly by amateurs is the answer. That, and fakedb
// doesn't understand 'LIKE'
D=DB.DBFetch();
final ResultSet R=D.query("SELECT * FROM CMACCT");
if(R!=null) while(R.next())
{
final String username=DB.getRes(R,"CMANAM");
if((mask==null)||(mask.length()==0)||(username.toLowerCase().indexOf(mask)>=0))
{
account = MakeAccount(username,R);
accounts.add(account);
}
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return accounts;
}
public List<String> DBExpiredCharNameSearch(final Set<String> skipNames)
{
DBConnection D=null;
String buf=null;
final List<String> expiredPlayers = new ArrayList<String>();
final long now=System.currentTimeMillis();
try
{
D=DB.DBFetch();
final ResultSet R=D.query("SELECT * FROM CMCHAR");
if(R!=null) while(R.next())
{
final String username=DB.getRes(R,"CMUSERID");
if((skipNames!=null)&&(skipNames.contains(username)))
continue;
buf=DBConnections.getRes(R,"CMPFIL");
final String secGrps=CMLib.xml().restoreAngleBrackets(CMLib.xml().returnXMLValue(buf,"SECGRPS"));
final SecGroup g=CMSecurity.instance().createGroup("", CMParms.parseSemicolons(secGrps,true));
if(g.contains(SecFlag.NOEXPIRE, false))
continue;
long expiration;
if(CMLib.xml().returnXMLValue(buf,"ACCTEXP").length()>0)
expiration=CMath.s_long(CMLib.xml().returnXMLValue(buf,"ACCTEXP"));
else
{
final Calendar C=Calendar.getInstance();
C.add(Calendar.DATE,CMProps.getIntVar(CMProps.Int.TRIALDAYS));
expiration=C.getTimeInMillis();
}
if(now>=expiration)
expiredPlayers.add(username);
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return expiredPlayers;
}
public PlayerLibrary.ThinnerPlayer DBUserSearch(String login)
{
DBConnection D=null;
String buf=null;
PlayerLibrary.ThinnerPlayer thinPlayer = null;
try
{
// why in the hell is this a memory scan?
// case insensitivity from databases configured almost
// certainly by amateurs is the answer. That, and fakedb
// doesn't understand 'LIKE'
D=DB.DBFetch();
login=CMStrings.capitalizeAndLower(DB.injectionClean(login));
final ResultSet R=D.query("SELECT * FROM CMCHAR WHERE CMUSERID='"+login+"'");
if(R!=null) while(R.next())
{
final String username=DB.getRes(R,"CMUSERID");
thinPlayer = new PlayerLibrary.ThinnerPlayer();
final String password=DB.getRes(R,"CMPASS");
final String email=DB.getRes(R,"CMEMAL");
thinPlayer.name=username;
thinPlayer.password=password;
thinPlayer.email=email;
// Acct Exp Code
buf=DBConnections.getRes(R,"CMPFIL");
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
if((buf!=null)&&(thinPlayer!=null))
{
PlayerAccount acct = null;
thinPlayer.accountName = CMLib.xml().returnXMLValue(buf,"ACCOUNT");
if((thinPlayer.accountName!=null)&&(thinPlayer.accountName.length()>0))
acct = CMLib.players().getLoadAccount(thinPlayer.accountName);
if((acct != null)&&(CMProps.isUsingAccountSystem()))
thinPlayer.expiration=acct.getAccountExpiration();
else
if(CMLib.xml().returnXMLValue(buf,"ACCTEXP").length()>0)
thinPlayer.expiration=CMath.s_long(CMLib.xml().returnXMLValue(buf,"ACCTEXP"));
else
{
final Calendar C=Calendar.getInstance();
C.add(Calendar.DATE,CMProps.getIntVar(CMProps.Int.TRIALDAYS));
thinPlayer.expiration=C.getTimeInMillis();
}
}
return thinPlayer;
}
public Pair<String, Boolean> DBFetchEmailData(String name)
{
for(final Enumeration<MOB> e=CMLib.players().players();e.hasMoreElements();)
{
final MOB M=e.nextElement();
if((M.Name().equalsIgnoreCase(name))&&(M.playerStats()!=null))
{
final boolean canReceiveRealEmail =
(M.playerStats()!=null)
&&(M.isAttributeSet(MOB.Attrib.AUTOFORWARD))
&&((M.playerStats().getAccount()==null)
||(!M.playerStats().getAccount().isSet(AccountFlag.NOAUTOFORWARD)));
return new Pair<String,Boolean>(M.playerStats().getEmail(),Boolean.valueOf(canReceiveRealEmail));
}
}
DBConnection D=null;
try
{
D=DB.DBFetch();
name=DB.injectionClean(name);
final ResultSet R=D.query("SELECT * FROM CMCHAR WHERE CMUSERID='"+name+"'");
if(R!=null) while(R.next())
{
// String username=DB.getRes(R,"CMUSERID");
final int btmp=CMath.s_int(DB.getRes(R,"CMBTMP"));
final String temail=DB.getRes(R,"CMEMAL");
return new Pair<String,Boolean>(temail,Boolean.valueOf((btmp&MOB.Attrib.AUTOFORWARD.getBitCode())!=0));
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return null;
}
public String DBPlayerEmailSearch(String email)
{
DBConnection D=null;
for(final Enumeration<MOB> e=CMLib.players().players();e.hasMoreElements();)
{
final MOB M=e.nextElement();
if((M.playerStats()!=null)&&(M.playerStats().getEmail().equalsIgnoreCase(email)))
return M.Name();
}
try
{
D=DB.DBFetch();
email=DB.injectionClean(email.trim());
ResultSet R=D.query("SELECT * FROM CMCHAR WHERE CMEMAL='"+email+"'");
if(((R==null)||(!R.next()))&&(!CMStrings.isLowerCase(email)))
R=D.query("SELECT * FROM CMCHAR WHERE CMEMAL='"+email.toLowerCase()+"'");
if((R==null)||(!R.next()))
R=D.query("SELECT * FROM CMCHAR WHERE CMEMAL LIKE '"+email+"'");
if((R==null)||(!R.next()))
R=D.query("SELECT * FROM CMCHAR");
if(R!=null)
{
while(R.next())
{
final String username=DB.getRes(R,"CMUSERID");
final String temail=DB.getRes(R,"CMEMAL");
if(temail.equalsIgnoreCase(email))
{
return username;
}
}
}
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return null;
}
public PlayerStats DBLoadPlayerStats(String name)
{
if((name==null)||(name.length()==0))
return null;
name=CMStrings.capitalizeAndLower(DB.injectionClean(name));
DBConnection D=null;
PlayerStats pStats = null;
// now grab the items
try
{
D=DB.DBFetch();
final ResultSet R=D.query("SELECT CMDATE, CMCHAN, CMPRPT, CMCOLR, CMLSIP, CMPFIL FROM CMCHAR WHERE CMUSERID='"+name+"'");
if(R.next())
{
pStats = (PlayerStats)CMClass.getCommon("DefaultPlayerStats");
pStats.setLastDateTime(CMath.s_long(DBConnections.getRes(R,"CMDATE")));
pStats.setChannelMask((int)DBConnections.getLongRes(R,"CMCHAN"));
pStats.setPrompt(DBConnections.getRes(R,"CMPRPT"));
final String colorStr=DBConnections.getRes(R,"CMCOLR");
if((colorStr!=null)&&(colorStr.length()>0)&&(!colorStr.equalsIgnoreCase("NULL")))
pStats.setColorStr(colorStr);
pStats.setLastIP(DBConnections.getRes(R,"CMLSIP"));
final String buf=DBConnections.getRes(R,"CMPFIL");
pStats.setXML(buf);
}
R.close();
}
catch(final Exception sqle)
{
Log.errOut("MOB",sqle);
}
finally
{
DB.DBDone(D);
}
return pStats;
}
}
