|
|
|
@ -3,8 +3,7 @@ package com.fr.plugin.db.redis.core;
|
|
|
|
|
import com.fr.stable.ParameterProvider; |
|
|
|
|
import com.fr.data.AbstractDataModel; |
|
|
|
|
import com.fanruan.api.log.LogKit; |
|
|
|
|
import com.fr.plugin.PluginLicense; |
|
|
|
|
import com.fr.plugin.PluginLicenseManager; |
|
|
|
|
import com.fanruan.api.runtime.PluginKit; |
|
|
|
|
import com.fr.plugin.db.redis.core.emb.Redis; |
|
|
|
|
import com.fr.plugin.db.redis.core.visit.VisitorFactory; |
|
|
|
|
import com.fr.plugin.db.redis.util.RedisUtils; |
|
|
|
@ -19,8 +18,7 @@ public class RedisTableDataModel extends AbstractDataModel {
|
|
|
|
|
private List<List<Object>> data; |
|
|
|
|
|
|
|
|
|
public RedisTableDataModel(Calculator calculator, Parameter[] ps, RedisDatabaseConnection mc, int dbIndex, String query, String script, int rowCount) { |
|
|
|
|
PluginLicense pluginLicense = PluginLicenseManager.getInstance().getPluginLicenseByID(RedisConstants.PLUGIN_ID); |
|
|
|
|
if (pluginLicense.isAvailable()) { |
|
|
|
|
if (PluginKit.isCurrentPluginAvailable()) { |
|
|
|
|
initRedisData(calculator, ps, mc, dbIndex, query, script, rowCount); |
|
|
|
|
} else { |
|
|
|
|
throw new RuntimeException("Redis Plugin License Expired!"); |
|
|
|
|