import java.util.List;\r
import org.onap.holmes.common.api.entity.CorrelationRule;\r
import org.onap.holmes.common.exception.CorrelationException;\r
-import org.onap.holmes.rulemgt.db.mapper.CorrelationRuleMapper;\r
+import org.onap.holmes.common.utils.CorrelationRuleMapper;\r
import org.skife.jdbi.v2.sqlobject.Bind;\r
import org.skife.jdbi.v2.sqlobject.BindBean;\r
import org.skife.jdbi.v2.sqlobject.GetGeneratedKeys;\r
public abstract class CorrelationRuleDao {\r
\r
@GetGeneratedKeys\r
- @SqlUpdate("INSERT INTO APLUS_RULE (NAME,CTRLLOOP,DESCRIPTION,ENABLE,TEMPLATEID,ENGINETYPE,CREATOR,UPDATOR,PARAMS,CONTENT ,VENDOR,CREATETIME,UPDATETIME,ENGINEID,PACKAGE,RID) VALUES (:name,:closedControlLoopName,:description,:enabled,:templateID,:engineType,:creator,:modifier,:params,:content,:vendor,:createTime,:updateTime,:engineID,:packageName,:rid)")\r
+ @SqlUpdate("INSERT INTO APLUS_RULE (NAME,CTRLLOOP,DESCRIPTION,ENABLE,TEMPLATEID,ENGINETYPE,CREATOR,UPDATOR,PARAMS,CONTENT ,VENDOR,CREATETIME,UPDATETIME,ENGINEID,PACKAGE,RID, ENGINEINSTANCE) VALUES (:name,:closedControlLoopName,:description,:enabled,:templateID,:engineType,:creator,:modifier,:params,:content,:vendor,:createTime,:updateTime,:engineID,:packageName,:rid,:engineInstance)")\r
protected abstract String addRule(@BindBean CorrelationRule correlationRule);\r
\r
- @SqlUpdate("UPDATE APLUS_RULE SET CTRLLOOP=:closedControlLoopName,DESCRIPTION=:description,ENABLE=:enabled,CONTENT=:content,UPDATOR=:modifier,UPDATETIME=:updateTime, PACKAGE=:packageName WHERE RID=:rid")\r
+ @SqlUpdate("UPDATE APLUS_RULE SET CTRLLOOP=:closedControlLoopName,DESCRIPTION=:description,ENABLE=:enabled,CONTENT=:content,UPDATOR=:modifier,UPDATETIME=:updateTime, PACKAGE=:packageName, ENGINEINSTANCE=:engineInstance WHERE RID=:rid")\r
protected abstract int updateRuleByRid(@BindBean CorrelationRule correlationRule);\r
\r
@SqlUpdate("DELETE FROM APLUS_RULE WHERE RID=:rid")\r
@SqlQuery("SELECT * FROM APLUS_RULE WHERE NAME=:name")\r
protected abstract CorrelationRule queryRuleByName(@Bind("name") String name);\r
\r
+ @SqlQuery("SELECT * FROM APLUS_RULE WHERE enable=:enable")\r
+ public abstract List<CorrelationRule> queryRuleByEnable(@Bind("enable") int enable);\r
+\r
+ @SqlQuery("SELECT * FROM APLUS_RULE WHERE engineinstance=:engineinstance")\r
+ public abstract List<CorrelationRule> queryRuleByEngineInstance(@Bind("engineinstance") String engineinstance);\r
+\r
+ public List<CorrelationRule> queryRuleByRuleEngineInstance(String enginetype) {\r
+ return queryRuleByEngineInstance(enginetype);\r
+ }\r
+\r
+ public List<CorrelationRule> queryRuleByRuleEnable(int enable) {\r
+ return queryRuleByEnable(enable);\r
+ }\r
+\r
+\r
private void deleteRule2DbInner(CorrelationRule correlationRule) {\r
String name = correlationRule.getName() != null ? correlationRule.getName().trim() : "";\r
String rid = correlationRule.getRid() != null ? correlationRule.getRid().trim() : "";\r