create_jds.sql

一个java方面的消息订阅发送的源码

/* DROP TABLE system_data; */
create table system_data (
  id                     int not null,
  version                varchar(20) not null,
  creationDate           DATE not null
);
create unique index system_data_pk on system_data(id);

/* DROP TABLE seeds; */
create table seeds (
  name                   varchar(20) not null,
  seed                   numeric(18) not null
);
create unique index seeds_pk on seeds(name);

/* DROP TABLE destinations; */
create table destinations (
  name                   varchar(255) not null,
  isQueue                int not null,
  destinationId          numeric(18) not null
);
create unique index destinations_pk on destinations(destinationId);

/* DROP TABLE messages; */
create table messages (
  messageId             varchar(64) not null,
  destinationId         numeric(18) not null,
  priority              int,
  createTime            numeric(18) not null,
  expiryTime            numeric(18),
  processed             int,
  messageBlob           binary not null
);
create index messages_pk on messages(messageId);

/* DROP TABLE message_handles; */
CREATE TABLE message_handles (
   messageId            varchar(64) not null,
   destinationId        numeric(18) NOT NULL,
   consumerId           numeric(18) NOT NULL,
   priority             int,
   acceptedTime         numeric(18),
   sequenceNumber       numeric(18),
   expiryTime           numeric(18),
   delivered            int
);
CREATE INDEX message_handles_pk ON message_handles(destinationId, consumerId, messageId);

/* DROP TABLE consumers; */
create table consumers (
  name                 varchar(255) not null,
  destinationId        numeric(18) not null,
  consumerId           numeric(18) not NULL,
  created              numeric(18) NOT NULL
);
create unique index consumers_pk on consumers(name, destinationId);

/* DROP TABLE users; */
create table users (
  username             varchar(50) not null,
  password             varchar(50) not null
);
create unique index users_pk on users(username);