Jump to content
  • 0

Database


papuna

Question

hello maxcheaters community

Players and developers i want to ask you about database save.

is any program which can keep my database? for example in every 5 or 10 min?

 

sorry if there is topic like this, i can not find it  :-* :-*

Link to comment
Share on other sites

10 answers to this question

Recommended Posts

  • 0

yes yes

 

addytzu have you skype ???

Yes, I have

 

You could to make a task, this is only for shutdown/restart

Index: l2jfree-core/config/options.properties
===================================================================
--- l2jfree-core/config/options.properties	(revision 8052)
+++ l2jfree-core/config/options.properties	(working copy)
@@ -400,3 +400,6 @@

# Whether to optimize tables each time server is launched
OptimizeDatabaseTables = True
+
+# Whether to dump tables each time server is launched and shutdown
+DumpDatabaseTables = True
\ No newline at end of file
Index: l2jfree-core/src/main/java/com/l2jfree/Config.java
===================================================================
--- l2jfree-core/src/main/java/com/l2jfree/Config.java	(revision 8052)
+++ l2jfree-core/src/main/java/com/l2jfree/Config.java	(working copy)
@@ -1254,6 +1254,7 @@
	public static int				RETARGET_BLOCKING_PERIOD;

	public static boolean			OPTIMIZE_DATABASE;
+    public static boolean			DUMP_DATABASE;

	// *******************************************************************************************
	private static final class OptionsConfig extends ConfigLoader
@@ -1465,6 +1466,7 @@
		    RETARGET_BLOCKING_PERIOD = Integer.parseInt(optionsSettings.getProperty("CannotRetargetFor", "400"));

		    OPTIMIZE_DATABASE = Boolean.parseBoolean(optionsSettings.getProperty("OptimizeDatabaseTables", "True"));
+            DUMP_DATABASE = Boolean.parseBoolean(optionsSettings.getProperty("DumpDatabaseTables", "True"));
		}
	}

Index: l2jfree-core/src/main/java/com/l2jfree/gameserver/GameServer.java
===================================================================
--- l2jfree-core/src/main/java/com/l2jfree/gameserver/GameServer.java	(revision 8052)
+++ l2jfree-core/src/main/java/com/l2jfree/gameserver/GameServer.java	(working copy)
@@ -20,6 +20,7 @@
import java.util.HashSet;
import java.util.Set;

+import com.l2jfree.gameserver.util.TableDumper;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

@@ -190,6 +191,8 @@
		_log.info("IdFactory: Free ObjectID's remaining: " + IdFactory.getInstance().size());
		if (Config.OPTIMIZE_DATABASE)
			TableOptimizer.optimize();
+        if (Config.DUMP_DATABASE)
+            TableDumper.saveDB();
		Class.forName(RunnableStatsManager.class.getName());
		ThreadPoolManager.getInstance();
		if (Config.DEADLOCKCHECK_INTERVAL > 0)
Index: l2jfree-core/src/main/java/com/l2jfree/gameserver/Shutdown.java
===================================================================
--- l2jfree-core/src/main/java/com/l2jfree/gameserver/Shutdown.java	(revision 8052)
+++ l2jfree-core/src/main/java/com/l2jfree/gameserver/Shutdown.java	(working copy)
@@ -14,6 +14,7 @@
 */
package com.l2jfree.gameserver;

+import com.l2jfree.gameserver.util.TableDumper;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

@@ -220,7 +221,10 @@

		SQLQueue.getInstance().run();
		System.out.println("Data saved. All players disconnected, " + _mode.getText() + ".");
-		
+
+        if (Config.DUMP_DATABASE)
+            TableDumper.saveDB();
+
		try
		{
			Thread.sleep(1000);
Index: l2jfree-core/src/main/java/com/l2jfree/gameserver/util/TableDumper.java
===================================================================
--- l2jfree-core/src/main/java/com/l2jfree/gameserver/util/TableDumper.java	(revision 0)
+++ l2jfree-core/src/main/java/com/l2jfree/gameserver/util/TableDumper.java	(revision 0)
@@ -0,0 +1,129 @@
+/*
+ * 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.l2jfree.gameserver.util;
+
+import java.io.File;
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.Statement;
+import java.util.ArrayList;
+
+import com.l2jfree.Config;
+import org.apache.commons.lang.StringUtils;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+import com.l2jfree.L2DatabaseFactory;
+
+public final class TableDumper
+{
+	private static final Log _log = LogFactory.getLog(TableDumper.class);
+	
+	public static void saveDB()
+	{
+		Connection con = null;
+		try
+		{
+			con = L2DatabaseFactory.getInstance().getConnection();
+			Statement st = con.createStatement();
+			
+			final ArrayList<String> tables = new ArrayList<String>();
+			{
+				ResultSet rs = st.executeQuery("SHOW FULL TABLES");
+				while (rs.next())
+				{
+					String tableType = rs.getString(2/*"Table_type"*/);
+					
+					if (tableType.equals("VIEW"))
+						continue;
+					
+					tables.add(rs.getString(1));
+				}
+				rs.close();
+			}
+			
+			{
+				ResultSet rs = st.executeQuery("CHECK TABLE " + StringUtils.join(tables, ","));
+				while (rs.next())
+				{
+					String table = rs.getString("Table");
+					String msgType = rs.getString("Msg_type");
+					String msgText = rs.getString("Msg_text");
+					
+					if (msgType.equals("status"))
+						if (msgText.equals("OK"))
+							continue;
+					
+					_log.warn("TableSaver: CHECK TABLE " + table + ": " + msgType + " -> " + msgText);
+				}
+				rs.close();
+				
+				_log.info("TableSaver: Database tables have been checked.");
+			}
+			
+			{
+				ResultSet rs = st.executeQuery("ANALYZE TABLE " + StringUtils.join(tables, ","));
+				while (rs.next())
+				{
+					String table = rs.getString("Table");
+					String msgType = rs.getString("Msg_type");
+					String msgText = rs.getString("Msg_text");
+					
+					if (msgType.equals("status"))
+						if (msgText.equals("OK") || msgText.equals("Table is already up to date"))
+							continue;
+					
+					_log.warn("TableSaver: ANALYZE TABLE " + table + ": " + msgType + " -> " + msgText);
+				}
+				rs.close();
+				
+				_log.info("TableSaver: Database tables have been analyzed.");
+			}
+			
+			{
+                File DirDump = new File(Config.DATAPACK_ROOT, "dump/");
+				ResultSet rs = st.executeQuery("SELECT * FROM " + StringUtils.join(tables, ",") + " INTO DUMPFILE '" + DirDump + "'");
+				while (rs.next())
+				{
+					String table = rs.getString("Table");
+					String msgType = rs.getString("Msg_type");
+					String msgText = rs.getString("Msg_text");
+					
+					if (msgType.equals("status"))
+						if (msgText.equals("OK") || msgText.equals("Table is already up to date"))
+							continue;
+					
+					if (msgType.equals("note"))
+						if (msgText.equals("Table does not support dump, doing recreate + analyze instead"))
+							continue;
+					
+					_log.warn("TableSaver: Create dump " + table + ": " + msgType + " -> " + msgText);
+				}
+				rs.close();
+				
+				_log.info("TableSaver: Database tables have been dumped.");
+			}
+			st.close();
+		}
+		catch (Exception e)
+		{
+			_log.warn("TableSaver: Cannot dump database tables!", e);
+		}
+		finally
+		{
+			L2DatabaseFactory.close(con);
+		}
+	}
+}

Link to comment
Share on other sites

  • 0

Yes, I have

 

You could to make a task, this is only for shutdown/restart

Index: l2jfree-core/config/options.properties
===================================================================
--- l2jfree-core/config/options.properties	(revision 8052)
+++ l2jfree-core/config/options.properties	(working copy)
@@ -400,3 +400,6 @@

# Whether to optimize tables each time server is launched
OptimizeDatabaseTables = True
+
+# Whether to dump tables each time server is launched and shutdown
+DumpDatabaseTables = True
\ No newline at end of file
Index: l2jfree-core/src/main/java/com/l2jfree/Config.java
===================================================================
--- l2jfree-core/src/main/java/com/l2jfree/Config.java	(revision 8052)
+++ l2jfree-core/src/main/java/com/l2jfree/Config.java	(working copy)
@@ -1254,6 +1254,7 @@
	public static int				RETARGET_BLOCKING_PERIOD;

	public static boolean			OPTIMIZE_DATABASE;
+    public static boolean			DUMP_DATABASE;

	// *******************************************************************************************
	private static final class OptionsConfig extends ConfigLoader
@@ -1465,6 +1466,7 @@
		    RETARGET_BLOCKING_PERIOD = Integer.parseInt(optionsSettings.getProperty("CannotRetargetFor", "400"));

		    OPTIMIZE_DATABASE = Boolean.parseBoolean(optionsSettings.getProperty("OptimizeDatabaseTables", "True"));
+            DUMP_DATABASE = Boolean.parseBoolean(optionsSettings.getProperty("DumpDatabaseTables", "True"));
		}
	}

Index: l2jfree-core/src/main/java/com/l2jfree/gameserver/GameServer.java
===================================================================
--- l2jfree-core/src/main/java/com/l2jfree/gameserver/GameServer.java	(revision 8052)
+++ l2jfree-core/src/main/java/com/l2jfree/gameserver/GameServer.java	(working copy)
@@ -20,6 +20,7 @@
import java.util.HashSet;
import java.util.Set;

+import com.l2jfree.gameserver.util.TableDumper;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

@@ -190,6 +191,8 @@
		_log.info("IdFactory: Free ObjectID's remaining: " + IdFactory.getInstance().size());
		if (Config.OPTIMIZE_DATABASE)
			TableOptimizer.optimize();
+        if (Config.DUMP_DATABASE)
+            TableDumper.saveDB();
		Class.forName(RunnableStatsManager.class.getName());
		ThreadPoolManager.getInstance();
		if (Config.DEADLOCKCHECK_INTERVAL > 0)
Index: l2jfree-core/src/main/java/com/l2jfree/gameserver/Shutdown.java
===================================================================
--- l2jfree-core/src/main/java/com/l2jfree/gameserver/Shutdown.java	(revision 8052)
+++ l2jfree-core/src/main/java/com/l2jfree/gameserver/Shutdown.java	(working copy)
@@ -14,6 +14,7 @@
  */
package com.l2jfree.gameserver;

+import com.l2jfree.gameserver.util.TableDumper;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

@@ -220,7 +221,10 @@

		SQLQueue.getInstance().run();
		System.out.println("Data saved. All players disconnected, " + _mode.getText() + ".");
-		
+
+        if (Config.DUMP_DATABASE)
+            TableDumper.saveDB();
+
		try
		{
			Thread.sleep(1000);
Index: l2jfree-core/src/main/java/com/l2jfree/gameserver/util/TableDumper.java
===================================================================
--- l2jfree-core/src/main/java/com/l2jfree/gameserver/util/TableDumper.java	(revision 0)
+++ l2jfree-core/src/main/java/com/l2jfree/gameserver/util/TableDumper.java	(revision 0)
@@ -0,0 +1,129 @@
+/*
+ * 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.l2jfree.gameserver.util;
+
+import java.io.File;
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.Statement;
+import java.util.ArrayList;
+
+import com.l2jfree.Config;
+import org.apache.commons.lang.StringUtils;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+import com.l2jfree.L2DatabaseFactory;
+
+public final class TableDumper
+{
+	private static final Log _log = LogFactory.getLog(TableDumper.class);
+	
+	public static void saveDB()
+	{
+		Connection con = null;
+		try
+		{
+			con = L2DatabaseFactory.getInstance().getConnection();
+			Statement st = con.createStatement();
+			
+			final ArrayList<String> tables = new ArrayList<String>();
+			{
+				ResultSet rs = st.executeQuery("SHOW FULL TABLES");
+				while (rs.next())
+				{
+					String tableType = rs.getString(2/*"Table_type"*/);
+					
+					if (tableType.equals("VIEW"))
+						continue;
+					
+					tables.add(rs.getString(1));
+				}
+				rs.close();
+			}
+			
+			{
+				ResultSet rs = st.executeQuery("CHECK TABLE " + StringUtils.join(tables, ","));
+				while (rs.next())
+				{
+					String table = rs.getString("Table");
+					String msgType = rs.getString("Msg_type");
+					String msgText = rs.getString("Msg_text");
+					
+					if (msgType.equals("status"))
+						if (msgText.equals("OK"))
+							continue;
+					
+					_log.warn("TableSaver: CHECK TABLE " + table + ": " + msgType + " -> " + msgText);
+				}
+				rs.close();
+				
+				_log.info("TableSaver: Database tables have been checked.");
+			}
+			
+			{
+				ResultSet rs = st.executeQuery("ANALYZE TABLE " + StringUtils.join(tables, ","));
+				while (rs.next())
+				{
+					String table = rs.getString("Table");
+					String msgType = rs.getString("Msg_type");
+					String msgText = rs.getString("Msg_text");
+					
+					if (msgType.equals("status"))
+						if (msgText.equals("OK") || msgText.equals("Table is already up to date"))
+							continue;
+					
+					_log.warn("TableSaver: ANALYZE TABLE " + table + ": " + msgType + " -> " + msgText);
+				}
+				rs.close();
+				
+				_log.info("TableSaver: Database tables have been analyzed.");
+			}
+			
+			{
+                File DirDump = new File(Config.DATAPACK_ROOT, "dump/");
+				ResultSet rs = st.executeQuery("SELECT * FROM " + StringUtils.join(tables, ",") + " INTO DUMPFILE '" + DirDump + "'");
+				while (rs.next())
+				{
+					String table = rs.getString("Table");
+					String msgType = rs.getString("Msg_type");
+					String msgText = rs.getString("Msg_text");
+					
+					if (msgType.equals("status"))
+						if (msgText.equals("OK") || msgText.equals("Table is already up to date"))
+							continue;
+					
+					if (msgType.equals("note"))
+						if (msgText.equals("Table does not support dump, doing recreate + analyze instead"))
+							continue;
+					
+					_log.warn("TableSaver: Create dump " + table + ": " + msgType + " -> " + msgText);
+				}
+				rs.close();
+				
+				_log.info("TableSaver: Database tables have been dumped.");
+			}
+			st.close();
+		}
+		catch (Exception e)
+		{
+			_log.warn("TableSaver: Cannot dump database tables!", e);
+		}
+		finally
+		{
+			L2DatabaseFactory.close(con);
+		}
+	}
+}

Link to comment
Share on other sites

Join the conversation

You can post now and register later. If you have an account, sign in now to post with your account.
Note: Your post will require moderator approval before it will be visible.

Guest
Answer this question...

×   Pasted as rich text.   Paste as plain text instead

  Only 75 emoji are allowed.

×   Your link has been automatically embedded.   Display as a link instead

×   Your previous content has been restored.   Clear editor

×   You cannot paste images directly. Upload or insert images from URL.



  • Posts

    • Welcome to my store : https://topestore.mysellix.io/fr/ 2015-2022 Aged Discord Account 2015 Discord Account : 60.99 $ 2016 Discord Account : 10.50 $ 2017 Discord Account :4.99 $ 2018 Discord Account : 3.99 $ 2019 Discord Account : 2.99 $ 2020 Discord Account :1.99$ 2021 Discord Account :1.50$ 2022 Discord Account :0.99$ Warranty :Lifetime Payment Methods : Crypto/ PayPal Contact Me On Discord Or Telegram Discord : @ultrasstore11 Telegram : https://t.me/ultrastore11 Whatsapp ; +212614849119
    • The heavy lifting is done in the client, because while you can get away with small imperfections in the java, everything in the client must be impecable. So, if you haven't touched the client, I'd say pick the newest protocol version you can find the client editing tools and Interface.u (mandatory) / NWindow.dll (better to have it) / Engine.dll (optional) sources for. At the very least, you need the Interface.u to fix the Clan Window and enable skill enchanting on Classic/Essence versions, if you decide to use one of them instead of MAIN/LIVE.
    • Thanks for clarification. Do you think the newest clients offer solid advantages compared to the classic ones like Salvation? I'm also in the process of porting h5 to one of them just for the sake of it, so I was wondering if I should just attempt to go to the newest possible.
    • Upgrading to Salvation is exactly the same as upgrading to the newest client with the only difference being access to free-shared client editing tools and resources. I am speaking from experience. I have upgraded my HF source to one of the newest clients by myself (in terms of server side. got help with the client) and hit every single wall there was in the process. Now, I already have several multi-protocool server cores so I can easily compare different approaches to tackling the same issue, which also helped the learning process. Best way to learn would be to use this one (link below) to snoop around and figure out what has been changed in the server side (the packet structure will be different, for sure, but works for understanding/figuring the process out in general terms). https://github.com/iBezneR/L2J_SunriseProject_Purity The client side will always be the same, always the same files, only the DAT structure will be different. I personally wrote myself some parsers for the data of the DAT files from OLD -> NEW client.
  • Topics

×
×
  • Create New...