--- mqtt/etc/mqtt_pub.sql	2011/12/09 13:43:55	1.1.2.9
+++ mqtt/etc/mqtt_pub.sql	2011/12/16 02:09:19	1.1.2.10
@@ -1,10 +1,9 @@
 PRAGMA foreign_keys=ON;
 BEGIN TRANSACTION;
 CREATE TABLE IF NOT EXISTS Online (
+ConnID varchar(23) not null primary key, 
 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,
@@ -14,6 +13,7 @@ Stamp timestamp);
 CREATE TABLE IF NOT EXISTS Topics (
 id integer not null primary key,
 MsgID smallint unsigned not null, 
+QoS char not null,
 Retain char not null,
 Topic varchar(255) not null,
 Value text,
@@ -23,7 +23,6 @@ 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 ConnID on Online (ConnID);
 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);