Fafurion branch.
This commit is contained in:
@ -0,0 +1,259 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.accountmanager;
|
||||
|
||||
import java.security.MessageDigest;
|
||||
import java.sql.Connection;
|
||||
import java.sql.PreparedStatement;
|
||||
import java.sql.ResultSet;
|
||||
import java.sql.SQLException;
|
||||
import java.util.Base64;
|
||||
import java.util.Scanner;
|
||||
|
||||
import com.l2jmobius.Config;
|
||||
import com.l2jmobius.Server;
|
||||
import com.l2jmobius.commons.database.DatabaseFactory;
|
||||
|
||||
/**
|
||||
* This class SQL Account Manager
|
||||
* @author netimperia
|
||||
*/
|
||||
public class SQLAccountManager
|
||||
{
|
||||
private static String _uname = "";
|
||||
private static String _pass = "";
|
||||
private static String _level = "";
|
||||
private static String _mode = "";
|
||||
|
||||
public static void main(String[] args)
|
||||
{
|
||||
Server.serverMode = Server.MODE_LOGINSERVER;
|
||||
Config.load();
|
||||
DatabaseFactory.init();
|
||||
|
||||
try (Scanner _scn = new Scanner(System.in))
|
||||
{
|
||||
while (true)
|
||||
{
|
||||
System.out.println("Please choose an option");
|
||||
System.out.println();
|
||||
System.out.println("1 - Create new account or update existing one (change pass and access level)");
|
||||
System.out.println("2 - Change access level");
|
||||
System.out.println("3 - Delete existing account");
|
||||
System.out.println("4 - List accounts and access levels");
|
||||
System.out.println("5 - Exit");
|
||||
while (!_mode.equals("1") && !_mode.equals("2") && !_mode.equals("3") && !_mode.equals("4") && !_mode.equals("5"))
|
||||
{
|
||||
System.out.print("Your choice: ");
|
||||
_mode = _scn.next();
|
||||
}
|
||||
|
||||
if (_mode.equals("1") || _mode.equals("2") || _mode.equals("3"))
|
||||
{
|
||||
while (_uname.trim().isEmpty())
|
||||
{
|
||||
System.out.print("Username: ");
|
||||
_uname = _scn.next().toLowerCase();
|
||||
}
|
||||
|
||||
if (_mode.equals("1"))
|
||||
{
|
||||
while (_pass.trim().isEmpty())
|
||||
{
|
||||
System.out.print("Password: ");
|
||||
_pass = _scn.next();
|
||||
}
|
||||
}
|
||||
|
||||
if (_mode.equals("1") || _mode.equals("2"))
|
||||
{
|
||||
while (_level.trim().isEmpty())
|
||||
{
|
||||
System.out.print("Access level: ");
|
||||
_level = _scn.next();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if (_mode.equals("1"))
|
||||
{
|
||||
// Add or Update
|
||||
addOrUpdateAccount(_uname.trim(), _pass.trim(), _level.trim());
|
||||
}
|
||||
else if (_mode.equals("2"))
|
||||
{
|
||||
// Change Level
|
||||
changeAccountLevel(_uname.trim(), _level.trim());
|
||||
}
|
||||
else if (_mode.equals("3"))
|
||||
{
|
||||
// Delete
|
||||
System.out.print("WARNING: This will not delete the gameserver data (characters, items, etc..)");
|
||||
System.out.print(" it will only delete the account login server data.");
|
||||
System.out.println();
|
||||
System.out.print("Do you really want to delete this account? Y/N: ");
|
||||
final String yesno = _scn.next();
|
||||
if ((yesno != null) && yesno.equalsIgnoreCase("Y"))
|
||||
{
|
||||
deleteAccount(_uname.trim());
|
||||
}
|
||||
else
|
||||
{
|
||||
System.out.println("Deletion cancelled.");
|
||||
}
|
||||
}
|
||||
else if (_mode.equals("4"))
|
||||
{
|
||||
// List
|
||||
_mode = "";
|
||||
System.out.println();
|
||||
System.out.println("Please choose a listing mode");
|
||||
System.out.println();
|
||||
System.out.println("1 - Banned accounts only (accessLevel < 0)");
|
||||
System.out.println("2 - GM/privileged accounts (accessLevel > 0");
|
||||
System.out.println("3 - Regular accounts only (accessLevel = 0)");
|
||||
System.out.println("4 - List all");
|
||||
while (!_mode.equals("1") && !_mode.equals("2") && !_mode.equals("3") && !_mode.equals("4"))
|
||||
{
|
||||
System.out.print("Your choice: ");
|
||||
_mode = _scn.next();
|
||||
}
|
||||
System.out.println();
|
||||
printAccInfo(_mode);
|
||||
}
|
||||
else if (_mode.equals("5"))
|
||||
{
|
||||
System.exit(0);
|
||||
}
|
||||
|
||||
_uname = "";
|
||||
_pass = "";
|
||||
_level = "";
|
||||
_mode = "";
|
||||
System.out.println();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private static void printAccInfo(String m)
|
||||
{
|
||||
int count = 0;
|
||||
String q = "SELECT login, accessLevel FROM accounts ";
|
||||
if (m.equals("1"))
|
||||
{
|
||||
q += "WHERE accessLevel < 0";
|
||||
}
|
||||
else if (m.equals("2"))
|
||||
{
|
||||
q += "WHERE accessLevel > 0";
|
||||
}
|
||||
else if (m.equals("3"))
|
||||
{
|
||||
q += "WHERE accessLevel = 0";
|
||||
}
|
||||
q += " ORDER BY login ASC";
|
||||
|
||||
try (Connection con = DatabaseFactory.getConnection();
|
||||
PreparedStatement ps = con.prepareStatement(q);
|
||||
ResultSet rset = ps.executeQuery())
|
||||
{
|
||||
while (rset.next())
|
||||
{
|
||||
System.out.println(rset.getString("login") + " -> " + rset.getInt("accessLevel"));
|
||||
count++;
|
||||
}
|
||||
|
||||
System.out.println("Displayed accounts: " + count);
|
||||
}
|
||||
catch (SQLException e)
|
||||
{
|
||||
System.out.println("There was error while displaying accounts:");
|
||||
System.out.println(e.getMessage());
|
||||
}
|
||||
}
|
||||
|
||||
private static void addOrUpdateAccount(String account, String password, String level)
|
||||
{
|
||||
try (Connection con = DatabaseFactory.getConnection();
|
||||
PreparedStatement ps = con.prepareStatement("REPLACE accounts(login, password, accessLevel) VALUES (?, ?, ?)"))
|
||||
{
|
||||
final MessageDigest md = MessageDigest.getInstance("SHA");
|
||||
final byte[] newPassword = md.digest(password.getBytes("UTF-8"));
|
||||
ps.setString(1, account);
|
||||
ps.setString(2, Base64.getEncoder().encodeToString(newPassword));
|
||||
ps.setString(3, level);
|
||||
if (ps.executeUpdate() > 0)
|
||||
{
|
||||
System.out.println("Account " + account + " has been created or updated");
|
||||
}
|
||||
else
|
||||
{
|
||||
System.out.println("Account " + account + " does not exist");
|
||||
}
|
||||
}
|
||||
catch (Exception e)
|
||||
{
|
||||
System.out.println("There was error while adding/updating account:");
|
||||
System.out.println(e.getMessage());
|
||||
}
|
||||
}
|
||||
|
||||
private static void changeAccountLevel(String account, String level)
|
||||
{
|
||||
try (Connection con = DatabaseFactory.getConnection();
|
||||
PreparedStatement ps = con.prepareStatement("UPDATE accounts SET accessLevel = ? WHERE login = ?"))
|
||||
{
|
||||
ps.setString(1, level);
|
||||
ps.setString(2, account);
|
||||
if (ps.executeUpdate() > 0)
|
||||
{
|
||||
System.out.println("Account " + account + " has been updated");
|
||||
}
|
||||
else
|
||||
{
|
||||
System.out.println("Account " + account + " does not exist");
|
||||
}
|
||||
}
|
||||
catch (SQLException e)
|
||||
{
|
||||
System.out.println("There was error while updating account:");
|
||||
System.out.println(e.getMessage());
|
||||
}
|
||||
}
|
||||
|
||||
private static void deleteAccount(String account)
|
||||
{
|
||||
try (Connection con = DatabaseFactory.getConnection();
|
||||
PreparedStatement ps = con.prepareStatement("DELETE FROM accounts WHERE login = ?"))
|
||||
{
|
||||
ps.setString(1, account);
|
||||
if (ps.executeUpdate() > 0)
|
||||
{
|
||||
System.out.println("Account " + account + " has been deleted");
|
||||
}
|
||||
else
|
||||
{
|
||||
System.out.println("Account " + account + " does not exist");
|
||||
}
|
||||
}
|
||||
catch (SQLException e)
|
||||
{
|
||||
System.out.println("There was error while deleting account:");
|
||||
System.out.println(e.getMessage());
|
||||
}
|
||||
}
|
||||
}
|
@ -0,0 +1,42 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.dbinstaller;
|
||||
|
||||
/**
|
||||
* Abstract Database Launcher.
|
||||
* @author Zoey76
|
||||
*/
|
||||
public abstract class AbstractDBLauncher
|
||||
{
|
||||
protected static String getArg(String arg, String[] args)
|
||||
{
|
||||
try
|
||||
{
|
||||
int i = 0;
|
||||
do
|
||||
{
|
||||
// Nothing is missing here.
|
||||
}
|
||||
while (!arg.equalsIgnoreCase(args[i++]));
|
||||
return args[i];
|
||||
}
|
||||
catch (Exception e)
|
||||
{
|
||||
return null;
|
||||
}
|
||||
}
|
||||
}
|
@ -0,0 +1,41 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.dbinstaller;
|
||||
|
||||
import java.sql.Connection;
|
||||
|
||||
/**
|
||||
* @author mrTJO
|
||||
*/
|
||||
public interface DBOutputInterface
|
||||
{
|
||||
void setProgressIndeterminate(boolean value);
|
||||
|
||||
void setProgressMaximum(int maxValue);
|
||||
|
||||
void setProgressValue(int value);
|
||||
|
||||
void setFrameVisible(boolean value);
|
||||
|
||||
void appendToProgressArea(String text);
|
||||
|
||||
Connection getConnection();
|
||||
|
||||
int requestConfirm(String title, String message, int type);
|
||||
|
||||
void showMessage(String title, String message, int type);
|
||||
}
|
@ -0,0 +1,61 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.dbinstaller;
|
||||
|
||||
import java.awt.HeadlessException;
|
||||
|
||||
import javax.swing.UIManager;
|
||||
|
||||
import com.l2jmobius.tools.dbinstaller.console.DBInstallerConsole;
|
||||
import com.l2jmobius.tools.dbinstaller.gui.DBConfigGUI;
|
||||
|
||||
/**
|
||||
* Contains main class for Database Installer If system doesn't support the graphical UI, start the installer in console mode.
|
||||
* @author mrTJO
|
||||
*/
|
||||
public class LauncherGS extends AbstractDBLauncher
|
||||
{
|
||||
public static void main(String[] args) throws Exception
|
||||
{
|
||||
final String defDatabase = "l2jmobius";
|
||||
final String dir = "sql/game/";
|
||||
|
||||
if ((args != null) && (args.length > 0))
|
||||
{
|
||||
new DBInstallerConsole(defDatabase, dir, getArg("-h", args), getArg("-p", args), getArg("-u", args), getArg("-pw", args), getArg("-d", args), getArg("-m", args));
|
||||
return;
|
||||
}
|
||||
|
||||
try
|
||||
{
|
||||
// Set OS Look And Feel
|
||||
UIManager.setLookAndFeel(UIManager.getSystemLookAndFeelClassName());
|
||||
}
|
||||
catch (Exception e)
|
||||
{
|
||||
}
|
||||
|
||||
try
|
||||
{
|
||||
new DBConfigGUI(defDatabase, dir);
|
||||
}
|
||||
catch (HeadlessException e)
|
||||
{
|
||||
new DBInstallerConsole(defDatabase, dir);
|
||||
}
|
||||
}
|
||||
}
|
@ -0,0 +1,61 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.dbinstaller;
|
||||
|
||||
import java.awt.HeadlessException;
|
||||
|
||||
import javax.swing.UIManager;
|
||||
|
||||
import com.l2jmobius.tools.dbinstaller.console.DBInstallerConsole;
|
||||
import com.l2jmobius.tools.dbinstaller.gui.DBConfigGUI;
|
||||
|
||||
/**
|
||||
* Contains main class for Database Installer If system doesn't support the graphical UI, start the installer in console mode.
|
||||
* @author mrTJO
|
||||
*/
|
||||
public class LauncherLS extends AbstractDBLauncher
|
||||
{
|
||||
public static void main(String[] args) throws Exception
|
||||
{
|
||||
final String defDatabase = "l2jmobius";
|
||||
final String dir = "sql/login/";
|
||||
|
||||
if ((args != null) && (args.length > 0))
|
||||
{
|
||||
new DBInstallerConsole(defDatabase, dir, getArg("-h", args), getArg("-p", args), getArg("-u", args), getArg("-pw", args), getArg("-d", args), getArg("-m", args));
|
||||
return;
|
||||
}
|
||||
|
||||
try
|
||||
{
|
||||
// Set OS Look And Feel
|
||||
UIManager.setLookAndFeel(UIManager.getSystemLookAndFeelClassName());
|
||||
}
|
||||
catch (Exception e)
|
||||
{
|
||||
}
|
||||
|
||||
try
|
||||
{
|
||||
new DBConfigGUI(defDatabase, dir);
|
||||
}
|
||||
catch (HeadlessException e)
|
||||
{
|
||||
new DBInstallerConsole(defDatabase, dir);
|
||||
}
|
||||
}
|
||||
}
|
@ -0,0 +1,66 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.dbinstaller;
|
||||
|
||||
import java.io.File;
|
||||
import java.sql.SQLException;
|
||||
|
||||
import javax.swing.JOptionPane;
|
||||
|
||||
import com.l2jmobius.tools.dbinstaller.util.mysql.DBDumper;
|
||||
import com.l2jmobius.tools.dbinstaller.util.mysql.ScriptExecutor;
|
||||
|
||||
/**
|
||||
* @author mrTJO
|
||||
*/
|
||||
public class RunTasks extends Thread
|
||||
{
|
||||
DBOutputInterface _frame;
|
||||
String _db;
|
||||
String _sqlDir;
|
||||
|
||||
public RunTasks(DBOutputInterface frame, String db, String sqlDir)
|
||||
{
|
||||
_frame = frame;
|
||||
_db = db;
|
||||
_sqlDir = sqlDir;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void run()
|
||||
{
|
||||
new DBDumper(_frame, _db);
|
||||
final ScriptExecutor exec = new ScriptExecutor(_frame);
|
||||
|
||||
_frame.appendToProgressArea("Installing Database Content...");
|
||||
exec.execSqlBatch(new File(_sqlDir));
|
||||
|
||||
_frame.appendToProgressArea("Database Installation Complete!");
|
||||
|
||||
try
|
||||
{
|
||||
_frame.getConnection().close();
|
||||
}
|
||||
catch (SQLException e)
|
||||
{
|
||||
JOptionPane.showMessageDialog(null, "Cannot close MySQL Connection: " + e.getMessage(), "Connection Error", JOptionPane.ERROR_MESSAGE);
|
||||
}
|
||||
|
||||
_frame.showMessage("Done!", "Database Installation Complete!", JOptionPane.INFORMATION_MESSAGE);
|
||||
System.exit(0);
|
||||
}
|
||||
}
|
@ -0,0 +1,170 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.dbinstaller.console;
|
||||
|
||||
import java.sql.Connection;
|
||||
import java.util.Scanner;
|
||||
import java.util.prefs.Preferences;
|
||||
|
||||
import com.l2jmobius.tools.dbinstaller.DBOutputInterface;
|
||||
import com.l2jmobius.tools.dbinstaller.RunTasks;
|
||||
import com.l2jmobius.tools.dbinstaller.util.CloseShieldedInputStream;
|
||||
import com.l2jmobius.tools.dbinstaller.util.mysql.MySqlConnect;
|
||||
|
||||
/**
|
||||
* @author mrTJO
|
||||
*/
|
||||
public class DBInstallerConsole implements DBOutputInterface
|
||||
{
|
||||
Connection _con;
|
||||
|
||||
public DBInstallerConsole(String db, String dir) throws Exception
|
||||
{
|
||||
System.out.println("Welcome to DataBase installer");
|
||||
final Preferences prop = Preferences.userRoot();
|
||||
RunTasks rt = null;
|
||||
try (Scanner scn = new Scanner(new CloseShieldedInputStream(System.in)))
|
||||
{
|
||||
while (_con == null)
|
||||
{
|
||||
System.out.printf("%s (%s): ", "Host", prop.get("dbHost_" + db, "localhost"));
|
||||
String dbHost = scn.nextLine();
|
||||
System.out.printf("%s (%s): ", "Port", prop.get("dbPort_" + db, "3306"));
|
||||
String dbPort = scn.nextLine();
|
||||
System.out.printf("%s (%s): ", "Username", prop.get("dbUser_" + db, "root"));
|
||||
String dbUser = scn.nextLine();
|
||||
System.out.printf("%s (%s): ", "Password", "");
|
||||
final String dbPass = scn.nextLine();
|
||||
System.out.printf("%s (%s): ", "Database", prop.get("dbDbse_" + db, db));
|
||||
String dbDbse = scn.nextLine();
|
||||
|
||||
dbHost = dbHost.isEmpty() ? prop.get("dbHost_" + db, "localhost") : dbHost;
|
||||
dbPort = dbPort.isEmpty() ? prop.get("dbPort_" + db, "3306") : dbPort;
|
||||
dbUser = dbUser.isEmpty() ? prop.get("dbUser_" + db, "root") : dbUser;
|
||||
dbDbse = dbDbse.isEmpty() ? prop.get("dbDbse_" + db, db) : dbDbse;
|
||||
|
||||
final MySqlConnect connector = new MySqlConnect(dbHost, dbPort, dbUser, dbPass, dbDbse, true);
|
||||
|
||||
_con = connector.getConnection();
|
||||
}
|
||||
|
||||
System.out.print("(C)lean install, (U)pdate or (E)xit? ");
|
||||
final String resp = scn.next();
|
||||
if (resp.equalsIgnoreCase("c"))
|
||||
{
|
||||
System.out.print("Do you really want to destroy your db (Y/N)?");
|
||||
if (scn.next().equalsIgnoreCase("y"))
|
||||
{
|
||||
rt = new RunTasks(this, db, dir);
|
||||
}
|
||||
}
|
||||
else if (resp.equalsIgnoreCase("u"))
|
||||
{
|
||||
rt = new RunTasks(this, db, dir);
|
||||
}
|
||||
}
|
||||
|
||||
if (rt != null)
|
||||
{
|
||||
rt.run();
|
||||
}
|
||||
else
|
||||
{
|
||||
System.exit(0);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Database Console Installer constructor.
|
||||
* @param defDatabase the default database name
|
||||
* @param dir the SQL script's directory
|
||||
* @param host the host name
|
||||
* @param port the port
|
||||
* @param user the user name
|
||||
* @param pass the password
|
||||
* @param database the database name
|
||||
* @param mode the mode, c: Clean, u:update
|
||||
* @throws Exception
|
||||
*/
|
||||
public DBInstallerConsole(String defDatabase, String dir, String host, String port, String user, String pass, String database, String mode) throws Exception
|
||||
{
|
||||
if ((database == null) || database.isEmpty())
|
||||
{
|
||||
database = defDatabase;
|
||||
}
|
||||
|
||||
final MySqlConnect connector = new MySqlConnect(host, port, user, pass, database, true);
|
||||
|
||||
_con = connector.getConnection();
|
||||
|
||||
if ((mode != null) && ("c".equalsIgnoreCase(mode) || "u".equalsIgnoreCase(mode)))
|
||||
{
|
||||
final RunTasks rt = new RunTasks(this, database, dir);
|
||||
rt.run();
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void appendToProgressArea(String text)
|
||||
{
|
||||
System.out.println(text);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Connection getConnection()
|
||||
{
|
||||
return _con;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void setProgressIndeterminate(boolean value)
|
||||
{
|
||||
}
|
||||
|
||||
@Override
|
||||
public void setProgressMaximum(int maxValue)
|
||||
{
|
||||
}
|
||||
|
||||
@Override
|
||||
public void setProgressValue(int value)
|
||||
{
|
||||
}
|
||||
|
||||
@Override
|
||||
public void setFrameVisible(boolean value)
|
||||
{
|
||||
}
|
||||
|
||||
@Override
|
||||
public int requestConfirm(String title, String message, int type)
|
||||
{
|
||||
System.out.print(message);
|
||||
String res = "";
|
||||
try (Scanner scn = new Scanner(new CloseShieldedInputStream(System.in)))
|
||||
{
|
||||
res = scn.next();
|
||||
}
|
||||
return res.equalsIgnoreCase("y") ? 0 : 1;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void showMessage(String title, String message, int type)
|
||||
{
|
||||
System.out.println(message);
|
||||
}
|
||||
}
|
@ -0,0 +1,213 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.dbinstaller.gui;
|
||||
|
||||
import java.awt.Dimension;
|
||||
import java.awt.Image;
|
||||
import java.awt.Toolkit;
|
||||
import java.awt.event.ActionListener;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.prefs.Preferences;
|
||||
|
||||
import javax.swing.ImageIcon;
|
||||
import javax.swing.JButton;
|
||||
import javax.swing.JFrame;
|
||||
import javax.swing.JLabel;
|
||||
import javax.swing.JOptionPane;
|
||||
import javax.swing.JPasswordField;
|
||||
import javax.swing.JTextField;
|
||||
import javax.swing.SpringLayout;
|
||||
import javax.swing.SwingConstants;
|
||||
import javax.swing.WindowConstants;
|
||||
|
||||
import com.l2jmobius.commons.util.SplashScreen;
|
||||
import com.l2jmobius.tools.dbinstaller.RunTasks;
|
||||
import com.l2jmobius.tools.dbinstaller.util.mysql.MySqlConnect;
|
||||
import com.l2jmobius.tools.dbinstaller.util.swing.SpringUtilities;
|
||||
|
||||
/**
|
||||
* @author mrTJO
|
||||
*/
|
||||
public class DBConfigGUI extends JFrame
|
||||
{
|
||||
JTextField _dbHost;
|
||||
JTextField _dbPort;
|
||||
JTextField _dbUser;
|
||||
JPasswordField _dbPass;
|
||||
JTextField _dbDbse;
|
||||
|
||||
String _db;
|
||||
String _dir;
|
||||
|
||||
Preferences _prop;
|
||||
|
||||
boolean _isVisible = true;
|
||||
|
||||
public DBConfigGUI(String db, String dir)
|
||||
{
|
||||
super("Mobius - DB Installer");
|
||||
setVisible(false);
|
||||
setLayout(new SpringLayout());
|
||||
setDefaultLookAndFeelDecorated(true);
|
||||
|
||||
// Set icons.
|
||||
List<Image> icons = new ArrayList<>();
|
||||
icons.add(new ImageIcon("..\\images\\l2jmobius_16x16.png").getImage());
|
||||
icons.add(new ImageIcon("..\\images\\l2jmobius_32x32.png").getImage());
|
||||
icons.add(new ImageIcon("..\\images\\l2jmobius_64x64.png").getImage());
|
||||
icons.add(new ImageIcon("..\\images\\l2jmobius_128x128.png").getImage());
|
||||
setIconImages(icons);
|
||||
|
||||
// Show SplashScreen.
|
||||
new SplashScreen("..\\images\\splash.png", 5000, this);
|
||||
|
||||
_db = db;
|
||||
_dir = dir;
|
||||
|
||||
final int width = 260;
|
||||
final int height = 220;
|
||||
final Dimension resolution = Toolkit.getDefaultToolkit().getScreenSize();
|
||||
|
||||
setDefaultCloseOperation(WindowConstants.EXIT_ON_CLOSE);
|
||||
setBounds((resolution.width - width) / 2, (resolution.height - height) / 2, width, height);
|
||||
setResizable(false);
|
||||
|
||||
_prop = Preferences.userRoot();
|
||||
|
||||
// Host
|
||||
final JLabel labelDbHost = new JLabel("Host: ", SwingConstants.LEFT);
|
||||
add(labelDbHost);
|
||||
_dbHost = new JTextField(15);
|
||||
_dbHost.setText(_prop.get("dbHost_" + db, "localhost"));
|
||||
labelDbHost.setLabelFor(_dbHost);
|
||||
add(_dbHost);
|
||||
|
||||
// Port
|
||||
final JLabel labelDbPort = new JLabel("Port: ", SwingConstants.LEFT);
|
||||
add(labelDbPort);
|
||||
_dbPort = new JTextField(15);
|
||||
_dbPort.setText(_prop.get("dbPort_" + db, "3306"));
|
||||
labelDbPort.setLabelFor(_dbPort);
|
||||
add(_dbPort);
|
||||
|
||||
// Username
|
||||
final JLabel labelDbUser = new JLabel("Username: ", SwingConstants.LEFT);
|
||||
add(labelDbUser);
|
||||
_dbUser = new JTextField(15);
|
||||
_dbUser.setText(_prop.get("dbUser_" + db, "root"));
|
||||
labelDbUser.setLabelFor(_dbUser);
|
||||
add(_dbUser);
|
||||
|
||||
// Password
|
||||
final JLabel labelDbPass = new JLabel("Password: ", SwingConstants.LEFT);
|
||||
add(labelDbPass);
|
||||
_dbPass = new JPasswordField(15);
|
||||
_dbPass.setText(_prop.get("dbPass_" + db, ""));
|
||||
labelDbPass.setLabelFor(_dbPass);
|
||||
add(_dbPass);
|
||||
|
||||
// Database
|
||||
final JLabel labelDbDbse = new JLabel("Database: ", SwingConstants.LEFT);
|
||||
add(labelDbDbse);
|
||||
_dbDbse = new JTextField(15);
|
||||
_dbDbse.setText(_prop.get("dbDbse_" + db, db));
|
||||
labelDbDbse.setLabelFor(_dbDbse);
|
||||
add(_dbDbse);
|
||||
|
||||
final ActionListener cancelListener = e -> System.exit(0);
|
||||
|
||||
// Cancel
|
||||
final JButton btnCancel = new JButton("Cancel");
|
||||
btnCancel.addActionListener(cancelListener);
|
||||
add(btnCancel);
|
||||
|
||||
final ActionListener connectListener = e ->
|
||||
{
|
||||
MySqlConnect connector = null;
|
||||
try
|
||||
{
|
||||
connector = new MySqlConnect(_dbHost.getText(), _dbPort.getText(), _dbUser.getText(), new String(_dbPass.getPassword()), _dbDbse.getText(), false);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
ex.printStackTrace();
|
||||
}
|
||||
|
||||
if ((connector != null) && (connector.getConnection() != null))
|
||||
{
|
||||
_prop.put("dbHost_" + _db, _dbHost.getText());
|
||||
_prop.put("dbPort_" + _db, _dbPort.getText());
|
||||
_prop.put("dbUser_" + _db, _dbUser.getText());
|
||||
_prop.put("dbDbse_" + _db, _dbDbse.getText());
|
||||
|
||||
final DBInstallerGUI dbi = new DBInstallerGUI(connector.getConnection());
|
||||
setVisible(false);
|
||||
|
||||
if (_dir.equals("sql/login/"))
|
||||
{
|
||||
final Object[] options =
|
||||
{
|
||||
"Install Login",
|
||||
"Exit"
|
||||
};
|
||||
final int n = JOptionPane.showOptionDialog(null, "Install login server database?", "Select an option", JOptionPane.YES_NO_CANCEL_OPTION, JOptionPane.QUESTION_MESSAGE, null, options, options[1]);
|
||||
|
||||
if ((n == 1) || (n == -1))
|
||||
{
|
||||
System.exit(0);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
final Object[] options =
|
||||
{
|
||||
"Install Server",
|
||||
"Exit"
|
||||
};
|
||||
final int n = JOptionPane.showOptionDialog(null, "Install game server database?", "Select an option", JOptionPane.YES_NO_CANCEL_OPTION, JOptionPane.QUESTION_MESSAGE, null, options, options[1]);
|
||||
|
||||
if ((n == 1) || (n == -1))
|
||||
{
|
||||
System.exit(0);
|
||||
}
|
||||
}
|
||||
_isVisible = false;
|
||||
dbi.setVisible(true);
|
||||
|
||||
final RunTasks task = new RunTasks(dbi, _db, _dir);
|
||||
task.setPriority(Thread.MAX_PRIORITY);
|
||||
task.start();
|
||||
}
|
||||
};
|
||||
|
||||
// Connect
|
||||
final JButton btnConnect = new JButton("Connect");
|
||||
btnConnect.addActionListener(connectListener);
|
||||
add(btnConnect);
|
||||
|
||||
SpringUtilities.makeCompactGrid(getContentPane(), 6, 2, 5, 5, 5, 5);
|
||||
|
||||
pack();
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean isVisible()
|
||||
{
|
||||
return _isVisible;
|
||||
}
|
||||
}
|
@ -0,0 +1,134 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.dbinstaller.gui;
|
||||
|
||||
import java.awt.BorderLayout;
|
||||
import java.awt.Dimension;
|
||||
import java.awt.Image;
|
||||
import java.awt.Toolkit;
|
||||
import java.sql.Connection;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
|
||||
import javax.swing.ImageIcon;
|
||||
import javax.swing.JFrame;
|
||||
import javax.swing.JOptionPane;
|
||||
import javax.swing.JProgressBar;
|
||||
import javax.swing.JScrollPane;
|
||||
import javax.swing.JTextArea;
|
||||
import javax.swing.WindowConstants;
|
||||
|
||||
import com.l2jmobius.tools.dbinstaller.DBOutputInterface;
|
||||
|
||||
/**
|
||||
* @author mrTJO
|
||||
*/
|
||||
public class DBInstallerGUI extends JFrame implements DBOutputInterface
|
||||
{
|
||||
private final JProgressBar _progBar;
|
||||
private final JTextArea _progArea;
|
||||
private final Connection _con;
|
||||
|
||||
public DBInstallerGUI(Connection con)
|
||||
{
|
||||
super("Mobius - DB Installer");
|
||||
setLayout(new BorderLayout());
|
||||
setDefaultLookAndFeelDecorated(true);
|
||||
|
||||
// Set icons.
|
||||
List<Image> icons = new ArrayList<>();
|
||||
icons.add(new ImageIcon("..\\images\\l2jmobius_16x16.png").getImage());
|
||||
icons.add(new ImageIcon("..\\images\\l2jmobius_32x32.png").getImage());
|
||||
icons.add(new ImageIcon("..\\images\\l2jmobius_64x64.png").getImage());
|
||||
icons.add(new ImageIcon("..\\images\\l2jmobius_128x128.png").getImage());
|
||||
setIconImages(icons);
|
||||
|
||||
_con = con;
|
||||
|
||||
final int width = 480;
|
||||
final int height = 360;
|
||||
final Dimension resolution = Toolkit.getDefaultToolkit().getScreenSize();
|
||||
|
||||
setDefaultCloseOperation(WindowConstants.EXIT_ON_CLOSE);
|
||||
setBounds((resolution.width - width) / 2, (resolution.height - height) / 2, width, height);
|
||||
setResizable(false);
|
||||
|
||||
_progBar = new JProgressBar();
|
||||
_progBar.setIndeterminate(true);
|
||||
add(_progBar, BorderLayout.PAGE_START);
|
||||
|
||||
_progArea = new JTextArea();
|
||||
final JScrollPane scrollPane = new JScrollPane(_progArea);
|
||||
|
||||
_progArea.setEditable(false);
|
||||
appendToProgressArea("Connected");
|
||||
|
||||
add(scrollPane, BorderLayout.CENTER);
|
||||
|
||||
getContentPane().setPreferredSize(new Dimension(width, height));
|
||||
pack();
|
||||
}
|
||||
|
||||
@Override
|
||||
public void setProgressIndeterminate(boolean value)
|
||||
{
|
||||
_progBar.setIndeterminate(value);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void setProgressMaximum(int maxValue)
|
||||
{
|
||||
_progBar.setMaximum(maxValue);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void setProgressValue(int value)
|
||||
{
|
||||
_progBar.setValue(value);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void appendToProgressArea(String text)
|
||||
{
|
||||
_progArea.append(text + System.getProperty("line.separator"));
|
||||
_progArea.setCaretPosition(_progArea.getDocument().getLength());
|
||||
}
|
||||
|
||||
@Override
|
||||
public Connection getConnection()
|
||||
{
|
||||
return _con;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void setFrameVisible(boolean value)
|
||||
{
|
||||
setVisible(value);
|
||||
}
|
||||
|
||||
@Override
|
||||
public int requestConfirm(String title, String message, int type)
|
||||
{
|
||||
return JOptionPane.showConfirmDialog(null, message, title, type);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void showMessage(String title, String message, int type)
|
||||
{
|
||||
JOptionPane.showMessageDialog(null, message, title, type);
|
||||
}
|
||||
}
|
@ -0,0 +1,142 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.dbinstaller.util;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
|
||||
/**
|
||||
* Prevent the underlying input stream to close.
|
||||
* @author Joe Cheng, Zoey76
|
||||
*/
|
||||
public class CloseShieldedInputStream extends InputStream
|
||||
{
|
||||
private InputStream _in = null;
|
||||
|
||||
/**
|
||||
* Instantiates a new close shielded input stream.
|
||||
* @param in the in
|
||||
*/
|
||||
public CloseShieldedInputStream(InputStream in)
|
||||
{
|
||||
_in = in;
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritDoc}
|
||||
*/
|
||||
@Override
|
||||
public void close()
|
||||
{
|
||||
_in = null;
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritDoc}
|
||||
*/
|
||||
@Override
|
||||
public int read() throws IOException
|
||||
{
|
||||
if (_in == null)
|
||||
{
|
||||
throw new IOException("Stream is null!");
|
||||
}
|
||||
return _in.read();
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritDoc}
|
||||
*/
|
||||
@Override
|
||||
public int read(byte b[]) throws IOException
|
||||
{
|
||||
if (_in == null)
|
||||
{
|
||||
throw new IOException("Stream is null!");
|
||||
}
|
||||
return _in.read(b);
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritDoc}
|
||||
*/
|
||||
@Override
|
||||
public int read(byte b[], int off, int len) throws IOException
|
||||
{
|
||||
if (_in == null)
|
||||
{
|
||||
throw new IOException("Stream is null!");
|
||||
}
|
||||
return _in.read(b, off, len);
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritDoc}
|
||||
*/
|
||||
@Override
|
||||
public long skip(long n) throws IOException
|
||||
{
|
||||
if (_in == null)
|
||||
{
|
||||
throw new IOException("Stream is null!");
|
||||
}
|
||||
return _in.skip(n);
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritDoc}
|
||||
*/
|
||||
@Override
|
||||
public synchronized void mark(int readlimit)
|
||||
{
|
||||
if (_in != null)
|
||||
{
|
||||
_in.mark(readlimit);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritDoc}
|
||||
*/
|
||||
@Override
|
||||
public boolean markSupported()
|
||||
{
|
||||
return (_in != null) && _in.markSupported();
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritDoc}
|
||||
*/
|
||||
@Override
|
||||
public synchronized void reset() throws IOException
|
||||
{
|
||||
if (_in == null)
|
||||
{
|
||||
throw new IOException("Stream is null!");
|
||||
}
|
||||
_in.reset();
|
||||
}
|
||||
|
||||
/**
|
||||
* Gets the underlying stream.
|
||||
* @return the underlying stream
|
||||
*/
|
||||
public InputStream getUnderlyingStream()
|
||||
{
|
||||
return _in;
|
||||
}
|
||||
}
|
@ -0,0 +1,47 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.dbinstaller.util;
|
||||
|
||||
import java.io.BufferedWriter;
|
||||
import java.io.FileWriter;
|
||||
import java.io.IOException;
|
||||
|
||||
/**
|
||||
* @author mrTJO
|
||||
*/
|
||||
public class FileWriterStdout extends BufferedWriter
|
||||
{
|
||||
public FileWriterStdout(FileWriter fileWriter)
|
||||
{
|
||||
super(fileWriter);
|
||||
}
|
||||
|
||||
public void println() throws IOException
|
||||
{
|
||||
append(System.getProperty("line.separator"));
|
||||
}
|
||||
|
||||
public void println(String line) throws IOException
|
||||
{
|
||||
append(line + System.getProperty("line.separator"));
|
||||
}
|
||||
|
||||
public void print(String text) throws IOException
|
||||
{
|
||||
append(text);
|
||||
}
|
||||
}
|
@ -0,0 +1,214 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.dbinstaller.util.mysql;
|
||||
|
||||
import java.io.File;
|
||||
import java.io.FileWriter;
|
||||
import java.sql.Connection;
|
||||
import java.sql.ResultSet;
|
||||
import java.sql.Statement;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Formatter;
|
||||
import java.util.GregorianCalendar;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
import com.l2jmobius.tools.dbinstaller.DBOutputInterface;
|
||||
import com.l2jmobius.tools.dbinstaller.util.FileWriterStdout;
|
||||
|
||||
/**
|
||||
* @author mrTJO
|
||||
*/
|
||||
public class DBDumper
|
||||
{
|
||||
DBOutputInterface _frame;
|
||||
String _db;
|
||||
|
||||
public DBDumper(DBOutputInterface frame, String db)
|
||||
{
|
||||
_frame = frame;
|
||||
_db = db;
|
||||
createDump();
|
||||
}
|
||||
|
||||
public void createDump()
|
||||
{
|
||||
try (Formatter form = new Formatter())
|
||||
{
|
||||
final Connection con = _frame.getConnection();
|
||||
try (Statement s = con.createStatement();
|
||||
ResultSet rset = s.executeQuery("SHOW TABLES"))
|
||||
{
|
||||
final File dump = new File("dumps", form.format("%1$s_dump_%2$tY%2$tm%2$td-%2$tH%2$tM%2$tS.sql", _db, new GregorianCalendar().getTime()).toString());
|
||||
new File("dumps").mkdir();
|
||||
dump.createNewFile();
|
||||
|
||||
_frame.appendToProgressArea("Writing dump " + dump.getName());
|
||||
if (rset.last())
|
||||
{
|
||||
final int rows = rset.getRow();
|
||||
rset.beforeFirst();
|
||||
if (rows > 0)
|
||||
{
|
||||
_frame.setProgressIndeterminate(false);
|
||||
_frame.setProgressMaximum(rows);
|
||||
}
|
||||
}
|
||||
|
||||
try (FileWriter fileWriter = new FileWriter(dump);
|
||||
FileWriterStdout fws = new FileWriterStdout(fileWriter))
|
||||
{
|
||||
while (rset.next())
|
||||
{
|
||||
_frame.setProgressValue(rset.getRow());
|
||||
_frame.appendToProgressArea("Dumping Table " + rset.getString(1));
|
||||
fws.println("CREATE TABLE `" + rset.getString(1) + "`");
|
||||
fws.println("(");
|
||||
try (Statement desc = con.createStatement();
|
||||
ResultSet dset = desc.executeQuery("DESC " + rset.getString(1)))
|
||||
{
|
||||
final Map<String, List<String>> keys = new HashMap<>();
|
||||
boolean isFirst = true;
|
||||
while (dset.next())
|
||||
{
|
||||
if (!isFirst)
|
||||
{
|
||||
fws.println(",");
|
||||
}
|
||||
fws.print("\t`" + dset.getString(1) + "`");
|
||||
fws.print(" " + dset.getString(2));
|
||||
if (dset.getString(3).equals("NO"))
|
||||
{
|
||||
fws.print(" NOT NULL");
|
||||
}
|
||||
if (!dset.getString(4).isEmpty())
|
||||
{
|
||||
if (!keys.containsKey(dset.getString(4)))
|
||||
{
|
||||
keys.put(dset.getString(4), new ArrayList<>());
|
||||
}
|
||||
keys.get(dset.getString(4)).add(dset.getString(1));
|
||||
}
|
||||
if (dset.getString(5) != null)
|
||||
{
|
||||
fws.print(" DEFAULT '" + dset.getString(5) + "'");
|
||||
}
|
||||
if (!dset.getString(6).isEmpty())
|
||||
{
|
||||
fws.print(" " + dset.getString(6));
|
||||
}
|
||||
isFirst = false;
|
||||
}
|
||||
if (keys.containsKey("PRI"))
|
||||
{
|
||||
fws.println(",");
|
||||
fws.print("\tPRIMARY KEY (");
|
||||
isFirst = true;
|
||||
for (String key : keys.get("PRI"))
|
||||
{
|
||||
if (!isFirst)
|
||||
{
|
||||
fws.print(", ");
|
||||
}
|
||||
fws.print("`" + key + "`");
|
||||
isFirst = false;
|
||||
}
|
||||
fws.print(")");
|
||||
}
|
||||
if (keys.containsKey("MUL"))
|
||||
{
|
||||
fws.println(",");
|
||||
isFirst = true;
|
||||
for (String key : keys.get("MUL"))
|
||||
{
|
||||
if (!isFirst)
|
||||
{
|
||||
fws.println(", ");
|
||||
}
|
||||
fws.print("\tKEY `key_" + key + "` (`" + key + "`)");
|
||||
isFirst = false;
|
||||
}
|
||||
}
|
||||
fws.println();
|
||||
fws.println(");");
|
||||
fws.flush();
|
||||
}
|
||||
|
||||
try (Statement desc = con.createStatement();
|
||||
ResultSet dset = desc.executeQuery("SELECT * FROM " + rset.getString(1)))
|
||||
{
|
||||
boolean isFirst = true;
|
||||
int cnt = 0;
|
||||
while (dset.next())
|
||||
{
|
||||
if ((cnt % 100) == 0)
|
||||
{
|
||||
fws.println("INSERT INTO `" + rset.getString(1) + "` VALUES ");
|
||||
}
|
||||
else
|
||||
{
|
||||
fws.println(",");
|
||||
}
|
||||
|
||||
fws.print("\t(");
|
||||
boolean isInFirst = true;
|
||||
for (int i = 1; i <= dset.getMetaData().getColumnCount(); i++)
|
||||
{
|
||||
if (!isInFirst)
|
||||
{
|
||||
fws.print(", ");
|
||||
}
|
||||
|
||||
if (dset.getString(i) != null)
|
||||
{
|
||||
fws.print("'" + dset.getString(i).replace("\'", "\\\'") + "'");
|
||||
}
|
||||
else
|
||||
{
|
||||
fws.print("NULL");
|
||||
}
|
||||
isInFirst = false;
|
||||
}
|
||||
fws.print(")");
|
||||
isFirst = false;
|
||||
|
||||
if ((cnt % 100) == 99)
|
||||
{
|
||||
fws.println(";");
|
||||
}
|
||||
cnt++;
|
||||
}
|
||||
if (!isFirst && ((cnt % 100) != 0))
|
||||
{
|
||||
fws.println(";");
|
||||
}
|
||||
fws.println();
|
||||
fws.flush();
|
||||
}
|
||||
}
|
||||
fws.flush();
|
||||
}
|
||||
}
|
||||
}
|
||||
catch (Exception e)
|
||||
{
|
||||
e.printStackTrace();
|
||||
}
|
||||
_frame.appendToProgressArea("Dump Complete!");
|
||||
}
|
||||
}
|
@ -0,0 +1,112 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.dbinstaller.util.mysql;
|
||||
|
||||
import java.sql.Connection;
|
||||
import java.sql.DriverManager;
|
||||
import java.sql.SQLException;
|
||||
import java.sql.Statement;
|
||||
import java.util.Formatter;
|
||||
|
||||
import javax.swing.JOptionPane;
|
||||
|
||||
/**
|
||||
* @author mrTJO
|
||||
*/
|
||||
public class MySqlConnect
|
||||
{
|
||||
Connection con = null;
|
||||
|
||||
public MySqlConnect(String host, String port, String user, String password, String db, boolean console) throws Exception
|
||||
{
|
||||
try (Formatter form = new Formatter())
|
||||
{
|
||||
Class.forName("org.mariadb.jdbc.Driver").getDeclaredConstructor().newInstance();
|
||||
final String formattedText = form.format("jdbc:mariadb://%1$s:%2$s", host, port).toString();
|
||||
con = DriverManager.getConnection(formattedText, user, password);
|
||||
|
||||
try (Statement s = con.createStatement())
|
||||
{
|
||||
s.execute("CREATE DATABASE IF NOT EXISTS `" + db + "`");
|
||||
s.execute("USE `" + db + "`");
|
||||
}
|
||||
}
|
||||
catch (SQLException e)
|
||||
{
|
||||
if (console)
|
||||
{
|
||||
e.printStackTrace();
|
||||
}
|
||||
else
|
||||
{
|
||||
JOptionPane.showMessageDialog(null, "MySQL Error: " + e.getMessage(), "Connection Error", JOptionPane.ERROR_MESSAGE);
|
||||
}
|
||||
}
|
||||
catch (InstantiationException e)
|
||||
{
|
||||
if (console)
|
||||
{
|
||||
e.printStackTrace();
|
||||
}
|
||||
else
|
||||
{
|
||||
JOptionPane.showMessageDialog(null, "Instantiation Exception: " + e.getMessage(), "Connection Error", JOptionPane.ERROR_MESSAGE);
|
||||
}
|
||||
}
|
||||
catch (IllegalAccessException e)
|
||||
{
|
||||
if (console)
|
||||
{
|
||||
e.printStackTrace();
|
||||
}
|
||||
else
|
||||
{
|
||||
JOptionPane.showMessageDialog(null, "Illegal Access: " + e.getMessage(), "Connection Error", JOptionPane.ERROR_MESSAGE);
|
||||
}
|
||||
}
|
||||
catch (ClassNotFoundException e)
|
||||
{
|
||||
if (console)
|
||||
{
|
||||
e.printStackTrace();
|
||||
}
|
||||
else
|
||||
{
|
||||
JOptionPane.showMessageDialog(null, "Cannot find MySQL Connector: " + e.getMessage(), "Connection Error", JOptionPane.ERROR_MESSAGE);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
public Connection getConnection()
|
||||
{
|
||||
return con;
|
||||
}
|
||||
|
||||
public Statement getStatement()
|
||||
{
|
||||
try
|
||||
{
|
||||
return con.createStatement();
|
||||
}
|
||||
catch (SQLException e)
|
||||
{
|
||||
e.printStackTrace();
|
||||
System.out.println("Statement Null");
|
||||
return null;
|
||||
}
|
||||
}
|
||||
}
|
@ -0,0 +1,134 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.dbinstaller.util.mysql;
|
||||
|
||||
import java.awt.HeadlessException;
|
||||
import java.io.File;
|
||||
import java.io.FileNotFoundException;
|
||||
import java.sql.Connection;
|
||||
import java.sql.SQLException;
|
||||
import java.sql.Statement;
|
||||
import java.util.Arrays;
|
||||
import java.util.Scanner;
|
||||
|
||||
import javax.swing.JOptionPane;
|
||||
|
||||
import com.l2jmobius.commons.util.file.filter.SQLFilter;
|
||||
import com.l2jmobius.tools.dbinstaller.DBOutputInterface;
|
||||
|
||||
/**
|
||||
* @author mrTJO
|
||||
*/
|
||||
public class ScriptExecutor
|
||||
{
|
||||
DBOutputInterface _frame;
|
||||
|
||||
public ScriptExecutor(DBOutputInterface frame)
|
||||
{
|
||||
_frame = frame;
|
||||
}
|
||||
|
||||
public void execSqlBatch(File dir)
|
||||
{
|
||||
execSqlBatch(dir, false);
|
||||
}
|
||||
|
||||
public void execSqlBatch(File dir, boolean skipErrors)
|
||||
{
|
||||
final File[] files = dir.listFiles(new SQLFilter());
|
||||
if (files == null)
|
||||
{
|
||||
return;
|
||||
}
|
||||
Arrays.sort(files);
|
||||
_frame.setProgressIndeterminate(false);
|
||||
_frame.setProgressMaximum(files.length - 1);
|
||||
for (int i = 0; i < files.length; i++)
|
||||
{
|
||||
_frame.setProgressValue(i);
|
||||
execSqlFile(files[i], skipErrors);
|
||||
}
|
||||
}
|
||||
|
||||
public void execSqlFile(File file)
|
||||
{
|
||||
execSqlFile(file, false);
|
||||
}
|
||||
|
||||
public void execSqlFile(File file, boolean skipErrors)
|
||||
{
|
||||
_frame.appendToProgressArea("Installing " + file.getName());
|
||||
String line = "";
|
||||
final Connection con = _frame.getConnection();
|
||||
try (Statement stmt = con.createStatement();
|
||||
Scanner scn = new Scanner(file))
|
||||
{
|
||||
StringBuilder sb = new StringBuilder();
|
||||
while (scn.hasNextLine())
|
||||
{
|
||||
line = scn.nextLine();
|
||||
if (line.startsWith("--"))
|
||||
{
|
||||
continue;
|
||||
}
|
||||
else if (line.contains("--"))
|
||||
{
|
||||
line = line.split("--")[0];
|
||||
}
|
||||
|
||||
line = line.trim();
|
||||
if (!line.isEmpty())
|
||||
{
|
||||
sb.append(line + System.getProperty("line.separator"));
|
||||
}
|
||||
|
||||
if (line.endsWith(";"))
|
||||
{
|
||||
stmt.execute(sb.toString());
|
||||
sb = new StringBuilder();
|
||||
}
|
||||
}
|
||||
}
|
||||
catch (FileNotFoundException e)
|
||||
{
|
||||
JOptionPane.showMessageDialog(null, "File Not Found!: " + e.getMessage(), "Installer Error", JOptionPane.ERROR_MESSAGE);
|
||||
}
|
||||
catch (SQLException e)
|
||||
{
|
||||
if (!skipErrors)
|
||||
{
|
||||
try
|
||||
{
|
||||
final Object[] options =
|
||||
{
|
||||
"Continue",
|
||||
"Abort"
|
||||
};
|
||||
|
||||
if (JOptionPane.showOptionDialog(null, "MySQL Error: " + e.getMessage(), "Script Error", JOptionPane.YES_NO_OPTION, JOptionPane.WARNING_MESSAGE, null, options, options[0]) == 1)
|
||||
{
|
||||
System.exit(0);
|
||||
}
|
||||
}
|
||||
catch (HeadlessException h)
|
||||
{
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
@ -0,0 +1,218 @@
|
||||
/*
|
||||
* Copyright (c) 1995, 2008, Oracle and/or its affiliates. All rights reserved.
|
||||
*
|
||||
* Redistribution and use in source and binary forms, with or without
|
||||
* modification, are permitted provided that the following conditions
|
||||
* are met:
|
||||
*
|
||||
* - Redistributions of source code must retain the above copyright
|
||||
* notice, this list of conditions and the following disclaimer.
|
||||
*
|
||||
* - Redistributions in binary form must reproduce the above copyright
|
||||
* notice, this list of conditions and the following disclaimer in the
|
||||
* documentation and/or other materials provided with the distribution.
|
||||
*
|
||||
* - Neither the name of Oracle or the names of its
|
||||
* contributors may be used to endorse or promote products derived
|
||||
* from this software without specific prior written permission.
|
||||
*
|
||||
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS
|
||||
* IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
|
||||
* THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
|
||||
* PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR
|
||||
* CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
|
||||
* EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
|
||||
* PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
|
||||
* PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
|
||||
* LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
|
||||
* NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
|
||||
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||
*/
|
||||
package com.l2jmobius.tools.dbinstaller.util.swing;
|
||||
|
||||
import java.awt.Component;
|
||||
import java.awt.Container;
|
||||
|
||||
import javax.swing.Spring;
|
||||
import javax.swing.SpringLayout;
|
||||
|
||||
/**
|
||||
* A 1.4 file that provides utility methods for creating form- or grid-style layouts with SpringLayout.<br>
|
||||
* These utilities are used by several programs, such as SpringBox and SpringCompactGrid.
|
||||
*/
|
||||
public class SpringUtilities
|
||||
{
|
||||
/**
|
||||
* A debugging utility that prints to stdout the component's minimum, preferred, and maximum sizes.
|
||||
* @param c
|
||||
*/
|
||||
public static void printSizes(Component c)
|
||||
{
|
||||
System.out.println("minimumSize = " + c.getMinimumSize());
|
||||
System.out.println("preferredSize = " + c.getPreferredSize());
|
||||
System.out.println("maximumSize = " + c.getMaximumSize());
|
||||
}
|
||||
|
||||
/**
|
||||
* Aligns the first <code>rows</code> * <code>cols</code> components of <code>parent</code> in a grid. Each component is as big as the maximum preferred width and height of the components. The parent is made just big enough to fit them all.
|
||||
* @param parent
|
||||
* @param rows number of rows
|
||||
* @param cols number of columns
|
||||
* @param initialX x location to start the grid at
|
||||
* @param initialY y location to start the grid at
|
||||
* @param xPad x padding between cells
|
||||
* @param yPad y padding between cells
|
||||
*/
|
||||
public static void makeGrid(Container parent, int rows, int cols, int initialX, int initialY, int xPad, int yPad)
|
||||
{
|
||||
SpringLayout layout;
|
||||
try
|
||||
{
|
||||
layout = (SpringLayout) parent.getLayout();
|
||||
}
|
||||
catch (ClassCastException exc)
|
||||
{
|
||||
System.err.println("The first argument to makeGrid must use SpringLayout.");
|
||||
return;
|
||||
}
|
||||
|
||||
final Spring xPadSpring = Spring.constant(xPad);
|
||||
final Spring yPadSpring = Spring.constant(yPad);
|
||||
final Spring initialXSpring = Spring.constant(initialX);
|
||||
final Spring initialYSpring = Spring.constant(initialY);
|
||||
final int max = rows * cols;
|
||||
|
||||
// Calculate Springs that are the max of the width/height so that all
|
||||
// cells have the same size.
|
||||
Spring maxWidthSpring = layout.getConstraints(parent.getComponent(0)).getWidth();
|
||||
Spring maxHeightSpring = layout.getConstraints(parent.getComponent(0)).getWidth();
|
||||
for (int i = 1; i < max; i++)
|
||||
{
|
||||
final SpringLayout.Constraints cons = layout.getConstraints(parent.getComponent(i));
|
||||
|
||||
maxWidthSpring = Spring.max(maxWidthSpring, cons.getWidth());
|
||||
maxHeightSpring = Spring.max(maxHeightSpring, cons.getHeight());
|
||||
}
|
||||
|
||||
// Apply the new width/height Spring. This forces all the
|
||||
// components to have the same size.
|
||||
for (int i = 0; i < max; i++)
|
||||
{
|
||||
final SpringLayout.Constraints cons = layout.getConstraints(parent.getComponent(i));
|
||||
|
||||
cons.setWidth(maxWidthSpring);
|
||||
cons.setHeight(maxHeightSpring);
|
||||
}
|
||||
|
||||
// Then adjust the x/y constraints of all the cells so that they
|
||||
// are aligned in a grid.
|
||||
SpringLayout.Constraints lastCons = null;
|
||||
SpringLayout.Constraints lastRowCons = null;
|
||||
for (int i = 0; i < max; i++)
|
||||
{
|
||||
final SpringLayout.Constraints cons = layout.getConstraints(parent.getComponent(i));
|
||||
if ((i % cols) == 0)
|
||||
{ // start of new row
|
||||
lastRowCons = lastCons;
|
||||
cons.setX(initialXSpring);
|
||||
}
|
||||
// x position depends on previous component
|
||||
else if (lastCons != null)
|
||||
{
|
||||
cons.setX(Spring.sum(lastCons.getConstraint(SpringLayout.EAST), xPadSpring));
|
||||
}
|
||||
|
||||
if ((i / cols) == 0)
|
||||
{
|
||||
// first row
|
||||
cons.setY(initialYSpring);
|
||||
}
|
||||
// y position depends on previous row
|
||||
else if (lastRowCons != null)
|
||||
{
|
||||
cons.setY(Spring.sum(lastRowCons.getConstraint(SpringLayout.SOUTH), yPadSpring));
|
||||
}
|
||||
lastCons = cons;
|
||||
}
|
||||
|
||||
// Set the parent's size.
|
||||
final SpringLayout.Constraints pCons = layout.getConstraints(parent);
|
||||
if (lastCons != null)
|
||||
{
|
||||
pCons.setConstraint(SpringLayout.SOUTH, Spring.sum(Spring.constant(yPad), lastCons.getConstraint(SpringLayout.SOUTH)));
|
||||
pCons.setConstraint(SpringLayout.EAST, Spring.sum(Spring.constant(xPad), lastCons.getConstraint(SpringLayout.EAST)));
|
||||
}
|
||||
}
|
||||
|
||||
/* Used by makeCompactGrid. */
|
||||
private static SpringLayout.Constraints getConstraintsForCell(int row, int col, Container parent, int cols)
|
||||
{
|
||||
return ((SpringLayout) parent.getLayout()).getConstraints(parent.getComponent((row * cols) + col));
|
||||
}
|
||||
|
||||
/**
|
||||
* Aligns the first <code>rows</code> * <code>cols</code> components of <code>parent</code> in a grid. Each component in a column is as wide as the maximum preferred width of the components in that column; height is similarly determined for each row. The parent is made just big enough to fit
|
||||
* them all.
|
||||
* @param parent
|
||||
* @param rows number of rows
|
||||
* @param cols number of columns
|
||||
* @param initialX x location to start the grid at
|
||||
* @param initialY y location to start the grid at
|
||||
* @param xPad x padding between cells
|
||||
* @param yPad y padding between cells
|
||||
*/
|
||||
public static void makeCompactGrid(Container parent, int rows, int cols, int initialX, int initialY, int xPad, int yPad)
|
||||
{
|
||||
SpringLayout layout;
|
||||
try
|
||||
{
|
||||
layout = (SpringLayout) parent.getLayout();
|
||||
}
|
||||
catch (ClassCastException exc)
|
||||
{
|
||||
System.err.println("The first argument to makeCompactGrid must use SpringLayout.");
|
||||
return;
|
||||
}
|
||||
|
||||
// Align all cells in each column and make them the same width.
|
||||
Spring x = Spring.constant(initialX);
|
||||
for (int c = 0; c < cols; c++)
|
||||
{
|
||||
Spring width = Spring.constant(0);
|
||||
for (int r = 0; r < rows; r++)
|
||||
{
|
||||
width = Spring.max(width, getConstraintsForCell(r, c, parent, cols).getWidth());
|
||||
}
|
||||
for (int r = 0; r < rows; r++)
|
||||
{
|
||||
final SpringLayout.Constraints constraints = getConstraintsForCell(r, c, parent, cols);
|
||||
constraints.setX(x);
|
||||
constraints.setWidth(width);
|
||||
}
|
||||
x = Spring.sum(x, Spring.sum(width, Spring.constant(xPad)));
|
||||
}
|
||||
|
||||
// Align all cells in each row and make them the same height.
|
||||
Spring y = Spring.constant(initialY);
|
||||
for (int r = 0; r < rows; r++)
|
||||
{
|
||||
Spring height = Spring.constant(0);
|
||||
for (int c = 0; c < cols; c++)
|
||||
{
|
||||
height = Spring.max(height, getConstraintsForCell(r, c, parent, cols).getHeight());
|
||||
}
|
||||
for (int c = 0; c < cols; c++)
|
||||
{
|
||||
final SpringLayout.Constraints constraints = getConstraintsForCell(r, c, parent, cols);
|
||||
constraints.setY(y);
|
||||
constraints.setHeight(height);
|
||||
}
|
||||
y = Spring.sum(y, Spring.sum(height, Spring.constant(yPad)));
|
||||
}
|
||||
|
||||
// Set the parent's size.
|
||||
final SpringLayout.Constraints pCons = layout.getConstraints(parent);
|
||||
pCons.setConstraint(SpringLayout.SOUTH, y);
|
||||
pCons.setConstraint(SpringLayout.EAST, x);
|
||||
}
|
||||
}
|
@ -0,0 +1,384 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.geodataconverter;
|
||||
|
||||
import java.io.BufferedOutputStream;
|
||||
import java.io.File;
|
||||
import java.io.FileOutputStream;
|
||||
import java.io.RandomAccessFile;
|
||||
import java.nio.ByteOrder;
|
||||
import java.nio.MappedByteBuffer;
|
||||
import java.nio.channels.FileChannel;
|
||||
import java.util.Scanner;
|
||||
|
||||
import com.l2jmobius.Config;
|
||||
import com.l2jmobius.commons.util.PropertiesParser;
|
||||
import com.l2jmobius.gameserver.geoengine.geodata.ABlock;
|
||||
import com.l2jmobius.gameserver.geoengine.geodata.BlockComplex;
|
||||
import com.l2jmobius.gameserver.geoengine.geodata.BlockFlat;
|
||||
import com.l2jmobius.gameserver.geoengine.geodata.BlockMultilayer;
|
||||
import com.l2jmobius.gameserver.geoengine.geodata.GeoFormat;
|
||||
import com.l2jmobius.gameserver.geoengine.geodata.GeoStructure;
|
||||
import com.l2jmobius.gameserver.model.L2World;
|
||||
|
||||
/**
|
||||
* @author Hasha
|
||||
*/
|
||||
public final class GeoDataConverter
|
||||
{
|
||||
private static GeoFormat _format;
|
||||
private static ABlock[][] _blocks;
|
||||
|
||||
public static void main(String[] args)
|
||||
{
|
||||
// initialize config
|
||||
loadGeoengineConfigs();
|
||||
|
||||
// get geodata format
|
||||
String type = "";
|
||||
try (Scanner scn = new Scanner(System.in))
|
||||
{
|
||||
while (!(type.equalsIgnoreCase("J") || type.equalsIgnoreCase("O") || type.equalsIgnoreCase("E")))
|
||||
{
|
||||
System.out.println("GeoDataConverter: Select source geodata type:");
|
||||
System.out.println(" J: L2J (e.g. 23_22.l2j)");
|
||||
System.out.println(" O: L2OFF (e.g. 23_22_conv.dat)");
|
||||
System.out.println(" E: Exit");
|
||||
System.out.print("Choice: ");
|
||||
type = scn.next();
|
||||
}
|
||||
}
|
||||
if (type.equalsIgnoreCase("E"))
|
||||
{
|
||||
System.exit(0);
|
||||
}
|
||||
|
||||
_format = type.equalsIgnoreCase("J") ? GeoFormat.L2J : GeoFormat.L2OFF;
|
||||
|
||||
// start conversion
|
||||
System.out.println("GeoDataConverter: Converting all " + _format + " files.");
|
||||
|
||||
// initialize geodata container
|
||||
_blocks = new ABlock[GeoStructure.REGION_BLOCKS_X][GeoStructure.REGION_BLOCKS_Y];
|
||||
|
||||
// initialize multilayer temporarily buffer
|
||||
BlockMultilayer.initialize();
|
||||
|
||||
// load geo files
|
||||
int converted = 0;
|
||||
for (int rx = L2World.TILE_X_MIN; rx <= L2World.TILE_X_MAX; rx++)
|
||||
{
|
||||
for (int ry = L2World.TILE_Y_MIN; ry <= L2World.TILE_Y_MAX; ry++)
|
||||
{
|
||||
final String input = String.format(_format.getFilename(), rx, ry);
|
||||
final String filepath = Config.GEODATA_PATH;
|
||||
File f = new File(filepath + input);
|
||||
if (f.exists() && !f.isDirectory())
|
||||
{
|
||||
// load geodata
|
||||
if (!loadGeoBlocks(input))
|
||||
{
|
||||
System.out.println("GeoDataConverter: Unable to load " + input + " region file.");
|
||||
continue;
|
||||
}
|
||||
|
||||
// recalculate nswe
|
||||
if (!recalculateNswe())
|
||||
{
|
||||
System.out.println("GeoDataConverter: Unable to convert " + input + " region file.");
|
||||
continue;
|
||||
}
|
||||
|
||||
// save geodata
|
||||
final String output = String.format(GeoFormat.L2D.getFilename(), rx, ry);
|
||||
if (!saveGeoBlocks(output))
|
||||
{
|
||||
System.out.println("GeoDataConverter: Unable to save " + output + " region file.");
|
||||
continue;
|
||||
}
|
||||
|
||||
converted++;
|
||||
System.out.println("GeoDataConverter: Created " + output + " region file.");
|
||||
}
|
||||
}
|
||||
}
|
||||
System.out.println("GeoDataConverter: Converted " + converted + " " + _format + " to L2D region file(s).");
|
||||
|
||||
// release multilayer block temporarily buffer
|
||||
BlockMultilayer.release();
|
||||
}
|
||||
|
||||
/**
|
||||
* Loads geo blocks from buffer of the region file.
|
||||
* @param filename : The name of the to load.
|
||||
* @return boolean : True when successful.
|
||||
*/
|
||||
private static boolean loadGeoBlocks(String filename)
|
||||
{
|
||||
// region file is load-able, try to load it
|
||||
try (RandomAccessFile raf = new RandomAccessFile(Config.GEODATA_PATH + filename, "r");
|
||||
FileChannel fc = raf.getChannel())
|
||||
{
|
||||
MappedByteBuffer buffer = fc.map(FileChannel.MapMode.READ_ONLY, 0, fc.size()).load();
|
||||
buffer.order(ByteOrder.LITTLE_ENDIAN);
|
||||
|
||||
// load 18B header for L2off geodata (1st and 2nd byte...region X and Y)
|
||||
if (_format == GeoFormat.L2OFF)
|
||||
{
|
||||
for (int i = 0; i < 18; i++)
|
||||
{
|
||||
buffer.get();
|
||||
}
|
||||
}
|
||||
|
||||
// loop over region blocks
|
||||
for (int ix = 0; ix < GeoStructure.REGION_BLOCKS_X; ix++)
|
||||
{
|
||||
for (int iy = 0; iy < GeoStructure.REGION_BLOCKS_Y; iy++)
|
||||
{
|
||||
if (_format == GeoFormat.L2J)
|
||||
{
|
||||
// get block type
|
||||
final byte type = buffer.get();
|
||||
|
||||
// load block according to block type
|
||||
switch (type)
|
||||
{
|
||||
case GeoStructure.TYPE_FLAT_L2J_L2OFF:
|
||||
{
|
||||
_blocks[ix][iy] = new BlockFlat(buffer, _format);
|
||||
break;
|
||||
}
|
||||
case GeoStructure.TYPE_COMPLEX_L2J:
|
||||
{
|
||||
_blocks[ix][iy] = new BlockComplex(buffer, _format);
|
||||
break;
|
||||
}
|
||||
case GeoStructure.TYPE_MULTILAYER_L2J:
|
||||
{
|
||||
_blocks[ix][iy] = new BlockMultilayer(buffer, _format);
|
||||
break;
|
||||
}
|
||||
default:
|
||||
{
|
||||
throw new IllegalArgumentException("Unknown block type: " + type);
|
||||
}
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
// get block type
|
||||
final short type = buffer.getShort();
|
||||
|
||||
// load block according to block type
|
||||
switch (type)
|
||||
{
|
||||
case GeoStructure.TYPE_FLAT_L2J_L2OFF:
|
||||
{
|
||||
_blocks[ix][iy] = new BlockFlat(buffer, _format);
|
||||
break;
|
||||
}
|
||||
case GeoStructure.TYPE_COMPLEX_L2OFF:
|
||||
{
|
||||
_blocks[ix][iy] = new BlockComplex(buffer, _format);
|
||||
break;
|
||||
}
|
||||
default:
|
||||
{
|
||||
_blocks[ix][iy] = new BlockMultilayer(buffer, _format);
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if (buffer.remaining() > 0)
|
||||
{
|
||||
System.out.println("GeoDataConverter: Region file " + filename + " can be corrupted, remaining " + buffer.remaining() + " bytes to read.");
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
catch (Exception e)
|
||||
{
|
||||
System.out.println("GeoDataConverter: Error while loading " + filename + " region file.");
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Recalculate diagonal flags for the region file.
|
||||
* @return boolean : True when successful.
|
||||
*/
|
||||
private static boolean recalculateNswe()
|
||||
{
|
||||
try
|
||||
{
|
||||
for (int x = 0; x < GeoStructure.REGION_CELLS_X; x++)
|
||||
{
|
||||
for (int y = 0; y < GeoStructure.REGION_CELLS_Y; y++)
|
||||
{
|
||||
// get block
|
||||
ABlock block = _blocks[x / GeoStructure.BLOCK_CELLS_X][y / GeoStructure.BLOCK_CELLS_Y];
|
||||
|
||||
// skip flat blocks
|
||||
if (block instanceof BlockFlat)
|
||||
{
|
||||
continue;
|
||||
}
|
||||
|
||||
// for complex and multilayer blocks go though all layers
|
||||
short height = Short.MAX_VALUE;
|
||||
int index;
|
||||
while ((index = block.getIndexBelow(x, y, height)) != -1)
|
||||
{
|
||||
// get height and nswe
|
||||
height = block.getHeight(index);
|
||||
byte nswe = block.getNswe(index);
|
||||
|
||||
// update nswe with diagonal flags
|
||||
nswe = updateNsweBelow(x, y, height, nswe);
|
||||
|
||||
// set nswe of the cell
|
||||
block.setNswe(index, nswe);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
catch (Exception e)
|
||||
{
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Updates the NSWE flag with diagonal flags.
|
||||
* @param x : Geodata X coordinate.
|
||||
* @param y : Geodata Y coordinate.
|
||||
* @param z : Geodata Z coordinate.
|
||||
* @param nswe : NSWE flag to be updated.
|
||||
* @return byte : Updated NSWE flag.
|
||||
*/
|
||||
private static byte updateNsweBelow(int x, int y, short z, byte nswe)
|
||||
{
|
||||
// calculate virtual layer height
|
||||
short height = (short) (z + GeoStructure.CELL_IGNORE_HEIGHT);
|
||||
|
||||
// get NSWE of neighbor cells below virtual layer (NPC/PC can fall down of clif, but can not climb it -> NSWE of cell below)
|
||||
byte nsweN = getNsweBelow(x, y - 1, height);
|
||||
byte nsweS = getNsweBelow(x, y + 1, height);
|
||||
byte nsweW = getNsweBelow(x - 1, y, height);
|
||||
byte nsweE = getNsweBelow(x + 1, y, height);
|
||||
|
||||
// north-west
|
||||
if ((((nswe & GeoStructure.CELL_FLAG_N) != 0) && ((nsweN & GeoStructure.CELL_FLAG_W) != 0)) || (((nswe & GeoStructure.CELL_FLAG_W) != 0) && ((nsweW & GeoStructure.CELL_FLAG_N) != 0)))
|
||||
{
|
||||
nswe |= GeoStructure.CELL_FLAG_NW;
|
||||
}
|
||||
|
||||
// north-east
|
||||
if ((((nswe & GeoStructure.CELL_FLAG_N) != 0) && ((nsweN & GeoStructure.CELL_FLAG_E) != 0)) || (((nswe & GeoStructure.CELL_FLAG_E) != 0) && ((nsweE & GeoStructure.CELL_FLAG_N) != 0)))
|
||||
{
|
||||
nswe |= GeoStructure.CELL_FLAG_NE;
|
||||
}
|
||||
|
||||
// south-west
|
||||
if ((((nswe & GeoStructure.CELL_FLAG_S) != 0) && ((nsweS & GeoStructure.CELL_FLAG_W) != 0)) || (((nswe & GeoStructure.CELL_FLAG_W) != 0) && ((nsweW & GeoStructure.CELL_FLAG_S) != 0)))
|
||||
{
|
||||
nswe |= GeoStructure.CELL_FLAG_SW;
|
||||
}
|
||||
|
||||
// south-east
|
||||
if ((((nswe & GeoStructure.CELL_FLAG_S) != 0) && ((nsweS & GeoStructure.CELL_FLAG_E) != 0)) || (((nswe & GeoStructure.CELL_FLAG_E) != 0) && ((nsweE & GeoStructure.CELL_FLAG_S) != 0)))
|
||||
{
|
||||
nswe |= GeoStructure.CELL_FLAG_SE;
|
||||
}
|
||||
|
||||
return nswe;
|
||||
}
|
||||
|
||||
private static byte getNsweBelow(int geoX, int geoY, short worldZ)
|
||||
{
|
||||
// out of geo coordinates
|
||||
if ((geoX < 0) || (geoX >= GeoStructure.REGION_CELLS_X))
|
||||
{
|
||||
return 0;
|
||||
}
|
||||
|
||||
// out of geo coordinates
|
||||
if ((geoY < 0) || (geoY >= GeoStructure.REGION_CELLS_Y))
|
||||
{
|
||||
return 0;
|
||||
}
|
||||
|
||||
// get block
|
||||
final ABlock block = _blocks[geoX / GeoStructure.BLOCK_CELLS_X][geoY / GeoStructure.BLOCK_CELLS_Y];
|
||||
|
||||
// get index, when valid, return nswe
|
||||
final int index = block.getIndexBelow(geoX, geoY, worldZ);
|
||||
return index == -1 ? 0 : block.getNswe(index);
|
||||
}
|
||||
|
||||
/**
|
||||
* Save region file to file.
|
||||
* @param filename : The name of file to save.
|
||||
* @return boolean : True when successful.
|
||||
*/
|
||||
private static boolean saveGeoBlocks(String filename)
|
||||
{
|
||||
try (BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(Config.GEODATA_PATH + filename), GeoStructure.REGION_BLOCKS * GeoStructure.BLOCK_CELLS * 3))
|
||||
{
|
||||
// loop over region blocks and save each block
|
||||
for (int ix = 0; ix < GeoStructure.REGION_BLOCKS_X; ix++)
|
||||
{
|
||||
for (int iy = 0; iy < GeoStructure.REGION_BLOCKS_Y; iy++)
|
||||
{
|
||||
_blocks[ix][iy].saveBlock(bos);
|
||||
}
|
||||
}
|
||||
|
||||
// flush data to file
|
||||
bos.flush();
|
||||
|
||||
return true;
|
||||
}
|
||||
catch (Exception e)
|
||||
{
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
private static void loadGeoengineConfigs()
|
||||
{
|
||||
final PropertiesParser geoData = new PropertiesParser(Config.GEOENGINE_CONFIG_FILE);
|
||||
Config.GEODATA_PATH = geoData.getString("GeoDataPath", "./data/geodata/");
|
||||
Config.COORD_SYNCHRONIZE = geoData.getInt("CoordSynchronize", -1);
|
||||
Config.PART_OF_CHARACTER_HEIGHT = geoData.getInt("PartOfCharacterHeight", 75);
|
||||
Config.MAX_OBSTACLE_HEIGHT = geoData.getInt("MaxObstacleHeight", 32);
|
||||
Config.PATHFINDING = geoData.getBoolean("PathFinding", true);
|
||||
Config.PATHFIND_BUFFERS = geoData.getString("PathFindBuffers", "100x6;128x6;192x6;256x4;320x4;384x4;500x2");
|
||||
Config.BASE_WEIGHT = geoData.getInt("BaseWeight", 10);
|
||||
Config.DIAGONAL_WEIGHT = geoData.getInt("DiagonalWeight", 14);
|
||||
Config.OBSTACLE_MULTIPLIER = geoData.getInt("ObstacleMultiplier", 10);
|
||||
Config.HEURISTIC_WEIGHT = geoData.getInt("HeuristicWeight", 20);
|
||||
Config.MAX_ITERATIONS = geoData.getInt("MaxIterations", 3500);
|
||||
}
|
||||
}
|
@ -0,0 +1,487 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.gsregistering;
|
||||
|
||||
import java.awt.HeadlessException;
|
||||
import java.io.File;
|
||||
import java.io.FileOutputStream;
|
||||
import java.io.IOException;
|
||||
import java.io.OutputStream;
|
||||
import java.math.BigInteger;
|
||||
import java.sql.Connection;
|
||||
import java.sql.PreparedStatement;
|
||||
import java.sql.SQLException;
|
||||
import java.sql.Statement;
|
||||
import java.util.Map.Entry;
|
||||
import java.util.Properties;
|
||||
import java.util.ResourceBundle;
|
||||
|
||||
import com.l2jmobius.Config;
|
||||
import com.l2jmobius.Server;
|
||||
import com.l2jmobius.commons.database.DatabaseFactory;
|
||||
import com.l2jmobius.commons.util.CommonUtil;
|
||||
import com.l2jmobius.loginserver.GameServerTable;
|
||||
|
||||
/**
|
||||
* The Class BaseGameServerRegister.
|
||||
* @author KenM
|
||||
*/
|
||||
public abstract class BaseGameServerRegister
|
||||
{
|
||||
private boolean _loaded = false;
|
||||
|
||||
/**
|
||||
* The main method.
|
||||
* @param args the arguments
|
||||
*/
|
||||
public static void main(String[] args)
|
||||
{
|
||||
boolean interactive = true;
|
||||
boolean force = false;
|
||||
boolean fallback = false;
|
||||
BaseTask task = null;
|
||||
|
||||
String arg;
|
||||
for (int i = 0; i < args.length; i++)
|
||||
{
|
||||
arg = args[i];
|
||||
|
||||
// --force : Forces GameServer register operations to overwrite a server if necessary
|
||||
if (arg.equals("-f") || arg.equals("--force"))
|
||||
{
|
||||
force = true;
|
||||
}
|
||||
// --fallback : If an register operation fails due to ID already being in use it will then try to register first available ID
|
||||
else if (arg.equals("-b") || arg.equals("--fallback"))
|
||||
{
|
||||
fallback = true;
|
||||
}
|
||||
// --register <id> <hexid_dest_dir> : Register GameServer with ID <id> and output hexid on <hexid_dest_dir>
|
||||
// Fails if <id> already in use, unless -force is used (overwrites)
|
||||
else if (arg.equals("-r") || arg.equals("--register"))
|
||||
{
|
||||
interactive = false;
|
||||
final int id = Integer.parseInt(args[++i]);
|
||||
final String dir = args[++i];
|
||||
|
||||
task = new RegisterTask(id, dir, force, fallback);
|
||||
}
|
||||
// --unregister <id> : Removes GameServer denoted by <id>
|
||||
else if (arg.equals("-u") || arg.equals("--unregister"))
|
||||
{
|
||||
interactive = false;
|
||||
final String gsId = args[++i];
|
||||
if (gsId.equalsIgnoreCase("all"))
|
||||
{
|
||||
task = new UnregisterAllTask();
|
||||
}
|
||||
else
|
||||
{
|
||||
try
|
||||
{
|
||||
final int id = Integer.parseInt(gsId);
|
||||
task = new UnregisterTask(id);
|
||||
}
|
||||
catch (NumberFormatException e)
|
||||
{
|
||||
System.out.printf("wrong argument for GameServer removal, specify a numeric ID or \"all\" without quotes to remove all." + Config.EOL, gsId);
|
||||
System.exit(1);
|
||||
}
|
||||
}
|
||||
}
|
||||
// --help : Prints usage/arguments/credits
|
||||
else if (arg.equals("-h") || arg.equals("--help"))
|
||||
{
|
||||
interactive = false;
|
||||
|
||||
printHelp();
|
||||
}
|
||||
}
|
||||
|
||||
try
|
||||
{
|
||||
if (interactive)
|
||||
{
|
||||
startCMD();
|
||||
}
|
||||
else
|
||||
{
|
||||
// if there is a task, do it, else the app has already finished
|
||||
if (task != null)
|
||||
{
|
||||
task.run();
|
||||
}
|
||||
}
|
||||
}
|
||||
catch (HeadlessException e)
|
||||
{
|
||||
startCMD();
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Prints the help.
|
||||
*/
|
||||
private static void printHelp()
|
||||
{
|
||||
final String[] help =
|
||||
{
|
||||
"Allows to register/remove GameServers from LoginServer.",
|
||||
"",
|
||||
"Options:",
|
||||
"-b, --fallback\t\t\t\tIf during the register operation the specified GameServer ID is in use, an attempt with the first available ID will be made.",
|
||||
"-c, --cmd\t\t\t\tForces this application to run in console mode, even if GUI is supported.",
|
||||
"-f, --force\t\t\t\tForces GameServer register operation to overwrite a previous registration on the specified ID, if necessary.",
|
||||
"-h, --help\t\t\t\tShows this help message and exits.",
|
||||
"-r, --register <id> <hexid_dest_dir>\tRegisters a GameServer on ID <id> and saves the hexid.txt file on <hexid_dest_dir>.",
|
||||
"\t\t\t\t\tYou can provide a negative value for <id> to register under the first available ID.",
|
||||
"\t\t\t\t\tNothing is done if <id> is already in use, unless --force or --fallback is used.",
|
||||
"",
|
||||
"-u, --unregister <id>|all\t\tRemoves the GameServer specified by <id>, use \"all\" to remove all currently registered GameServers.",
|
||||
"",
|
||||
"© 2008-2009 L2J Team. All rights reserved.",
|
||||
"Bug Reports: http://www.l2jserver.com"
|
||||
};
|
||||
|
||||
for (String str : help)
|
||||
{
|
||||
System.out.println(str);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Start the CMD.
|
||||
*/
|
||||
private static void startCMD()
|
||||
{
|
||||
final GameServerRegister cmdUi = new GameServerRegister();
|
||||
try
|
||||
{
|
||||
cmdUi.consoleUI();
|
||||
}
|
||||
catch (IOException e)
|
||||
{
|
||||
cmdUi.showError("I/O exception trying to get input from keyboard.", e);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Load.
|
||||
*/
|
||||
public void load()
|
||||
{
|
||||
Server.serverMode = Server.MODE_LOGINSERVER;
|
||||
|
||||
Config.load();
|
||||
DatabaseFactory.init();
|
||||
GameServerTable.getInstance();
|
||||
|
||||
_loaded = true;
|
||||
}
|
||||
|
||||
/**
|
||||
* Checks if is loaded.
|
||||
* @return true, if is loaded
|
||||
*/
|
||||
public boolean isLoaded()
|
||||
{
|
||||
return _loaded;
|
||||
}
|
||||
|
||||
/**
|
||||
* Show the error.
|
||||
* @param msg the msg.
|
||||
* @param t the t.
|
||||
*/
|
||||
public abstract void showError(String msg, Throwable t);
|
||||
|
||||
/**
|
||||
* Unregister the game server.
|
||||
* @param id the game server id.
|
||||
* @throws SQLException the SQL exception.
|
||||
*/
|
||||
public static void unregisterGameServer(int id) throws SQLException
|
||||
{
|
||||
try (Connection con = DatabaseFactory.getConnection();
|
||||
PreparedStatement ps = con.prepareStatement("DELETE FROM gameservers WHERE server_id = ?"))
|
||||
|
||||
{
|
||||
ps.setInt(1, id);
|
||||
ps.executeUpdate();
|
||||
}
|
||||
GameServerTable.getInstance().getRegisteredGameServers().remove(id);
|
||||
}
|
||||
|
||||
/**
|
||||
* Unregister all game servers.
|
||||
* @throws SQLException the SQL exception
|
||||
*/
|
||||
public static void unregisterAllGameServers() throws SQLException
|
||||
{
|
||||
try (Connection con = DatabaseFactory.getConnection();
|
||||
Statement s = con.createStatement())
|
||||
{
|
||||
s.executeUpdate("DELETE FROM gameservers");
|
||||
}
|
||||
GameServerTable.getInstance().getRegisteredGameServers().clear();
|
||||
}
|
||||
|
||||
/**
|
||||
* Register a game server.
|
||||
* @param id the id of the game server.
|
||||
* @param outDir the out dir.
|
||||
* @throws IOException Signals that an I/O exception has occurred.
|
||||
*/
|
||||
public static void registerGameServer(int id, String outDir) throws IOException
|
||||
{
|
||||
final byte[] hexId = CommonUtil.generateHex(16);
|
||||
GameServerTable.getInstance().registerServerOnDB(hexId, id, "");
|
||||
|
||||
final Properties hexSetting = new Properties();
|
||||
final File file = new File(outDir, "hexid.txt");
|
||||
// Create a new empty file only if it doesn't exist
|
||||
file.createNewFile();
|
||||
try (OutputStream out = new FileOutputStream(file))
|
||||
{
|
||||
hexSetting.setProperty("ServerID", String.valueOf(id));
|
||||
hexSetting.setProperty("HexID", new BigInteger(hexId).toString(16));
|
||||
hexSetting.store(out, "The HexId to Auth into LoginServer");
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Register first available.
|
||||
* @param outDir the out dir
|
||||
* @return the int
|
||||
* @throws IOException Signals that an I/O exception has occurred.
|
||||
*/
|
||||
public static int registerFirstAvailable(String outDir) throws IOException
|
||||
{
|
||||
for (Entry<Integer, String> e : GameServerTable.getInstance().getServerNames().entrySet())
|
||||
{
|
||||
if (!GameServerTable.getInstance().hasRegisteredGameServerOnId(e.getKey()))
|
||||
{
|
||||
registerGameServer(e.getKey(), outDir);
|
||||
return e.getKey();
|
||||
}
|
||||
}
|
||||
return -1;
|
||||
}
|
||||
|
||||
/**
|
||||
* The Class BaseTask.
|
||||
*/
|
||||
protected static abstract class BaseTask implements Runnable
|
||||
{
|
||||
protected ResourceBundle _bundle;
|
||||
|
||||
/**
|
||||
* Sets the bundle.
|
||||
* @param bundle The bundle to set.
|
||||
*/
|
||||
public void setBundle(ResourceBundle bundle)
|
||||
{
|
||||
_bundle = bundle;
|
||||
}
|
||||
|
||||
/**
|
||||
* Gets the bundle.
|
||||
* @return Returns the bundle.
|
||||
*/
|
||||
public ResourceBundle getBundle()
|
||||
{
|
||||
return _bundle;
|
||||
}
|
||||
|
||||
/**
|
||||
* Show the error.
|
||||
* @param msg the msg
|
||||
* @param t the t
|
||||
*/
|
||||
public void showError(String msg, Throwable t)
|
||||
{
|
||||
String title;
|
||||
if (_bundle != null)
|
||||
{
|
||||
title = _bundle.getString("error");
|
||||
msg += Config.EOL + _bundle.getString("reason") + ' ' + t.getLocalizedMessage();
|
||||
}
|
||||
else
|
||||
{
|
||||
title = "Error";
|
||||
msg += Config.EOL + "Cause: " + t.getLocalizedMessage();
|
||||
}
|
||||
System.out.println(title + ": " + msg);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* The Class RegisterTask.
|
||||
*/
|
||||
private static class RegisterTask extends BaseTask
|
||||
{
|
||||
private final int _id;
|
||||
private final String _outDir;
|
||||
private boolean _force;
|
||||
private boolean _fallback;
|
||||
|
||||
/**
|
||||
* Instantiates a new register task.
|
||||
* @param id the id.
|
||||
* @param outDir the out dir.
|
||||
* @param force the force.
|
||||
* @param fallback the fallback.
|
||||
*/
|
||||
public RegisterTask(int id, String outDir, boolean force, boolean fallback)
|
||||
{
|
||||
_id = id;
|
||||
_outDir = outDir;
|
||||
_force = force;
|
||||
_fallback = fallback;
|
||||
}
|
||||
|
||||
/**
|
||||
* Sets the actions.
|
||||
* @param force the force.
|
||||
* @param fallback the fallback.
|
||||
*/
|
||||
@SuppressWarnings("unused")
|
||||
public void setActions(boolean force, boolean fallback)
|
||||
{
|
||||
_force = force;
|
||||
_fallback = fallback;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void run()
|
||||
{
|
||||
try
|
||||
{
|
||||
if (_id < 0)
|
||||
{
|
||||
final int registeredId = registerFirstAvailable(_outDir);
|
||||
|
||||
if (registeredId < 0)
|
||||
{
|
||||
System.out.println(_bundle.getString("noFreeId"));
|
||||
}
|
||||
else
|
||||
{
|
||||
System.out.printf(_bundle.getString("registrationOk") + Config.EOL, registeredId);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
System.out.printf(_bundle.getString("checkingIdInUse") + Config.EOL, _id);
|
||||
if (GameServerTable.getInstance().hasRegisteredGameServerOnId(_id))
|
||||
{
|
||||
System.out.println(_bundle.getString("yes"));
|
||||
if (_force)
|
||||
{
|
||||
System.out.printf(_bundle.getString("forcingRegistration") + Config.EOL, _id);
|
||||
unregisterGameServer(_id);
|
||||
registerGameServer(_id, _outDir);
|
||||
System.out.printf(_bundle.getString("registrationOk") + Config.EOL, _id);
|
||||
}
|
||||
else if (_fallback)
|
||||
{
|
||||
System.out.println(_bundle.getString("fallingBack"));
|
||||
final int registeredId = registerFirstAvailable(_outDir);
|
||||
|
||||
if (registeredId < 0)
|
||||
{
|
||||
System.out.println(_bundle.getString("noFreeId"));
|
||||
}
|
||||
else
|
||||
{
|
||||
System.out.printf(_bundle.getString("registrationOk") + Config.EOL, registeredId);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
System.out.println(_bundle.getString("noAction"));
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
System.out.println(_bundle.getString("no"));
|
||||
registerGameServer(_id, _outDir);
|
||||
}
|
||||
}
|
||||
}
|
||||
catch (SQLException e)
|
||||
{
|
||||
showError(_bundle.getString("sqlErrorRegister"), e);
|
||||
}
|
||||
catch (IOException e)
|
||||
{
|
||||
showError(_bundle.getString("ioErrorRegister"), e);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* The Class UnregisterTask.
|
||||
*/
|
||||
private static class UnregisterTask extends BaseTask
|
||||
{
|
||||
private final int _id;
|
||||
|
||||
/**
|
||||
* Instantiates a new unregister task.
|
||||
* @param id the task id.
|
||||
*/
|
||||
public UnregisterTask(int id)
|
||||
{
|
||||
_id = id;
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void run()
|
||||
{
|
||||
System.out.printf(_bundle.getString("removingGsId") + Config.EOL, _id);
|
||||
try
|
||||
{
|
||||
unregisterGameServer(_id);
|
||||
}
|
||||
catch (SQLException e)
|
||||
{
|
||||
showError(_bundle.getString("sqlErrorRegister"), e);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* The Class UnregisterAllTask.
|
||||
*/
|
||||
protected static class UnregisterAllTask extends BaseTask
|
||||
{
|
||||
@Override
|
||||
public void run()
|
||||
{
|
||||
try
|
||||
{
|
||||
unregisterAllGameServers();
|
||||
}
|
||||
catch (SQLException e)
|
||||
{
|
||||
showError(_bundle.getString("sqlErrorUnregisterAll"), e);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
@ -0,0 +1,326 @@
|
||||
/*
|
||||
* This file is part of the L2J Mobius project.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
* General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
package com.l2jmobius.tools.gsregistering;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStreamReader;
|
||||
import java.io.LineNumberReader;
|
||||
import java.sql.SQLException;
|
||||
import java.util.Map.Entry;
|
||||
|
||||
import com.l2jmobius.Config;
|
||||
import com.l2jmobius.loginserver.GameServerTable;
|
||||
|
||||
public class GameServerRegister extends BaseGameServerRegister
|
||||
{
|
||||
private LineNumberReader _in;
|
||||
|
||||
public static void main(String[] args)
|
||||
{
|
||||
// Backwards compatibility, redirect to the new one
|
||||
BaseGameServerRegister.main(args);
|
||||
}
|
||||
|
||||
public GameServerRegister()
|
||||
{
|
||||
load();
|
||||
|
||||
if (GameServerTable.getInstance().getServerNames().isEmpty())
|
||||
{
|
||||
System.out.println("No available names for GameServer, verify servername.xml file exists in the LoginServer folder.");
|
||||
System.exit(1);
|
||||
}
|
||||
}
|
||||
|
||||
public void consoleUI() throws IOException
|
||||
{
|
||||
_in = new LineNumberReader(new InputStreamReader(System.in));
|
||||
boolean choiceOk = false;
|
||||
String choice;
|
||||
|
||||
while (true)
|
||||
{
|
||||
hr();
|
||||
System.out.println("GSRegister");
|
||||
System.out.println(Config.EOL);
|
||||
System.out.println("1 - Register GameServer");
|
||||
System.out.println("2 - List GameServers Names and IDs");
|
||||
System.out.println("3 - Remove GameServer");
|
||||
System.out.println("4 - Remove ALL GameServers");
|
||||
System.out.println("5 - Exit");
|
||||
|
||||
do
|
||||
{
|
||||
System.out.print("Choice: ");
|
||||
choice = _in.readLine();
|
||||
try
|
||||
{
|
||||
final int choiceNumber = Integer.parseInt(choice);
|
||||
choiceOk = true;
|
||||
|
||||
switch (choiceNumber)
|
||||
{
|
||||
case 1:
|
||||
{
|
||||
registerNewGS();
|
||||
break;
|
||||
}
|
||||
case 2:
|
||||
{
|
||||
listGSNames();
|
||||
break;
|
||||
}
|
||||
case 3:
|
||||
{
|
||||
unregisterSingleGS();
|
||||
break;
|
||||
}
|
||||
case 4:
|
||||
{
|
||||
unregisterAllGS();
|
||||
break;
|
||||
}
|
||||
case 5:
|
||||
{
|
||||
System.exit(0);
|
||||
break;
|
||||
}
|
||||
default:
|
||||
{
|
||||
System.out.printf("Invalid Choice: %s" + Config.EOL, choice);
|
||||
choiceOk = false;
|
||||
}
|
||||
}
|
||||
}
|
||||
catch (NumberFormatException nfe)
|
||||
{
|
||||
System.out.printf("Invalid Choice: %s" + Config.EOL, choice);
|
||||
}
|
||||
}
|
||||
while (!choiceOk);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private void hr()
|
||||
{
|
||||
System.out.println("_____________________________________________________" + Config.EOL);
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private void listGSNames()
|
||||
{
|
||||
int idMaxLen = 0;
|
||||
int nameMaxLen = 0;
|
||||
for (Entry<Integer, String> e : GameServerTable.getInstance().getServerNames().entrySet())
|
||||
{
|
||||
if (e.getKey().toString().length() > idMaxLen)
|
||||
{
|
||||
idMaxLen = e.getKey().toString().length();
|
||||
}
|
||||
if (e.getValue().length() > nameMaxLen)
|
||||
{
|
||||
nameMaxLen = e.getValue().length();
|
||||
}
|
||||
}
|
||||
idMaxLen += 2;
|
||||
nameMaxLen += 2;
|
||||
|
||||
String id;
|
||||
boolean inUse;
|
||||
final String gsInUse = "In Use";
|
||||
final String gsFree = "Free";
|
||||
final int gsStatusMaxLen = Math.max(gsInUse.length(), gsFree.length()) + 2;
|
||||
for (Entry<Integer, String> e : GameServerTable.getInstance().getServerNames().entrySet())
|
||||
{
|
||||
id = e.getKey().toString();
|
||||
System.out.print(id);
|
||||
|
||||
for (int i = id.length(); i < idMaxLen; i++)
|
||||
{
|
||||
System.out.print(' ');
|
||||
}
|
||||
System.out.print("| ");
|
||||
|
||||
System.out.print(e.getValue());
|
||||
|
||||
for (int i = e.getValue().length(); i < nameMaxLen; i++)
|
||||
{
|
||||
System.out.print(' ');
|
||||
}
|
||||
System.out.print("| ");
|
||||
|
||||
inUse = GameServerTable.getInstance().hasRegisteredGameServerOnId(e.getKey());
|
||||
final String inUseStr = inUse ? gsInUse : gsFree;
|
||||
System.out.print(inUseStr);
|
||||
|
||||
for (int i = inUseStr.length(); i < gsStatusMaxLen; i++)
|
||||
{
|
||||
System.out.print(' ');
|
||||
}
|
||||
System.out.println('|');
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* @throws IOException
|
||||
*/
|
||||
private void unregisterAllGS() throws IOException
|
||||
{
|
||||
if (yesNoQuestion("Are you sure you want to remove ALL GameServers?"))
|
||||
{
|
||||
try
|
||||
{
|
||||
BaseGameServerRegister.unregisterAllGameServers();
|
||||
System.out.println("All GameServers were successfully removed.");
|
||||
}
|
||||
catch (SQLException e)
|
||||
{
|
||||
showError("An SQL error occurred while trying to remove ALL GameServers.", e);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private boolean yesNoQuestion(String question) throws IOException
|
||||
{
|
||||
do
|
||||
{
|
||||
hr();
|
||||
System.out.println(question);
|
||||
System.out.println("1 - Yes");
|
||||
System.out.println("2 - No");
|
||||
System.out.print("Choice: ");
|
||||
String choice;
|
||||
choice = _in.readLine();
|
||||
if (choice != null)
|
||||
{
|
||||
if (choice.equals("1"))
|
||||
{
|
||||
return true;
|
||||
}
|
||||
else if (choice.equals("2"))
|
||||
{
|
||||
return false;
|
||||
}
|
||||
else
|
||||
{
|
||||
System.out.printf("Invalid Choice: %s" + Config.EOL, choice);
|
||||
}
|
||||
}
|
||||
}
|
||||
while (true);
|
||||
}
|
||||
|
||||
/**
|
||||
* @throws IOException
|
||||
*/
|
||||
private void unregisterSingleGS() throws IOException
|
||||
{
|
||||
String line;
|
||||
int id = Integer.MIN_VALUE;
|
||||
|
||||
do
|
||||
{
|
||||
System.out.print("Enter desired ID: ");
|
||||
line = _in.readLine();
|
||||
try
|
||||
{
|
||||
id = Integer.parseInt(line);
|
||||
}
|
||||
catch (NumberFormatException e)
|
||||
{
|
||||
System.out.printf("Invalid Choice: %s" + Config.EOL, line);
|
||||
}
|
||||
}
|
||||
while (id == Integer.MIN_VALUE);
|
||||
|
||||
final String name = GameServerTable.getInstance().getServerNameById(id);
|
||||
if (name == null)
|
||||
{
|
||||
System.out.printf("No name for ID: %d" + Config.EOL, id);
|
||||
}
|
||||
else if (GameServerTable.getInstance().hasRegisteredGameServerOnId(id))
|
||||
{
|
||||
System.out.printf("Are you sure you want to remove GameServer %d - %s?" + Config.EOL, id, name);
|
||||
try
|
||||
{
|
||||
BaseGameServerRegister.unregisterGameServer(id);
|
||||
System.out.printf("GameServer ID: %d was successfully removed from LoginServer." + Config.EOL, id);
|
||||
}
|
||||
catch (SQLException e)
|
||||
{
|
||||
showError("An SQL error occurred while trying to remove the GameServer.", e);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
System.out.printf("No GameServer is registered on ID: %d" + Config.EOL, id);
|
||||
}
|
||||
}
|
||||
|
||||
private void registerNewGS() throws IOException
|
||||
{
|
||||
String line;
|
||||
int id = Integer.MIN_VALUE;
|
||||
|
||||
do
|
||||
{
|
||||
System.out.println("Enter desired ID:");
|
||||
line = _in.readLine();
|
||||
try
|
||||
{
|
||||
id = Integer.parseInt(line);
|
||||
}
|
||||
catch (NumberFormatException e)
|
||||
{
|
||||
System.out.printf("Invalid Choice: %s" + Config.EOL, line);
|
||||
}
|
||||
}
|
||||
while (id == Integer.MIN_VALUE);
|
||||
|
||||
if (GameServerTable.getInstance().getServerNameById(id) == null)
|
||||
{
|
||||
System.out.printf("No name for ID: %d" + Config.EOL, id);
|
||||
}
|
||||
else if (GameServerTable.getInstance().hasRegisteredGameServerOnId(id))
|
||||
{
|
||||
System.out.println("This ID is not available.");
|
||||
}
|
||||
else
|
||||
{
|
||||
try
|
||||
{
|
||||
BaseGameServerRegister.registerGameServer(id, ".");
|
||||
}
|
||||
catch (IOException e)
|
||||
{
|
||||
showError("An error saving the hexid file occurred while trying to register the GameServer.", e);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void showError(String msg, Throwable t)
|
||||
{
|
||||
msg += Config.EOL + "Reason: " + t.getMessage();
|
||||
System.out.println("Error: " + msg);
|
||||
}
|
||||
}
|
Reference in New Issue
Block a user