Jump to content
  • 0

Database


papuna
 Share

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.

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.

 Share



×
×
  • Create New...

AdBlock Extension Detected!

Our website is made possible by displaying online advertisements to our members.

Please disable AdBlock browser extension first, to be able to use our community.

I've Disbaled AdBlock