<stringAttribute key="org.eclipse.jdt.launching.JRE_CONTAINER" value="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8"/>\r
<stringAttribute key="org.eclipse.jdt.launching.PROGRAM_ARGUMENTS" value="-os ${target.os} -ws ${target.ws} -arch ${target.arch} -nl ${target.nl} -consoleLog -console"/>\r
<stringAttribute key="org.eclipse.jdt.launching.SOURCE_PATH_PROVIDER" value="org.eclipse.pde.ui.workbenchClasspathProvider"/>\r
-<stringAttribute key="org.eclipse.jdt.launching.VM_ARGUMENTS" value="-Djavax.ws.rs.ext.RuntimeDelegate=org.jboss.resteasy.spi.ResteasyProviderFactory -Dorg.eclipse.epp.logging.aeri.skipReports=true -Declipse.ignoreApp=true -Dosgi.noShutdown=true -Djobengine.jobsteps.root="${workspace_loc}/user.jobengine.executors/config" -Djobengine.jobtemplates.root="${workspace_loc}/user.jobengine.executors/jobtemplates" -Djobengine.db.url=jdbc:db2://10.228.198.1:50000/mediaarc:retrieveMessagesFromServerOnGetMessage=true; -Djobengine.db.user=db2admin -Djobengine.db.password=password -Djobengine.loglevel=INFO -Dlog4j.configurationFile="${workspace_loc}/-configuration/log4j2.xml" -Djobengine.jobsteps.alternate.root="${workspace_loc}/user.jobengine.executors/bin/" -Djetty.home="${workspace_loc:}/-configuration/jetty" -Djetty.etc.config.urls=etc/user-jetty.xml,etc/user-jetty-ssl.xml,etc/user-jetty-ssl-context.xml,,etc/user-jetty-http.xml,etc/user-jetty-https.xml -Dorg.eclipse.jetty.webapp.basetempdir=c:\temp\jetty -Djava.io.tmpdir=c:\temp\jetty -Djobengine.octopus.api.address=http://10.10.1.11/api/v1 -Djobengine.octopus.api.user=mam -Djobengine.octopus.api.password=napocska -Djobengine.nosql.db.url=jdbc:db2://10.228.198.1:50000/mccache:retrieveMessagesFromServerOnGetMessage=true; -Djobengine.nosql.db.user=db2admin -Djobengine.nosql.db.password=password -Djobengine.nosql.db.schema=test -Djobengine.selenio.address=http://10.10.1.71:44000/TranscodeMgrWS?wsdl -Djobengine.selenio.projectfilepath=\\10.10.1.71\Data\Blueprints\MP4_H264_AAC.zenium -Djobengine.jobscheduling.config="${workspace_loc}/-configuration/scheduledjobs.json" -Djobengine.nexio.db.url=jdbc:sqlserver://10.10.1.59:1433;databaseName=NXDB; -Djobengine.nexio.db.user=sa -Djobengine.nexio.db.password=resolve -Djobengine.planair.db.url=jdbc:sqlserver://10.10.1.45;databaseName=PA_Echo; -Djobengine.planair.db.user=MAM -Djobengine.planair.db.password=Echotv.hu -Dnexio.host=192.168.0.12 -Djobengine.nexio.name=testnexioclips -Dnexio.useMOSGateway=false -Dnexio.disable=true -Djobengine.octopus.rundowns.name=rundowns181026 -Djobengine.octopus.storyfolders.name=storyfolders181026 -Djobengine.octopus.stories.name=stories181026 -Djobengine.maestro.config="${workspace_loc}/-configuration/maestro.json" -Djobengine.mediacube.config="${workspace_loc}/-configuration/mediacube.json" -Dgui.statistics.disable=true -Dgui.help.disable=true -Dgui.editor.disable=true"/>\r
+<stringAttribute key="org.eclipse.jdt.launching.VM_ARGUMENTS" value="-Djavax.ws.rs.ext.RuntimeDelegate=org.jboss.resteasy.spi.ResteasyProviderFactory -Dorg.eclipse.epp.logging.aeri.skipReports=true -Declipse.ignoreApp=true -Dosgi.noShutdown=true -Djobengine.jobsteps.root="${workspace_loc}/user.jobengine.executors/config" -Djobengine.jobtemplates.root="${workspace_loc}/user.jobengine.executors/jobtemplates" -Djobengine.db.url=jdbc:db2://10.228.198.1:50000/mediaarc:retrieveMessagesFromServerOnGetMessage=true; -Djobengine.db.user=db2admin -Djobengine.db.password=password -Djobengine.loglevel=INFO -Dlog4j.configurationFile="${workspace_loc}/-configuration/log4j2.xml" -Djobengine.jobsteps.alternate.root="${workspace_loc}/user.jobengine.executors/bin/" -Djetty.home="${workspace_loc:}/-configuration/jetty" -Djetty.etc.config.urls=etc/user-jetty.xml,etc/user-jetty-ssl.xml,etc/user-jetty-ssl-context.xml,,etc/user-jetty-http.xml,etc/user-jetty-https.xml -Dorg.eclipse.jetty.webapp.basetempdir=c:\temp\jetty -Djava.io.tmpdir=c:\temp\jetty -Djobengine.octopus.api.address=http://10.10.1.11/api/v1 -Djobengine.octopus.api.user=mam -Djobengine.octopus.api.password=napocska -Djobengine.nosql.db.url=jdbc:db2://10.228.198.1:50000/mccache:retrieveMessagesFromServerOnGetMessage=true; -Djobengine.nosql.db.user=db2admin -Djobengine.nosql.db.password=password -Djobengine.nosql.db.schema=test -Djobengine.selenio.address=http://10.10.1.71:44000/TranscodeMgrWS?wsdl -Djobengine.selenio.projectfilepath=\\10.10.1.71\Data\Blueprints\MP4_H264_AAC.zenium -Djobengine.jobscheduling.config="${workspace_loc}/-configuration/scheduledjobs.json" -Djobengine.nexio.db.url=jdbc:sqlserver://10.10.1.59:1433;databaseName=NXDB; -Djobengine.nexio.db.user=sa -Djobengine.nexio.db.password=resolve -Djobengine.planair.db.url=jdbc:sqlserver://10.10.1.45;databaseName=PA_Echo; -Djobengine.planair.db.user=MAM -Djobengine.planair.db.password=Echotv.hu -Dnexio.host=192.168.0.12 -Djobengine.nexio.name=testnexioclips -Dnexio.useMOSGateway=false -Dnexio.disable=true -Djobengine.octopus.rundowns.name=rundowns181026 -Djobengine.octopus.storyfolders.name=storyfolders181026 -Djobengine.octopus.stories.name=stories181026 -Djobengine.maestro.config="${workspace_loc}/-configuration/maestro.json" -Djobengine.mediacube.config="${workspace_loc}/-configuration/mediacube.json" -Dgui.statistics.disable=true -Dgui.help.disable=true -Dgui.editor.disable=true -Djobengine.mediafinder.external=true"/>\r
<stringAttribute key="pde.version" value="3.3"/>\r
<booleanAttribute key="show_selected_only" value="false"/>\r
<stringAttribute key="target_bundles" value="cglib@default:default,com.fasterxml.jackson.core.jackson-annotations@default:default,com.fasterxml.jackson.core.jackson-core@default:default,com.fasterxml.jackson.core.jackson-databind@default:default,com.fasterxml.jackson.datatype.jackson-datatype-joda@default:default,com.fasterxml.jackson.jaxrs.jackson-jaxrs-base@default:default,com.fasterxml.jackson.jaxrs.jackson-jaxrs-json-provider@default:default,com.ibm.db2jcc4@default:default,com.ibm.nosql@default:default,com.microsoft.sqlserver.sqljdbc@default:default,humble.video.noarch@default:default,humble.video.windows@default:default,javax.annotation-api@default:default,javax.mail@default:default,javax.servlet-api@default:default,javax.ws.rs-api@default:default,jcifs@default:default,joda-time@default:default,org.apache.aries.spifly.dynamic.bundle@default:default,org.apache.aries.util@default:default,org.apache.commons.beanutils@default:default,org.apache.commons.collections@default:default,org.apache.commons.digester@default:default,org.apache.commons.io@default:default,org.apache.commons.lang@default:default,org.apache.commons.logging@default:default,org.apache.commons.net@default:default,org.apache.felix.gogo.command@default:default,org.apache.felix.gogo.runtime@default:default,org.apache.felix.gogo.shell@default:default,org.apache.httpcomponents.httpclient@default:default,org.apache.httpcomponents.httpcore@default:default,org.apache.logging.log4j.api@1:true,org.apache.logging.log4j.core@default:default,org.apache.logging.log4j.slf4j-impl@default:default,org.apache.servicemix.bundles.quartz@default:default,org.eclipse.equinox.common@2:true,org.eclipse.equinox.console@default:default,org.eclipse.equinox.ds@1:true,org.eclipse.equinox.util@default:default,org.eclipse.jetty.deploy@default:default,org.eclipse.jetty.http@default:default,org.eclipse.jetty.io@default:default,org.eclipse.jetty.osgi.boot@default:true,org.eclipse.jetty.schemas@default:default,org.eclipse.jetty.security@default:default,org.eclipse.jetty.server@default:default,org.eclipse.jetty.servlet@default:default,org.eclipse.jetty.util@default:default,org.eclipse.jetty.webapp@default:default,org.eclipse.jetty.websocket.api@default:default,org.eclipse.jetty.websocket.client@default:default,org.eclipse.jetty.websocket.common@default:default,org.eclipse.jetty.websocket.server@default:default,org.eclipse.jetty.websocket.servlet@default:default,org.eclipse.jetty.xml@default:default,org.eclipse.osgi.services@default:default,org.eclipse.osgi@-1:true,org.hamcrest.core@default:default,org.jboss.resteasy.client@default:default,org.jboss.resteasy.jaxrs@default:default,org.jmock.junit4@default:default,org.jmock@default:default,org.junit@default:default,org.mybatis.mybatis@default:default,org.objectweb.asm.commons@default:default,org.objectweb.asm.tree@default:default,org.objectweb.asm@default:default,slf4j.api@default:default,slf4j.simple@default:false"/>\r
List<IndexerDescription> indexerDescriptions = mapper.selectAll();\r
int i = 0;\r
LogFactory.useLog4J2Logging();\r
+\r
+ int logStep = indexerDescriptions.size() / 10;\r
+\r
for (IndexerDescription indexerDescription : indexerDescriptions) {\r
\r
String description = mapper.selectDescription(indexerDescription);\r
indexerDescription.setDescription(description);\r
//logger.info("{}", indexerDescription);\r
- boolean processed = ++i % 10 == 0;\r
+ boolean putLog = ++i % logStep == 0;\r
+ boolean lastRow = i == indexerDescriptions.size();\r
try {\r
indexer.index(indexerDescription);\r
- if (i == indexerDescriptions.size())\r
+\r
+ if (putLog || lastRow)\r
+ logger.info("Processed {} / {}", i, indexerDescriptions.size());\r
+\r
+ if (lastRow) {\r
indexer.commit();\r
+ logger.error("Index committed");\r
+ }\r
} catch (IOException e) {\r
logger.error("Can not create index, caused by {} : {}", e.getClass().getSimpleName(), e.getMessage(), e);\r
break;\r
}\r
\r
- if (processed) {\r
- logger.info("Processed {} / {}", i, indexerDescriptions.size());\r
- }\r
-\r
- }\r
- try {\r
- indexer.commit();\r
- } catch (IOException e) {\r
- logger.error("Commit error", e);\r
}\r
}\r
\r
import hu.user.mediacube.indexer.lucene.LuceneIndexer;\r
\r
@RestController\r
-@RequestMapping("rest")\r
+@RequestMapping("indexer")\r
public class RESTController {\r
\r
private static Logger logger = LoggerFactory.getLogger(RESTController.class);\r
+server.port=8081\r
spring.main.banner-mode=off\r
spring.output.ansi.enabled=always\r
spring.datasource.driver-class-name=com.ibm.db2.jcc.DB2Driver\r
logger.error(marker,\r
"Az '{}' állomány .catched jelző állománya nem törölhető. Az újabb archiválási kísérlethez annak kézi eltávolítása szükséges!",\r
sourceMediaFile.getName());\r
+ mediaCubeMedia.remove();\r
} else {\r
saveMetadata(mediaCubeMedia, sourceMediaFile, existingMediaId);\r
logger.info(marker, "Az '{}' archiválása sikeres.", sourceFileName);\r
Service-Component: OSGI-INF/component.xml
Bundle-ActivationPolicy: lazy
Import-Package: com.fasterxml.jackson.annotation;version="2.4.5",
- org.apache.logging.log4j;version="2.8.2"
+ javax.ws.rs.client,
+ javax.ws.rs.core,
+ org.apache.logging.log4j;version="2.8.2",
+ org.jboss.resteasy.client.jaxrs
Export-Package: user.jobengine.db
private void initalize() {\r
ItemManager.getInstance().traceIn();\r
if (attributes == null) {\r
- if (getItemType() != null) {\r
+ if (getItemType() != null && !getItemType().getIsStatic()) {\r
attributes = new HashMap<String, Object>();\r
List<Metadata> metadatas = getItemType().getMetadatas();\r
if (metadatas != null) {\r
import user.commons.IEntityBase;\r
\r
public class DynamicAttributesDAO extends EntityBaseDAO {\r
- private Converter converter;\r
-\r
public class BooleanConverter implements IValueConverter {\r
\r
@Override\r
}\r
}\r
\r
+ private Converter converter;\r
+\r
public DynamicAttributesDAO(ItemManager manager) {\r
super(manager);\r
HashMap<BaseType, IValueConverter> converters = new HashMap<BaseType, IValueConverter>();\r
\r
}\r
\r
- void addAsDomain(DefaultContext context, IEntityBase entity, Metadata metadata, List<Domain> domains, boolean modify) throws SQLException {\r
- DomainIndexDAO indexdao = (DomainIndexDAO) manager.getBaseDAO(DomainIndex.class);\r
-\r
- if (domains != null && domains.size() > 0) {\r
- logger.debug("Adding domain attribute " + metadata.getMetadataElement().getName() + " , value count: " + domains.size());\r
- long domainCategoryId = metadata.getMetadataElement().getDomainCategoryId();\r
- DomainCategory dc = (DomainCategory) manager.get(DomainCategory.class, domainCategoryId);\r
- dc.setDomains(domains);\r
- DomainDAO dao = (DomainDAO) manager.getBaseDAO(Domain.class);\r
- dao.addMissing(context, dc);\r
- if (modify)\r
- indexdao.removeAll(context, entity, metadata);\r
- indexdao.addAll(context, entity, metadata, dc);\r
- } else {\r
- if (modify)\r
- indexdao.removeAll(context, entity, metadata);\r
- }\r
- }\r
-\r
@Override\r
public void add(DefaultContext context, IEntityBase entity) {\r
manager.traceIn();\r
da.checkParameter("ID", da.getId(), false);\r
Map<String, Object> attributes = da.getAttributes();\r
ItemType itemType = (ItemType) manager.get(ItemType.class, da.getItemTypeId());\r
- if (itemType != null) {\r
+ if (itemType != null && !itemType.getIsStatic()) {\r
List<Metadata> metadatas = itemType.getMetadatas();\r
if (metadatas != null) {\r
for (Metadata metadata : metadatas) {\r
manager.traceOut();\r
}\r
\r
- @SuppressWarnings("unchecked")\r
- Domains getAsDomain(DefaultContext context, IEntityBase entity, Metadata metadata) throws SQLException {\r
- logger.debug("Reading domain attribute " + metadata.getMetadataElement().getName());\r
- DomainDAO dao = (DomainDAO) manager.getBaseDAO(Domain.class);\r
- List<Domain> domains = (List<Domain>) (List<?>) dao.getAll(context, entity, metadata);\r
- Domains result = null;\r
- if (domains != null)\r
- result = new Domains(domains);\r
- return result;\r
+ void addAsDomain(DefaultContext context, IEntityBase entity, Metadata metadata, List<Domain> domains, boolean modify) throws SQLException {\r
+ DomainIndexDAO indexdao = (DomainIndexDAO) manager.getBaseDAO(DomainIndex.class);\r
+\r
+ if (domains != null && domains.size() > 0) {\r
+ logger.debug("Adding domain attribute " + metadata.getMetadataElement().getName() + " , value count: " + domains.size());\r
+ long domainCategoryId = metadata.getMetadataElement().getDomainCategoryId();\r
+ DomainCategory dc = (DomainCategory) manager.get(DomainCategory.class, domainCategoryId);\r
+ dc.setDomains(domains);\r
+ DomainDAO dao = (DomainDAO) manager.getBaseDAO(Domain.class);\r
+ dao.addMissing(context, dc);\r
+ if (modify)\r
+ indexdao.removeAll(context, entity, metadata);\r
+ indexdao.addAll(context, entity, metadata, dc);\r
+ } else {\r
+ if (modify)\r
+ indexdao.removeAll(context, entity, metadata);\r
+ }\r
}\r
\r
void get(IEntityBase entity) {\r
manager.traceOut();\r
}\r
\r
+ @SuppressWarnings("unchecked")\r
+ Domains getAsDomain(DefaultContext context, IEntityBase entity, Metadata metadata) throws SQLException {\r
+ logger.debug("Reading domain attribute " + metadata.getMetadataElement().getName());\r
+ DomainDAO dao = (DomainDAO) manager.getBaseDAO(Domain.class);\r
+ List<Domain> domains = (List<Domain>) (List<?>) dao.getAll(context, entity, metadata);\r
+ Domains result = null;\r
+ if (domains != null)\r
+ result = new Domains(domains);\r
+ return result;\r
+ }\r
+\r
@Override\r
public void modify(DefaultContext context, IEntityBase entity) {\r
manager.traceIn();\r
manager.traceOut();\r
}\r
\r
- void removeAsDomain(DefaultContext context, IEntityBase entity, Metadata metadata) throws SQLException {\r
- logger.debug("Removing domain attribute " + metadata.getMetadataElement().getName());\r
- DomainIndexDAO indexdao = (DomainIndexDAO) manager.getBaseDAO(DomainIndex.class);\r
- indexdao.removeAll(context, entity, metadata);\r
- }\r
-\r
@Override\r
public void remove(DefaultContext context, IEntityBase entity) {\r
manager.traceIn();\r
}\r
manager.traceOut();\r
}\r
+\r
+ void removeAsDomain(DefaultContext context, IEntityBase entity, Metadata metadata) throws SQLException {\r
+ logger.debug("Removing domain attribute " + metadata.getMetadataElement().getName());\r
+ DomainIndexDAO indexdao = (DomainIndexDAO) manager.getBaseDAO(DomainIndex.class);\r
+ indexdao.removeAll(context, entity, metadata);\r
+ }\r
}\r
* JobEngine adatbázis modell kezelő API.\r
*/\r
public class ItemManager extends MemoryCache implements IItemManager {\r
+ private static final String JOBENGINE_MEDIAFINDER_EXTERNAL = "jobengine.mediafinder.external";\r
private static final Logger logger = LogManager.getLogger();\r
public static String DBURL = "jobengine.db.url";\r
public static String DBUSERNAME = "jobengine.db.user";\r
String dbPassword = null;\r
\r
private SignalServer signalServer;\r
- private MediaFinder finder;\r
- private LuceneMediaFinder luceneFinder;\r
+ private IMediaFinder finder;\r
\r
public ItemManager() {\r
initializeItemManager(signalServer);\r
// System.getProperty("jobengine.mediafinder.external") == true\r
// System.getProperty("jobengine.mediafinder.external.url")\r
\r
- if (System.getProperty("jobengine.mediafinder.external") == "false") {\r
- finder = new MediaFinder(this);\r
+ boolean useLucene = false;\r
+ try {\r
+ useLucene = Boolean.parseBoolean(System.getProperty(JOBENGINE_MEDIAFINDER_EXTERNAL));\r
+ } catch (Exception e) {\r
+ logger.info("Configuration property {} mising", JOBENGINE_MEDIAFINDER_EXTERNAL);\r
+ }\r
+\r
+ if (useLucene) {\r
+ finder = new LuceneMediaFinder();\r
} else {\r
- luceneFinder = new LuceneMediaFinder();\r
+ finder = new MediaFinder(this);\r
}\r
}\r
\r
public SearchResult<ArchivedMedia> search(String criteria, List<String> searchFilters, String orderBy, boolean orderAscending, int fromResult,\r
int toResult) {\r
traceIn();\r
- SearchResult<ArchivedMedia> result = null;\r
- if (System.getProperty("jobengine.mediafinder.external") == "false") {\r
- result = finder.search(criteria, searchFilters, orderBy, orderAscending, fromResult, toResult);\r
- } else {\r
- result = luceneFinder.search(criteria, searchFilters, orderBy, orderAscending, fromResult, toResult);\r
- }\r
+ SearchResult<ArchivedMedia> result = finder.search(criteria, searchFilters, orderBy, orderAscending, fromResult, toResult);\r
traceOut();\r
return result;\r
}\r
\r
import java.util.List;\r
\r
-import org.jboss.resteasy.client.jaxrs.BasicAuthentication;\r
+import javax.ws.rs.client.WebTarget;\r
+import javax.ws.rs.core.Response;\r
+\r
import org.jboss.resteasy.client.jaxrs.ResteasyClient;\r
import org.jboss.resteasy.client.jaxrs.ResteasyClientBuilder;\r
\r
public class LuceneMediaFinder implements IMediaFinder {\r
\r
+ private WebTarget webTarget;\r
+ private String apiAddress = "http://localhost:8081/indexer";\r
+ private String apiPath = "/search/*.*/0/10/1/0";\r
+\r
@Override\r
public SearchResult<ArchivedMedia> search(String criteria, List<String> searchFilters, String orderBy, boolean orderAscending, int fromResult,\r
int toResult) {\r
// TODO Auto-generated method stub\r
ResteasyClient client = new ResteasyClientBuilder().build();\r
- webTarget = client.target(apiAddress).register(new BasicAuthentication(apiUser, apiPwd));\r
-\r
+ webTarget = client.target(apiAddress);\r
+ WebTarget target = webTarget.path(apiPath);\r
+ Response response = target.request().get();\r
return null;\r
}\r
\r
private String parameter = null;
/**
- * Serializációs technikával másolatot készít egy Metadata objektumról. A
- * DynamicAttributes osztály használja.
- *
- * @return Metadata objektum másolata.
+ * Serializ�ci�s technik�val m�solatot k�sz�t egy Metadata objektumr�l. A DynamicAttributes oszt�ly haszn�lja.
+ *
+ * @return Metadata objektum m�solata.
*/
Metadata copy() {
Metadata result = null;
return result;
}
+ public String getFieldName() {
+ String fieldName = null;
+ if (staticTable != null)
+ fieldName = String.format(getPrefix() + getSqlField());
+ else
+ fieldName = String.format("%1$s.%2$s", getTableName(), getColumnName());
+ return fieldName;
+ }
+
public GuiType getGuiType() {
return guiType;
}
return pojoField;
}
+ public String getPrefix() {
+ String result = null;
+ if (staticTable == StaticTables.MEDIA)
+ result = String.format("mm.");
+ if (staticTable == StaticTables.ITEM)
+ result = String.format("ii.");
+ if (staticTable == StaticTables.FOLDER)
+ result = String.format("f.");
+ return result;
+ }
+
public String getRemoveSQL() {
ItemType itemType = (ItemType) ItemManager.getInstance().retrieveCached(ItemType.class, getItemTypeId());
String tableName = itemType.getTableName();
return getStaticTable() != null ? null : "METADATA_" + getId();
}
- public String getPrefix() {
- String result = null;
- if (staticTable == StaticTables.MEDIA)
- result = String.format("mm.");
- if (staticTable == StaticTables.ITEM)
- result = String.format("ii.");
- if (staticTable == StaticTables.FOLDER)
- result = String.format("f.");
- return result;
- }
-
- public String getFieldName() {
- String fieldName = null;
- if (staticTable != null)
- fieldName = String.format(getPrefix() + getSqlField());
- else
- fieldName = String.format("%1$s.%2$s", getTableName(), getColumnName());
- return fieldName;
- }
-
// public Object getValue() {
// return value;
// }
Bundle-SymbolicName: user.jobengine.osgi.server;singleton:=true
Bundle-Version: 1.0.0
Service-Component: OSGI-INF/component.xml, OSGI-INF/componentBinder.xml
-Import-Package: com.fasterxml.jackson.annotation;version="2.4.5",
- com.fasterxml.jackson.core;version="2.4.5",
- com.fasterxml.jackson.databind;version="2.4.5",
- com.fasterxml.jackson.databind.util;version="2.4.5",
- com.fasterxml.jackson.datatype.joda;version="2.4.5",
- com.fasterxml.jackson.jaxrs.json;version="2.4.5",
- javax.servlet;version="3.1.0",
+Import-Package: javax.servlet;version="3.1.0",
javax.servlet.http;version="3.1.0",
- javax.ws.rs.client,
- javax.ws.rs.core;version="2.0.1",
org.apache.logging.log4j;version="2.8.2",
org.apache.logging.log4j.message;version="2.8.2",
org.eclipse.core.runtime.adaptor,
org.eclipse.osgi.framework.console;version="1.1.0",
- org.jboss.resteasy.client.jaxrs,
- org.jboss.resteasy.plugins.providers,
- org.jboss.resteasy.spi,
- org.joda.time;version="2.2.0",
- org.joda.time.base;version="2.2.0",
org.osgi.framework;version="1.5.0",
org.osgi.framework.wiring;version="1.2.0",
org.osgi.util.tracker;version="1.4.0",
--- /dev/null
+package user.jobengine.server.IT;\r
+\r
+import java.util.Date;\r
+\r
+import org.junit.AfterClass;\r
+import org.junit.BeforeClass;\r
+import org.junit.Test;\r
+\r
+import user.commons.logging.LogUtils;\r
+import user.jobengine.db.IItemManager;\r
+import user.jobengine.db.Item;\r
+import user.jobengine.db.ItemManager;\r
+import user.jobengine.db.Media;\r
+import user.jobengine.db.MediaFile;\r
+\r
+public class SupportTest {\r
+ public class BD {\r
+ Date fBD;\r
+ Date nBD;\r
+ }\r
+\r
+ protected static IItemManager manager = null;\r
+\r
+ private static final String LOWRES_ROOT = "//10.10.1.27/mclowres/www/video";\r
+\r
+ private static final long[] duplicateLength = { 0 };\r
+\r
+ @BeforeClass\r
+ static public void setUpConnection() {\r
+ System.setProperty("jobengine.octopus.rundowns.name", "rundowns180620");\r
+ System.setProperty("jobengine.octopus.stories.name", "stories180620");\r
+ System.setProperty("jobengine.octopus.storyfolders.name", "storyfolders180620");\r
+\r
+ System.setProperty("jobengine.nosql.db.url", "jdbc:db2://10.228.198.1:50000/mccache:retrieveMessagesFromServerOnGetMessage=true;");\r
+ System.setProperty("jobengine.nosql.db.user", "db2admin");\r
+ System.setProperty("jobengine.nosql.db.password", "password");\r
+ System.setProperty(ItemManager.DBURL, "jdbc:db2://10.228.198.1:50000/mediaarc:retrieveMessagesFromServerOnGetMessage=true;");\r
+ System.setProperty(ItemManager.DBUSERNAME, "db2admin");\r
+ System.setProperty(ItemManager.DBPASSWORD, "password");\r
+ System.setProperty(LogUtils.LOGLEVEL, "INFO");\r
+ // System.setProperty(ItemManager.DBURL,\r
+\r
+ manager = new ItemManager();\r
+ manager.connect();\r
+ }\r
+\r
+ @AfterClass\r
+ static public void tearDownConnection() {\r
+ manager.disconnect();\r
+ }\r
+\r
+ @Test\r
+ public void mergeItemStructure() throws Exception {\r
+ Item item = manager.createItem("Default", "Item1", "Itemdesc1", "Itemhouseid1");\r
+ Media media = manager.createMedia("Default", "Media1", "Mediadesc1", "Mediahouseid1");\r
+ item.appendMedia(media);\r
+ MediaFile mf1 = manager.createMediaFile("/xxx", manager.getFileType("Lowres"), manager.getSystemStore(true), media);\r
+ MediaFile mf2 = manager.createMediaFile("/yyy", manager.getFileType("Lowres"), manager.getSystemStore(true), media);\r
+\r
+ item.add();\r
+\r
+ //manager.mergeItemStructure(item);\r
+ }\r
+\r
+}\r
https://git.useribm.hu / mediacube.git / commitdiff