--- mqtt/etc/mqtt_pub.sql	2011/11/28 16:59:28	1.1.2.7
+++ mqtt/etc/mqtt_pub.sql	2011/12/08 17:02:25	1.1.2.8
@@ -1,12 +1,19 @@
 PRAGMA foreign_keys=ON;
 BEGIN TRANSACTION;
 CREATE TABLE IF NOT EXISTS Online (
-Username varchar(64) not null,
+Username varchar(12) not null,
+ConnID varchar(23) not null, 
 RemoteHost varchar(64) not null,
 RemotePort smallint unsigned not null,
+WillFlag tinyint not null,
+WillTopic text,
+WillMsg text,
+WillQoS tinyint,
+WillRetain tinyint,
 Stamp timestamp);
 CREATE TABLE IF NOT EXISTS Topics (
 id integer not null primary key,
+MsgID smallint unsigned not null, 
 Retain char not null,
 Topic varchar(255) not null,
 Value text,
@@ -16,10 +23,12 @@ PubHost varchar(64) not null,
 Stamp timestamp);
 CREATE INDEX IF NOT EXISTS RemoteHost on Online (RemoteHost);
 CREATE INDEX IF NOT EXISTS Username on Online (Username);
-CREATE UNIQUE INDEX IF NOT EXISTS User on Online (Username, RemoteHost);
+CREATE INDEX IF NOT EXISTS ConnID on Online (ConnID);
+CREATE UNIQUE INDEX IF NOT EXISTS User on Online (Username, ConnID, RemoteHost);
 CREATE INDEX IF NOT EXISTS PubDate on Topics (PubDate);
 CREATE INDEX IF NOT EXISTS PubHost on Topics (PubHost);
 CREATE INDEX IF NOT EXISTS PubUser on Topics (PubUser);
+CREATE INDEX IF NOT EXISTS MsgID on Topics (MsgID);
 CREATE INDEX IF NOT EXISTS Topic on Topics (Topic);
 CREATE TRIGGER IF NOT EXISTS Online_update_t AFTER UPDATE ON Online
 BEGIN