diff --git a/quickfixj-core/src/main/resources/config/sql/mysql/create_all.sql b/quickfixj-core/src/main/resources/config/sql/mysql/create_all.sql
new file mode 100644
index 000000000..99bf6e3cf
--- /dev/null
+++ b/quickfixj-core/src/main/resources/config/sql/mysql/create_all.sql
@@ -0,0 +1,84 @@
+DROP DATABASE IF EXISTS quickfix;
+CREATE DATABASE quickfix;
+
+
+USE quickfix;
+
+DROP TABLE IF EXISTS sessions;
+
+CREATE TABLE sessions (
+beginstring CHAR(8) NOT NULL,
+sendercompid VARCHAR(64) NOT NULL,
+sendersubid VARCHAR(64) NOT NULL,
+senderlocid VARCHAR(64) NOT NULL,
+targetcompid VARCHAR(64) NOT NULL,
+targetsubid VARCHAR(64) NOT NULL,
+targetlocid VARCHAR(64) NOT NULL,
+session_qualifier VARCHAR(64) NOT NULL,
+creation_time DATETIME NOT NULL,
+incoming_seqnum INT NOT NULL,
+outgoing_seqnum INT NOT NULL,
+PRIMARY KEY (beginstring, sendercompid, sendersubid, senderlocid,
+			 targetcompid, targetsubid, targetlocid, session_qualifier)
+);
+
+
+USE quickfix;
+
+DROP TABLE IF EXISTS messages;
+
+CREATE TABLE messages (
+beginstring CHAR(8) NOT NULL,
+sendercompid VARCHAR(64) NOT NULL,
+sendersubid VARCHAR(64) NOT NULL,
+senderlocid VARCHAR(64) NOT NULL,
+targetcompid VARCHAR(64) NOT NULL,
+targetsubid VARCHAR(64) NOT NULL,
+targetlocid VARCHAR(64) NOT NULL,
+session_qualifier VARCHAR(64) NOT NULL,
+msgseqnum INT NOT NULL,
+message TEXT NOT NULL,
+PRIMARY KEY (beginstring, sendercompid, sendersubid, senderlocid,
+			 targetcompid, targetsubid, targetlocid, session_qualifier,
+			 msgseqnum)
+);
+
+
+USE quickfix;
+
+DROP TABLE IF EXISTS messages_log;
+
+CREATE TABLE messages_log (
+id INT UNSIGNED NOT NULL AUTO_INCREMENT,
+time DATETIME NOT NULL,
+beginstring CHAR(8) NOT NULL,
+sendercompid VARCHAR(64) NOT NULL,
+sendersubid VARCHAR(64) NOT NULL,
+senderlocid VARCHAR(64) NOT NULL,
+targetcompid VARCHAR(64) NOT NULL,
+targetsubid VARCHAR(64) NOT NULL,
+targetlocid VARCHAR(64) NOT NULL,
+session_qualifier VARCHAR(64) NOT NULL,
+text TEXT NOT NULL,
+PRIMARY KEY (id)
+);
+
+
+USE quickfix;
+
+DROP TABLE IF EXISTS event_log;
+
+CREATE TABLE event_log (
+id INT UNSIGNED NOT NULL AUTO_INCREMENT,
+time DATETIME NOT NULL,
+beginstring CHAR(8) NOT NULL,
+sendercompid VARCHAR(64) NOT NULL,
+sendersubid VARCHAR(64) NOT NULL,
+senderlocid VARCHAR(64) NOT NULL,
+targetcompid VARCHAR(64) NOT NULL,
+targetsubid VARCHAR(64) NOT NULL,
+targetlocid VARCHAR(64) NOT NULL,
+session_qualifier VARCHAR(64),
+text TEXT NOT NULL,
+PRIMARY KEY (id)
+);