git.useribm.hu - mediacube.git/blob

   1 package hu.user.mediacube.executors.tests;\r
   2 \r
   3 import java.sql.Connection;\r
   4 import java.sql.SQLException;\r
   5 \r
   6 import org.junit.AfterClass;\r
   7 import org.junit.BeforeClass;\r
   8 import org.junit.Test;\r
   9 \r
  10 import user.jobengine.db.IItemManager;\r
  11 import user.jobengine.db.ItemManager;\r
  12 import user.jobengine.db.Media;\r
  13 import user.jobengine.server.IJobRuntime;\r
  14 import user.jobengine.server.JobRuntime;\r
  15 import user.jobengine.server.steps.AttachLowresStep;\r
  16 \r
  17 public class SupportAttachLowres {\r
  18         protected static IItemManager manager = null;\r
  19         private static final String LOWRES_ROOT = "//10.11.1.90/data/lowres";\r
  20         private static final String LOWRES_OUTPUT = "//10.11.1.100/Promise/TRANSCODER/FFASTRANSCODER/Out";\r
  21 \r
  22         private static final long[] duplicateLength = { 0 };\r
  23 \r
  24         @BeforeClass\r
  25         static public void setUpConnection() {\r
  26                 //              System.setProperty("jobengine.nosql.db.url", "jdbc:db2://10.11.1.90:50000/mc:retrieveMessagesFromServerOnGetMessage=true;");\r
  27                 //              System.setProperty("jobengine.nosql.db.user", "db2admin");\r
  28                 //              System.setProperty("jobengine.nosql.db.password", "password");\r
  29                 //              System.setProperty(ItemManager.DBURL, "jdbc:db2://10.11.1.90:50000/mc:retrieveMessagesFromServerOnGetMessage=true;");\r
  30                 //              System.setProperty(ItemManager.DBUSERNAME, "db2admin");\r
  31                 //              System.setProperty(ItemManager.DBPASSWORD, "password");\r
  32                 manager = new ItemManager();\r
  33                 manager.connect();\r
  34         }\r
  35 \r
  36         @AfterClass\r
  37         static public void tearDownConnection() {\r
  38                 manager.disconnect();\r
  39         }\r
  40 \r
  41         @Test\r
  42         public void process() throws SQLException {\r
  43                 final Connection[] con = { null };\r
  44                 final AttachLowresStep step = new AttachLowresStep();\r
  45                 final IJobRuntime runtime = new JobRuntime();\r
  46                 runtime.setPersister(manager);\r
  47 \r
  48                 manager.executeQuery("select mediaid from vw_mediafiles where mediafilecount = 1", rs -> {\r
  49                         long mediaId = rs.getLong("mediaId");\r
  50                         Media m = manager.getMedia(mediaId);\r
  51                         try {\r
  52                                 step.run(null, runtime, new Object[] { m, LOWRES_OUTPUT, LOWRES_ROOT });\r
  53                         } catch (Throwable e) {\r
  54                                 System.out.println("Error: " + e.getMessage());\r
  55                         }\r
  56                         return true;\r
  57                 }, null);\r
  58 \r
  59                 con[0].close();\r
  60         }\r
  61 \r
  62 }\r