diff --git a/build.gradle b/build.gradle index e2681941..824f0624 100644 --- a/build.gradle +++ b/build.gradle @@ -21,6 +21,7 @@ plugins { repositories { maven { url 'http://maven.aliyun.com/nexus/content/groups/public' } jcenter() + mavenCentral() } configurations { @@ -64,6 +65,7 @@ dependencies { compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-netflix-zuul', version: springBootVersion compile group: 'org.mybatis.spring.boot', name: 'mybatis-spring-boot-starter', version: springMybatisVersion compile group: 'mysql', name: 'mysql-connector-java', version: mysqlConnectorVersion + compile group: 'org.herddb', name: 'herddb-jdbc', version: herddbVersion compile group: 'javax.validation', name: 'validation-api', version: javaxValidationVersion compile group: 'io.jsonwebtoken', name: 'jjwt', version: jsonWebTokenVersion compile group: 'org.xerial', name: 'sqlite-jdbc', version: sqliteVersion diff --git a/gradle.properties b/gradle.properties index 1a3dabfd..970f5976 100644 --- a/gradle.properties +++ b/gradle.properties @@ -14,3 +14,4 @@ swaggeruiVersion=2.9.2 apiMockitoVersion=1.7.1 mockitoJunit4Version=1.7.1 gsonVersion=2.8.2 +herddbVersion=0.12.0 diff --git a/src/main/java/io/streamnative/pulsar/manager/dao/ConsumersStatsRepositoryImpl.java b/src/main/java/io/streamnative/pulsar/manager/dao/ConsumersStatsRepositoryImpl.java index 923b4742..3258a8b5 100644 --- a/src/main/java/io/streamnative/pulsar/manager/dao/ConsumersStatsRepositoryImpl.java +++ b/src/main/java/io/streamnative/pulsar/manager/dao/ConsumersStatsRepositoryImpl.java @@ -61,7 +61,7 @@ public Page findByReplicationStatsId(Integer pageNum, Integ } public void remove(long timestamp, long timeInterval) { - consumerStatsMapper.delete(timestamp, timeInterval); + consumerStatsMapper.delete(timestamp - timeInterval); } } diff --git a/src/main/java/io/streamnative/pulsar/manager/dao/PublishersStatsRepositoryImpl.java b/src/main/java/io/streamnative/pulsar/manager/dao/PublishersStatsRepositoryImpl.java index 79ca042f..d835d5b2 100644 --- a/src/main/java/io/streamnative/pulsar/manager/dao/PublishersStatsRepositoryImpl.java +++ b/src/main/java/io/streamnative/pulsar/manager/dao/PublishersStatsRepositoryImpl.java @@ -44,7 +44,7 @@ public Page findByTopicStatsId(Integer pageNum, Integer pa } public void remove(long timestamp, long timeInterval) { - publishersStatsMapper.delete(timestamp, timeInterval); + publishersStatsMapper.delete(timestamp - timeInterval); } } diff --git a/src/main/java/io/streamnative/pulsar/manager/dao/ReplicationsStatsRepositoryImpl.java b/src/main/java/io/streamnative/pulsar/manager/dao/ReplicationsStatsRepositoryImpl.java index 6ccb8f3d..34f4a2aa 100644 --- a/src/main/java/io/streamnative/pulsar/manager/dao/ReplicationsStatsRepositoryImpl.java +++ b/src/main/java/io/streamnative/pulsar/manager/dao/ReplicationsStatsRepositoryImpl.java @@ -45,6 +45,6 @@ public Page findByTopicStatsId(Integer pageNum, Integer } public void remove(long timestamp, long timeInterval) { - replicationsStatsMapper.delete(timestamp, timeInterval); + replicationsStatsMapper.delete(timestamp - timeInterval); } } diff --git a/src/main/java/io/streamnative/pulsar/manager/dao/SubscriptionsStatsRepositoryImpl.java b/src/main/java/io/streamnative/pulsar/manager/dao/SubscriptionsStatsRepositoryImpl.java index 280190e5..370e53d9 100644 --- a/src/main/java/io/streamnative/pulsar/manager/dao/SubscriptionsStatsRepositoryImpl.java +++ b/src/main/java/io/streamnative/pulsar/manager/dao/SubscriptionsStatsRepositoryImpl.java @@ -44,6 +44,6 @@ public Page findByTopicStatsId(Integer pageNum, Integer } public void remove(long timestamp, long timeInterval) { - subscriptionsStatsMapper.delete(timestamp, timeInterval); + subscriptionsStatsMapper.delete(timestamp - timeInterval); } } diff --git a/src/main/java/io/streamnative/pulsar/manager/dao/TopicsStatsRepositoryImpl.java b/src/main/java/io/streamnative/pulsar/manager/dao/TopicsStatsRepositoryImpl.java index 5802f453..2e54a912 100644 --- a/src/main/java/io/streamnative/pulsar/manager/dao/TopicsStatsRepositoryImpl.java +++ b/src/main/java/io/streamnative/pulsar/manager/dao/TopicsStatsRepositoryImpl.java @@ -79,6 +79,6 @@ public Page findByMultiTopic(Integer pageNum, } public void remove(long timestamp, long timeInterval) { - topicsStatsMapper.delete(timestamp, timeInterval); + topicsStatsMapper.delete(timestamp - timeInterval); } } diff --git a/src/main/java/io/streamnative/pulsar/manager/mapper/ConsumerStatsMapper.java b/src/main/java/io/streamnative/pulsar/manager/mapper/ConsumerStatsMapper.java index 01feed7c..c91f5500 100644 --- a/src/main/java/io/streamnative/pulsar/manager/mapper/ConsumerStatsMapper.java +++ b/src/main/java/io/streamnative/pulsar/manager/mapper/ConsumerStatsMapper.java @@ -22,7 +22,7 @@ public interface ConsumerStatsMapper { @Insert("INSERT INTO consumersStats(consumer,topicStatsId,replicationStatsId,subscriptionStatsId,address," + "availablePermits,connectedSince,msgRateOut,msgThroughputOut,msgRateRedeliver," + - "clientVersion,timestamp,metadata) " + + "clientVersion,`timestamp`,metadata) " + "VALUES(#{consumer},#{topicStatsId},#{replicationStatsId},#{subscriptionStatsId},#{address}," + "#{availablePermits},#{connectedSince},#{msgRateOut},#{msgThroughputOut},#{msgRateRedeliver}," + "#{clientVersion},#{timestamp},#{metadata})") @@ -31,25 +31,25 @@ public interface ConsumerStatsMapper { @Select("SELECT consumerStatsId,consumer,topicStatsId,replicationStatsId,subscriptionStatsId,address," + "availablePermits,connectedSince,msgRateOut,msgThroughputOut,msgRateRedeliver," + - "clientVersion,timestamp,metadata FROM consumersStats " + - "where topicStatsId=#{topicStatsId} and timestamp=#{timestamp}") + "clientVersion,`timestamp`,metadata FROM consumersStats " + + "where topicStatsId=#{topicStatsId} and `timestamp`=#{timestamp}") Page findByTopicStatsId(@Param("topicStatsId") long topicStatsId, @Param("timestamp") long timestamp); @Select("SELECT consumerStatsId,consumer,topicStatsId,replicationStatsId,subscriptionStatsId,address," + "availablePermits,connectedSince,msgRateOut,msgThroughputOut,msgRateRedeliver," + - "clientVersion,timestamp,metadata FROM consumersStats " + - "where subscriptionStatsId=#{subscriptionStatsId} and timestamp=#{timestamp}") + "clientVersion,`timestamp`,metadata FROM consumersStats " + + "where subscriptionStatsId=#{subscriptionStatsId} and `timestamp`=#{timestamp}") Page findBySubscriptionStatsId(@Param("subscriptionStatsId") long subscriptionStatsId, @Param("timestamp") long timestamp); @Select("SELECT consumerStatsId,consumer,topicStatsId,replicationStatsId,subscriptionStatsId,address," + "availablePermits,connectedSince,msgRateOut,msgThroughputOut,msgRateRedeliver," + - "clientVersion,timestamp,metadata FROM consumersStats " + - "where replicationStatsId=#{replicationStatsId} and timestamp=#{timestamp}") + "clientVersion,`timestamp`,metadata FROM consumersStats " + + "where replicationStatsId=#{replicationStatsId} and `timestamp`=#{timestamp}") Page findByReplicationStatsId(@Param("replicationStatsId") long replicationStatsId, @Param("timestamp") long timestamp); - @Delete("DELETE FROM consumersStats WHERE #{nowTime} - #{timeInterval} >= timestamp") - void delete(@Param("nowTime") long nowTime, @Param("timeInterval") long timeInterval); + @Delete("DELETE FROM consumersStats WHERE `timestamp` <= #{refTime}") + void delete(@Param("refTime") long refTime); } diff --git a/src/main/java/io/streamnative/pulsar/manager/mapper/PublishersStatsMapper.java b/src/main/java/io/streamnative/pulsar/manager/mapper/PublishersStatsMapper.java index 5ef226cb..a86d68f0 100644 --- a/src/main/java/io/streamnative/pulsar/manager/mapper/PublishersStatsMapper.java +++ b/src/main/java/io/streamnative/pulsar/manager/mapper/PublishersStatsMapper.java @@ -21,18 +21,18 @@ public interface PublishersStatsMapper { @Insert("INSERT INTO publishersStats(producerId,topicStatsId,producerName,msgRateIn," + - "msgThroughputIn,averageMsgSize,address,connectedSince,clientVersion,metadata,timestamp) " + + "msgThroughputIn,averageMsgSize,address,connectedSince,clientVersion,metadata,`timestamp`) " + "VALUES(#{producerId},#{topicStatsId},#{producerName},#{msgRateIn},#{msgThroughputIn}," + "#{averageMsgSize},#{address},#{connectedSince},#{clientVersion},#{metadata},#{timestamp})") @Options(useGeneratedKeys=true, keyProperty="publisherStatsId", keyColumn="publisherStatsId") void save(PublisherStatsEntity publisherStatsEntity); @Select("SELECT publisherStatsId,producerId,topicStatsId,producerName,msgRateIn,msgThroughputIn,averageMsgSize," + - "address,connectedSince,clientVersion,metadata,timestamp From publishersStats " + - "WHERE topicStatsId=#{topicStatsId} and timestamp=#{timestamp}") + "address,connectedSince,clientVersion,metadata,`timestamp` From publishersStats " + + "WHERE topicStatsId=#{topicStatsId} and `timestamp`=#{timestamp}") Page findByTopicStatsId(@Param("topicStatsId") long topicStatsId, @Param("timestamp") long timestamp); - @Delete("DELETE FROM publishersStats WHERE #{nowTime} - #{timeInterval} >= timestamp") - void delete(@Param("nowTime") long nowTime, @Param("timeInterval") long timeInterval); + @Delete("DELETE FROM publishersStats WHERE `timestamp` <= #{refTime}") + void delete(@Param("refTime") long refTime); } diff --git a/src/main/java/io/streamnative/pulsar/manager/mapper/ReplicationsStatsMapper.java b/src/main/java/io/streamnative/pulsar/manager/mapper/ReplicationsStatsMapper.java index 9c9219cf..f41b9dbb 100644 --- a/src/main/java/io/streamnative/pulsar/manager/mapper/ReplicationsStatsMapper.java +++ b/src/main/java/io/streamnative/pulsar/manager/mapper/ReplicationsStatsMapper.java @@ -22,7 +22,7 @@ public interface ReplicationsStatsMapper { @Insert("INSERT INTO replicationsStats(topicStatsId,cluster,connected,msgRateIn,msgRateOut,msgThroughputIn," + "msgThroughputOut,replicationBacklog,replicationDelayInSeconds,inboundConnection," + - "inboundConnectedSince,outboundConnection,outboundConnectedSince,timestamp,msgRateExpired) " + + "inboundConnectedSince,outboundConnection,outboundConnectedSince,`timestamp`,msgRateExpired) " + "VALUES(#{topicStatsId},#{cluster},#{connected},#{msgRateIn},#{msgRateOut},#{msgThroughputIn}," + "#{msgThroughputOut},#{replicationBacklog},#{replicationDelayInSeconds}," + "#{inboundConnection},#{inboundConnectedSince},#{outboundConnection},#{outboundConnectedSince}," + @@ -32,11 +32,11 @@ public interface ReplicationsStatsMapper { @Select("SELECT replicationStatsId,topicStatsId,cluster,connected,msgRateIn,msgRateOut,msgThroughputIn,msgThroughputOut," + "replicationBacklog,replicationDelayInSeconds,inboundConnection,inboundConnectedSince," + - "outboundConnection,outboundConnectedSince,timestamp,msgRateExpired FROM replicationsStats " + - "where topicStatsId=#{topicStatsId} and timestamp=#{timestamp}") + "outboundConnection,outboundConnectedSince,`timestamp`,msgRateExpired FROM replicationsStats " + + "where topicStatsId=#{topicStatsId} and `timestamp`=#{timestamp}") Page findByTopicStatsId(@Param("topicStatsId") long topicStatsId, @Param("timestamp") long timestamp); - @Delete("DELETE FROM replicationsStats WHERE #{nowTime} - #{timeInterval} >= timestamp") - void delete(@Param("nowTime") long nowTime, @Param("timeInterval") long timeInterval); + @Delete("DELETE FROM replicationsStats WHERE `timestamp` <= #{refTime}") + void delete(@Param("refTime") long refTime); } diff --git a/src/main/java/io/streamnative/pulsar/manager/mapper/SubscriptionsStatsMapper.java b/src/main/java/io/streamnative/pulsar/manager/mapper/SubscriptionsStatsMapper.java index 559b85f8..e6b8d467 100644 --- a/src/main/java/io/streamnative/pulsar/manager/mapper/SubscriptionsStatsMapper.java +++ b/src/main/java/io/streamnative/pulsar/manager/mapper/SubscriptionsStatsMapper.java @@ -22,7 +22,7 @@ public interface SubscriptionsStatsMapper { @Insert("INSERT INTO subscriptionsStats(topicStatsId,subscription,msgBacklog,msgRateExpired," + "msgRateOut,msgThroughputOut,msgRateRedeliver,numberOfEntriesSinceFirstNotAckedMessage," + - "totalNonContiguousDeletedMessagesRange,subscriptionType,timestamp) " + + "totalNonContiguousDeletedMessagesRange,subscriptionType,`timestamp`) " + "VALUES(#{topicStatsId},#{subscription},#{msgBacklog},#{msgRateExpired},#{msgRateOut}," + "#{msgThroughputOut},#{msgRateRedeliver},#{numberOfEntriesSinceFirstNotAckedMessage}," + "#{totalNonContiguousDeletedMessagesRange},#{subscriptionType}," + @@ -32,11 +32,11 @@ public interface SubscriptionsStatsMapper { @Select("SELECT subscriptionStatsId,topicStatsId,subscription,msgBacklog,msgRateExpired,msgRateOut," + "msgThroughputOut,msgRateRedeliver,numberOfEntriesSinceFirstNotAckedMessage," + - "totalNonContiguousDeletedMessagesRange,subscriptionType,timestamp FROM subscriptionsStats " + - "where topicStatsId=#{topicStatsId} and timestamp=#{timestamp}") + "totalNonContiguousDeletedMessagesRange,subscriptionType,`timestamp` FROM subscriptionsStats " + + "where topicStatsId=#{topicStatsId} and `timestamp`=#{timestamp}") Page findByTopicStatsId(@Param("topicStatsId") long topicStatsId, @Param("timestamp") long timestamp); - @Delete("DELETE FROM subscriptionsStats WHERE #{nowTime} - #{timeInterval} >= timestamp") - void delete(@Param("nowTime") long nowTime, @Param("timeInterval") long timeInterval); + @Delete("DELETE FROM subscriptionsStats WHERE `timestamp` <= #{refTime}") + void delete(@Param("refTime") long refTime); } diff --git a/src/main/java/io/streamnative/pulsar/manager/mapper/TopicsStatsMapper.java b/src/main/java/io/streamnative/pulsar/manager/mapper/TopicsStatsMapper.java index b70d4666..c605b0ba 100644 --- a/src/main/java/io/streamnative/pulsar/manager/mapper/TopicsStatsMapper.java +++ b/src/main/java/io/streamnative/pulsar/manager/mapper/TopicsStatsMapper.java @@ -24,7 +24,7 @@ public interface TopicsStatsMapper { @Insert("INSERT INTO topicsStats(environment, cluster,broker,tenant,namespace,bundle,persistent,topic," + "producerCount,subscriptionCount,msgRateIn,msgThroughputIn,msgRateOut,msgThroughputOut," + - "averageMsgSize,storageSize,timestamp) " + + "averageMsgSize,storageSize,`timestamp`) " + "VALUES(#{environment},#{cluster},#{broker},#{tenant},#{namespace},#{bundle},#{persistent},#{topic}," + "#{producerCount},#{subscriptionCount},#{msgRateIn},#{msgThroughputIn},#{msgRateOut},#{msgThroughputOut}," + "#{averageMsgSize},#{storageSize},#{timestamp})") @@ -32,13 +32,13 @@ public interface TopicsStatsMapper { void insert(TopicStatsEntity topicStatsEntity); @Select("SELECT topicStatsId,environment,cluster,broker,tenant,namespace,bundle,persistent,topic,producerCount,subscriptionCount," + - "msgRateIn,msgThroughputIn,msgRateOut,msgThroughputOut,averageMsgSize,storageSize,timestamp FROM topicsStats " + - "ORDER BY timestamp DESC limit 1 ") + "msgRateIn,msgThroughputIn,msgRateOut,msgThroughputOut,averageMsgSize,storageSize,`timestamp` FROM topicsStats " + + "ORDER BY `timestamp` DESC limit 1 ") TopicStatsEntity findMaxTime(); @Select("SELECT topicStatsId,environment,cluster,broker,tenant,namespace,bundle,persistent,topic,producerCount,subscriptionCount," + - "msgRateIn,msgThroughputIn,msgRateOut,msgThroughputOut,averageMsgSize,storageSize,timestamp FROM topicsStats " + - "WHERE environment=#{environment} and cluster=#{cluster} and broker=#{broker} and timestamp=#{timestamp}") + "msgRateIn,msgThroughputIn,msgRateOut,msgThroughputOut,averageMsgSize,storageSize,`timestamp` FROM topicsStats " + + "WHERE environment=#{environment} and cluster=#{cluster} and broker=#{broker} and `timestamp`=#{timestamp}") Page findByClusterBroker( @Param("environment") String environment, @Param("cluster") String cluster, @@ -46,9 +46,9 @@ Page findByClusterBroker( @Param("timestamp") long timestamp); @Select("SELECT topicStatsId,environment,cluster,tenant,namespace,bundle,persistent,topic,producerCount,subscriptionCount," + - "msgRateIn,msgThroughputIn,msgRateOut,msgThroughputOut,averageMsgSize,storageSize,timestamp FROM topicsStats " + + "msgRateIn,msgThroughputIn,msgRateOut,msgThroughputOut,averageMsgSize,storageSize,`timestamp` FROM topicsStats " + "WHERE environment=#{environment} and tenant=#{tenant} and namespace=#{namespace} " + - "and timestamp=#{timestamp}") + "and `timestamp`=#{timestamp}") Page findByNamespace( @Param("environment") String environment, @Param("tenant") String tenant, @@ -64,10 +64,10 @@ Page findByNamespace( + "sum(msgRateOut) as msgRateOut," + "sum(msgThroughputOut) as msgThroughputOut," + "avg(averageMsgSize) as averageMsgSize," - + "sum(storageSize) as storageSize, timestamp FROM topicsStats", - "WHERE environment=#{environment} and tenant=#{tenant} and namespace=#{namespace} and timestamp=#{timestamp} and " + + + "sum(storageSize) as storageSize, `timestamp` FROM topicsStats", + "WHERE environment=#{environment} and tenant=#{tenant} and namespace=#{namespace} and `timestamp`=#{timestamp} and " + "topic IN #{topic} " + - "GROUP BY cluster, persistent, topic" + + "GROUP BY environment, cluster, tenant, namespace, persistent, topic, `timestamp` " + ""}) Page findByMultiTopic( @Param("environment") String environment, @@ -77,6 +77,6 @@ Page findByMultiTopic( @Param("topicList") List topicList, @Param("timestamp") long timestamp); - @Delete("DELETE FROM topicsStats WHERE #{nowTime} - #{timeInterval} >= timestamp") - void delete(@Param("nowTime") long nowTime, @Param("timeInterval") long timeInterval); + @Delete("DELETE FROM topicsStats WHERE `timestamp` <= #{refTime}") + void delete(@Param("refTime") long refTime); } diff --git a/src/main/resources/META-INF/sql/herddb-schema.sql b/src/main/resources/META-INF/sql/herddb-schema.sql new file mode 100644 index 00000000..3c335e85 --- /dev/null +++ b/src/main/resources/META-INF/sql/herddb-schema.sql @@ -0,0 +1,110 @@ +-- +-- Licensed under the Apache License, Version 2.0 (the "License"); +-- you may not use this file except in compliance with the License. +-- You may obtain a copy of the License at +-- +-- http://www.apache.org/licenses/LICENSE-2.0 +-- +-- Unless required by applicable law or agreed to in writing, software +-- distributed under the License is distributed on an "AS IS" BASIS, +-- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +-- See the License for the specific language governing permissions and +-- limitations under the License. +-- + +CREATE TABLE IF NOT EXISTS environments ( + name varchar(256) NOT NULL PRIMARY KEY, + broker varchar(1024) NOT NULL, + UNIQUE (broker) +) ; + +CREATE TABLE IF NOT EXISTS topicsStats ( + topicStatsId BIGINT PRIMARY KEY AUTO_INCREMENT, + environment varchar(255) NOT NULL, + cluster varchar(255) NOT NULL, + broker varchar(255) NOT NULL, + tenant varchar(255) NOT NULL, + namespace varchar(255) NOT NULL, + bundle varchar(255) NOT NULL, + persistent varchar(36) NOT NULL, + topic varchar(255) NOT NULL, + producerCount BIGINT, + subscriptionCount BIGINT, + msgRateIn double, + msgThroughputIn double, + msgRateOut double, + msgThroughputOut double, + averageMsgSize double, + storageSize double, + timestamp BIGINT +) ; + +CREATE TABLE IF NOT EXISTS publishersStats ( + publisherStatsId BIGINT PRIMARY KEY AUTO_INCREMENT, + producerId BIGINT, + topicStatsId BIGINT NOT NULL, + producerName varchar(255) NOT NULL, + msgRateIn double, + msgThroughputIn double, + averageMsgSize double, + address varchar(255), + connectedSince varchar(128), + clientVersion varchar(36), + metadata text, + timestamp BIGINT, + CONSTRAINT FK_publishers_stats_topic_stats_id FOREIGN KEY (topicStatsId) References topicsStats(topicStatsId) +); + +CREATE TABLE IF NOT EXISTS replicationsStats ( + replicationStatsId BIGINT PRIMARY KEY AUTO_INCREMENT, + topicStatsId BIGINT NOT NULL, + cluster varchar(255) NOT NULL, + connected BOOLEAN, + msgRateIn double, + msgRateOut double, + msgRateExpired double, + msgThroughputIn double, + msgThroughputOut double, + msgRateRedeliver double, + replicationBacklog BIGINT, + replicationDelayInSeconds BIGINT, + inboundConnection varchar(255), + inboundConnectedSince varchar(255), + outboundConnection varchar(255), + outboundConnectedSince varchar(255), + timestamp BIGINT +) ; + +CREATE TABLE IF NOT EXISTS subscriptionsStats ( + subscriptionStatsId BIGINT PRIMARY KEY AUTO_INCREMENT, + topicStatsId BIGINT NOT NULL, + subscription varchar(255) NULL, + msgBacklog BIGINT, + msgRateExpired double, + msgRateOut double, + msgThroughputOut double, + msgRateRedeliver double, + numberOfEntriesSinceFirstNotAckedMessage BIGINT, + totalNonContiguousDeletedMessagesRange BIGINT, + subscriptionType varchar(16), + blockedSubscriptionOnUnackedMsgs BOOLEAN, + timestamp BIGINT, + UNIQUE (topicStatsId, subscription) +) ; + +CREATE TABLE IF NOT EXISTS consumersStats ( + consumerStatsId BIGINT PRIMARY KEY AUTO_INCREMENT, + consumer varchar(255) NOT NULL, + topicStatsId BIGINT NOT NUll, + replicationStatsId BIGINT, + subscriptionStatsId BIGINT, + address varchar(255), + availablePermits BIGINT, + connectedSince varchar(255), + msgRateOut double, + msgThroughputOut double, + msgRateRedeliver double, + clientVersion varchar(36), + timestamp BIGINT, + metadata text +) ; diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties index 173d2eab..77dc079d 100644 --- a/src/main/resources/application.properties +++ b/src/main/resources/application.properties @@ -18,13 +18,25 @@ server.port=7750 mybatis.type-aliases-package=io.streamnative.pulsar.manager # database connection + +# SQLLite spring.datasource.driver-class-name=org.sqlite.JDBC spring.datasource.url=jdbc:sqlite:pulsar_manager.db spring.datasource.initialization-mode=always spring.datasource.schema=classpath:/META-INF/sql/sqlite-schema.sql spring.datasource.username= spring.datasource.password= + +# HerdDB JDBC Driver +# spring.datasource.driver-class-name=herddb.jdbc.Driver +# HerdDB - local in memory-only (check docs for starting an embedded server or embedded replicated server) +# spring.datasource.url=jdbc:herddb:local +# spring.datasource.schema=classpath:/META-INF/sql/herddb-schema.sql +# spring.datasource.username=sa +# spring.datasource.password=hdb + spring.datasource.max-idle=10 +spring.datasource.initialization-mode=always spring.datasource.max-wait=10000 spring.datasource.min-idle=5 spring.datasource.initial-size=5 @@ -36,7 +48,9 @@ zuul.routes.lookup.path=/lookup/** zuul.routes.lookup.url=http://localhost:8080/lookup/ # pagehelper plugin -#pagehelper.helperDialect=sqlite +# force 'mysql' for HerdDB +#pagehelper.helperDialect=mysql + # DEBUG print execute sql logging.level.com.manager.=DEBUG