package user.commons;\r
\r
/**\r
- * Commons kivétel. \r
+ * Commons kivétel.\r
*/\r
public class CommonsException extends RuntimeException {\r
private static final long serialVersionUID = -2357518580850559771L;\r
import java.util.Map;\r
\r
/**\r
- * <b>Hashtable alapú paraméter tároló.</b>\r
- * A paraméterek típus helyesen írhatóak be és vehetõek ki. \r
+ * <b>Hashtable alapú paraméter tároló.</b> A paraméterek típus helyesen\r
+ * írhatóak be és vehetőek ki.\r
*/\r
public class CommonsProperties {\r
static public void checkParameter(String name, double parameter) {\r
String msg = name + " cannot be 0.";\r
throw new IllegalArgumentException(msg);\r
}\r
- } \r
+ }\r
\r
static public void checkParameter(String name, int parameter) {\r
if (parameter == 0) {\r
public boolean getBool(String key) {\r
Object value = get(key);\r
if (!(value instanceof Boolean))\r
- throw new CommonsException("Property doesn't contains Boolean value: " + key);\r
+ throw new CommonsException("Property doesn't contain Boolean value: " + key);\r
return Boolean.parseBoolean(value.toString());\r
}\r
\r
throw new CommonsException("Property doesn't contains Integer value." + key);\r
return Integer.parseInt(value.toString());\r
}\r
- \r
+\r
public long getLong(String key) {\r
Object value = get(key);\r
if (!(value instanceof Long))\r
\r
@SuppressWarnings("serial")\r
public class FileTypeUtils {\r
- \r
+\r
private static Map<String, FileTypeInfo> fileTypes;\r
private static FileTypeInfo defaultFileTypeInfo;\r
- \r
- public static String FILETYPE_FILM = "film"; \r
- public static String FILETYPE_MUSIC = "hanganyag"; \r
- public static String FILETYPE_OTHER = "egyéb"; \r
+\r
+ public static String FILETYPE_FILM = "film";\r
+ public static String FILETYPE_MUSIC = "hanganyag";\r
+ public static String FILETYPE_OTHER = "egyéb";\r
static {\r
fileTypes = new HashMap<String, FileTypeInfo>() {\r
- { \r
+ {\r
put("avi", new FileTypeInfo(FILETYPE_FILM, true));\r
put("mpg", new FileTypeInfo(FILETYPE_FILM, true));\r
put("mp4", new FileTypeInfo(FILETYPE_FILM, true));\r
put("mp3", new FileTypeInfo(FILETYPE_MUSIC, false));\r
}\r
};\r
- \r
+\r
defaultFileTypeInfo = new FileTypeInfo(FILETYPE_OTHER, false);\r
}\r
- \r
+\r
public static FileTypeInfo get(String extension) {\r
FileTypeInfo result = defaultFileTypeInfo;\r
if (extension != null) {\r
public interface IEntityPersister {\r
\r
/***\r
- * Az adatb�zisban l�trehoz egy �j entit�st\r
+ * Az adatbázisban létrehoz egy új entitást\r
* \r
- * @param entity\r
- * Perziszt�land� objektum\r
+ * @param entity perzisztálandó objektum\r
*/\r
void add(IEntityBase entity);\r
\r
/***\r
- * Elk�r az adatb�zisb�l egy objektumot\r
+ * Elkér az adatbázisból egy objektumot\r
* \r
- * @param classInfo\r
- * Az objektum t�pusa\r
- * @param id\r
- * Egyedi azonos�t�\r
- * @return Perziszt�lt objektum p�ld�ny\r
+ * @param classInfo Az objektum típusa\r
+ * @param id Egyedi azonosító\r
+ * @return Perzisztált objektum példány\r
*/\r
IEntityBase get(Class<? extends IEntityBase> classInfo, long id);\r
\r
/***\r
- * Az adatb�zisban m�dos�t egy m�r l�tez� objektumot\r
+ * Az adatbázisban módosít egy már létező objektumot\r
* \r
- * @param entity\r
- * A perziszt�land� objektum\r
+ * @param entity A perzisztálandó objektum\r
*/\r
void modify(IEntityBase entity);\r
\r
/***\r
- * Elt�vol�t egy objektumot az adatb�zisb�l\r
+ * Eltávolít egy objektumot az adatbázisból\r
* \r
- * @param entity\r
- * Az elt�vol�tand� objektum\r
+ * @param entity Az eltávolítandó objektum\r
*/\r
void remove(IEntityBase entity);\r
\r
import java.util.concurrent.locks.AbstractQueuedSynchronizer;\r
\r
/**\r
- * Szinkronizációs õsosztály. \r
+ * Szinkronizációs ősosztály.\r
*/\r
public class Syncable extends EntityBase {\r
\r
private final Sync sync = new Sync();\r
\r
/**\r
- * Folyamat szinkronizálás blokkolásának feloldása. Unit tesztek\r
- * támogatására készült. A akkor hívódik meg, amikor a folyamat feldolgozása\r
- * véget ért egy teszt szempontjából. Ekkor a get() hívás, amit egy másik\r
- * szál korábban kezdeményezett, visszatér, feloldva az hívó szál futásának\r
- * blokkolását.\r
+ * Folyamat szinkronizálás blokkolásának feloldása. Unit tesztek támogatására\r
+ * készült. A akkor hívódik meg, amikor a folyamat feldolgozása véget ért egy\r
+ * teszt szempontjából. Ekkor a get() hívás, amit egy másik szál korábban\r
+ * kezdeményezett, visszatér, feloldva a hívó szál futásának blokkolását.\r
*/\r
public void done() {\r
sync.innerDone();\r
}\r
\r
/**\r
- * A folyamat futásának kivárása. A hívó szál addig blokkolódik, amig a\r
- * done() hívás meg nem történik, ekkor visszatér.\r
+ * A folyamat futásának kivárása. A hívó szál addig blokkolódik, amíg a done()\r
+ * hívás meg nem történik, ekkor visszatér.\r
* \r
- * @return Ellenõrzõ objektum.\r
+ * @return Ellenőrző objektum.\r
* @throws InterruptedException\r
*/\r
public Object get() throws InterruptedException {\r
import java.net.Socket;\r
\r
/**\r
- * <b>Adatcsatorna segédosztály.</b>\r
- * A kliens és a server is használja. \r
- * Az aktív/passzív átviteli módtól függõen hozza létre a kapcsolatot.\r
+ * <b>Adatcsatorna segédosztály.</b> A kliens és a szerver is használja. Az\r
+ * aktív/passzív átviteli módtól függően hozza létre a kapcsolatot.\r
* \r
* @author vasary\r
*/\r
public class DataChannel {\r
- \r
+\r
static public DataChannel fromPort(String params) {\r
final String[] p = params.split(",");\r
if (p.length < 6)\r
- throw new FtpException("Parameter not contains enough information.");\r
- \r
+ throw new FtpException("Parameter does not contain enough information.");\r
+\r
int[] values = new int[6];\r
InetAddress address = null;\r
try {\r
throw new FtpException("Parameter contains illegal port specification.");\r
}\r
int port = (values[4] << 8) + values[5];\r
- \r
+\r
return new DataChannel(address, port);\r
}\r
- \r
+\r
private InetAddress address = null;\r
private boolean passive = false;\r
- private ServerSocket passiveDataSocket = null; \r
+ private ServerSocket passiveDataSocket = null;\r
private int port = 0;\r
\r
private final String PORT = "%1$d,%2$d,%3$d,%4$d,%5$d,%6$d";\r
- \r
+\r
DataChannel() {\r
try {\r
this.passiveDataSocket = new ServerSocket(0);\r
- //this.passiveDataSocket.setReuseAddress(true); set this, if using fixed port (firewall implementation)\r
+ // this.passiveDataSocket.setReuseAddress(true); set this, if using fixed port\r
+ // (firewall implementation)\r
this.port = passiveDataSocket.getLocalPort();\r
this.address = InetAddress.getLocalHost();\r
} catch (final Exception e) {\r
- e.printStackTrace();\r
+ e.printStackTrace();\r
}\r
this.passive = true;\r
}\r
- \r
+\r
DataChannel(InetAddress address, int port) {\r
this.address = address;\r
this.port = port;\r
public InetAddress getAddress() {\r
return address;\r
}\r
- \r
+\r
private byte[] getAddressBytes() {\r
byte[] bytes = address.getAddress();\r
for (int i = 0; i < 4; i++) {\r
- if (bytes[i] < 0) \r
+ if (bytes[i] < 0)\r
bytes[i] += 256;\r
}\r
return bytes;\r
}\r
\r
public Socket getDataSocket() {\r
- Socket socket = null; \r
+ Socket socket = null;\r
try {\r
if (passive) {\r
passiveDataSocket.setSoTimeout(FtpConstants.DataSocketTimeOut);\r
}\r
\r
public Socket getClientDataSocket() {\r
- Socket socket = null; \r
+ Socket socket = null;\r
try {\r
if (passive) {\r
passiveDataSocket.setSoTimeout(FtpConstants.DataSocketTimeOut);\r
}\r
return socket;\r
}\r
- \r
+\r
public int getPort() {\r
return port;\r
}\r
- \r
+\r
public String getPortString() {\r
byte[] bytes = getAddressBytes();\r
- return String.format(PORT, bytes[0], bytes[1], bytes[2], bytes[3], (getPort() & 0xff00) >> 8, getPort() & 0x00ff); \r
+ return String.format(PORT, bytes[0], bytes[1], bytes[2], bytes[3], (getPort() & 0xff00) >> 8,\r
+ getPort() & 0x00ff);\r
}\r
\r
public boolean isPassive() {\r
import java.util.EventObject;\r
\r
/**\r
- * <b>File eseménykezelõ.</b>\r
+ * <b>File eseménykezelő.</b>\r
* \r
* @author vasary\r
*/\r
private static final long serialVersionUID = 1L;\r
private int percentComplete = 0;\r
private boolean cancel = false;\r
- \r
+\r
public FileEvent(Object source, int percent) {\r
- super(source);\r
- this.percentComplete = percent;\r
- }\r
+ super(source);\r
+ this.percentComplete = percent;\r
+ }\r
\r
public void cancel() {\r
cancel = true;\r
}\r
\r
void setProgress(int percent) {\r
- this.percentComplete = percent;\r
+ this.percentComplete = percent;\r
}\r
}\r
-\r
package user.commons.ftp;\r
\r
import java.util.EventListener;\r
+\r
/**\r
- * <b>Ftp kliens file események.</b>\r
- * Egy file fel- és letöltésekor hívódik meg. \r
- * Tartalmazza a folyamat százalékos állapotát.\r
- * Visszajelzéssel megszakítható a folyamat.\r
+ * <b>Ftp kliens file események.</b> Egy file fel- és letöltésekor hívódik meg.\r
+ * Tartalmazza a folyamat százalékos állapotát. Visszajelzéssel megszakítható a\r
+ * folyamat.\r
* \r
* @author vasary\r
*/\r
public interface FileEventListener extends EventListener {\r
- public void fileUpload(FileEvent evt);\r
- public void fileDownload(FileEvent evt);\r
-}\r
+ public void fileUpload(FileEvent evt);\r
\r
+ public void fileDownload(FileEvent evt);\r
+}\r
import java.util.List;\r
\r
import javax.swing.event.EventListenerList;\r
+\r
import user.commons.ftp.FtpConstants.Command;\r
\r
/**\r
- * <b>Ftp kliens.</b>\r
- * A protokolnál magasabb szintû tagfüggvények támogatják az egyszerû fájl átvitelt.\r
- * \r
+ * <b>Ftp kliens.</b> A protokolnál magasabb szintű tagfüggvények támogatják az\r
+ * egyszerű fájlátvitelt.\r
+ * \r
* @author vasary\r
*/\r
public class FtpClient {\r
private DataChannel dataChannel = null;\r
private boolean passive = false;\r
private EventListenerList listenerList = new EventListenerList();\r
- \r
+\r
public FtpClient() {\r
}\r
\r
- public void addFileListener(FileEventListener listener) {\r
- listenerList.add(FileEventListener.class, listener);\r
- }\r
+ public void addFileListener(FileEventListener listener) {\r
+ listenerList.add(FileEventListener.class, listener);\r
+ }\r
\r
- public void connect(String host, int port) {\r
- try\r
- {\r
+ public void connect(String host, int port) {\r
+ try {\r
socket = new Socket(host, port);\r
- inputStream = new DataInputStream(socket.getInputStream());\r
+ inputStream = new DataInputStream(socket.getInputStream());\r
outputStream = new DataOutputStream(socket.getOutputStream());\r
} catch (Exception e) {\r
System.out.println("Connection error: " + e.getMessage());\r
\r
lastResponse = getResponse();\r
if (lastResponse.getCode() != 220)\r
- throw new FtpException("Connect unsucessfull.");\r
+ throw new FtpException("Connection unsuccessful.");\r
}\r
\r
- public boolean cwd(String dir) {\r
+ public boolean cwd(String dir) {\r
writeRequest(Command.CWD, dir);\r
lastResponse = getResponse();\r
- if (lastResponse.getCode() == 250) \r
+ if (lastResponse.getCode() == 250)\r
return true;\r
return false;\r
}\r
- \r
+\r
public void disconnect() {\r
writeRequest(Command.QUIT);\r
lastResponse = getResponse();\r
if (isConnected())\r
socket.close();\r
} catch (Exception e) {\r
- throw new FtpException("Error closeing connection: " + e.getMessage()); \r
+ throw new FtpException("Error closing connection: " + e.getMessage());\r
}\r
- } \r
+ }\r
\r
public void download(String target, String destination) {\r
if (passive == false) {\r
if (!port())\r
- throw new FtpException("PORT command is unsuccessful!"); \r
+ throw new FtpException("PORT command is unsuccessful!");\r
}\r
long fileSize = getSize(target);\r
writeRequest(Command.RETR, target);\r
int byteCount = 0;\r
int prevPercent = 0;\r
long downloadedBytes = 0;\r
- \r
+\r
fireFileDownloadEvent(evt);\r
if (!evt.isCanceled()) {\r
while ((byteCount = inputSteam.read(buf)) > 0) {\r
outputSteam.write(buf, 0, byteCount);\r
- downloadedBytes += byteCount; \r
- if (fileSize == 0) \r
+ downloadedBytes += byteCount;\r
+ if (fileSize == 0)\r
continue;\r
int percent = (int) (downloadedBytes * 100 / fileSize);\r
if (percent - prevPercent >= 5) {\r
- prevPercent = percent; \r
+ prevPercent = percent;\r
evt.setProgress(percent);\r
fireFileDownloadEvent(evt);\r
if (evt.isCanceled())\r
- break; \r
+ break;\r
}\r
}\r
}\r
} catch (Exception e) {\r
throw new FtpException(e.getMessage());\r
} finally {\r
- try{\r
+ try {\r
if (inputSteam != null)\r
inputSteam.close();\r
if (outputSteam != null)\r
outputSteam.close();\r
if (dataSocket != null)\r
dataSocket.close();\r
- } catch (Exception e) {}\r
+ } catch (Exception e) {\r
+ }\r
}\r
lastResponse = getResponse();\r
if (lastResponse.getCode() != 226 && !evt.isCanceled())\r
throw new FtpException("Unexpected termination of data transmission.");\r
}\r
- \r
+\r
protected void fireFileDownloadEvent(FileEvent evt) {\r
- Object[] listeners = listenerList.getListenerList();\r
- for (int i=0; i<listeners.length; i+=2) {\r
- if (listeners[i]==FileEventListener.class) {\r
- ((FileEventListener)listeners[i+1]).fileDownload(evt);\r
- if (evt.isCanceled())\r
- break;\r
- }\r
- }\r
- }\r
+ Object[] listeners = listenerList.getListenerList();\r
+ for (int i = 0; i < listeners.length; i += 2) {\r
+ if (listeners[i] == FileEventListener.class) {\r
+ ((FileEventListener) listeners[i + 1]).fileDownload(evt);\r
+ if (evt.isCanceled())\r
+ break;\r
+ }\r
+ }\r
+ }\r
\r
protected void fireFileUploadEvent(FileEvent evt) {\r
- Object[] listeners = listenerList.getListenerList();\r
- for (int i=0; i<listeners.length; i+=2) {\r
- if (listeners[i]==FileEventListener.class) {\r
- ((FileEventListener)listeners[i+1]).fileUpload(evt);\r
- if (evt.isCanceled())\r
- break;\r
- }\r
- }\r
- }\r
- \r
+ Object[] listeners = listenerList.getListenerList();\r
+ for (int i = 0; i < listeners.length; i += 2) {\r
+ if (listeners[i] == FileEventListener.class) {\r
+ ((FileEventListener) listeners[i + 1]).fileUpload(evt);\r
+ if (evt.isCanceled())\r
+ break;\r
+ }\r
+ }\r
+ }\r
+\r
public List<FtpFile> flist(String params) {\r
List<FtpFile> formatted = new ArrayList<FtpFile>();\r
String[] lines = list(params, false);\r
- for (String line: lines) {\r
+ for (String line : lines) {\r
formatted.add(new FtpFile(line));\r
}\r
return formatted;\r
}\r
- \r
+\r
private FtpResponse getResponse() {\r
final byte buf[] = new byte[FtpConstants.BufferSize];\r
int byteCount = 0;\r
}\r
\r
boolean isConnected() {\r
- if (socket == null) \r
+ if (socket == null)\r
return false;\r
return socket.isBound() && !socket.isClosed();\r
}\r
- \r
+\r
public String[] list(String params) {\r
return list(params, false);\r
}\r
- \r
+\r
private String[] list(String params, boolean namesOnly) {\r
if (passive == false) {\r
if (!port())\r
- throw new FtpException("PORT command is unsuccessful!"); \r
+ throw new FtpException("PORT command is unsuccessful!");\r
}\r
- \r
+\r
if (namesOnly)\r
writeRequest(Command.NLST, params);\r
else\r
writeRequest(Command.LIST, params);\r
- \r
+\r
lastResponse = getResponse();\r
if (lastResponse.getCode() != 150)\r
throw new FtpException("Unable to receive data.");\r
- \r
+\r
Socket dataSocket = null;\r
BufferedInputStream inputStream = null;\r
String line = "";\r
}\r
} catch (Exception e) {\r
throw new FtpException(e.getMessage());\r
- }finally {\r
+ } finally {\r
try {\r
if (inputStream != null)\r
inputStream.close();\r
if (dataSocket != null)\r
dataSocket.close();\r
- } catch (Exception e) {}\r
+ } catch (Exception e) {\r
+ }\r
}\r
lastResponse = getResponse();\r
if (lastResponse.getCode() != 226)\r
public boolean mkDir(String dir) {\r
writeRequest(Command.MKD, dir);\r
lastResponse = getResponse();\r
- if (lastResponse.getCode() == 250) \r
+ if (lastResponse.getCode() == 250)\r
return true;\r
return false;\r
}\r
- \r
+\r
public String[] nlist(String params) {\r
return list(params, true);\r
}\r
int start = msg.indexOf("(") + 1;\r
int end = msg.indexOf(")");\r
if (start == 0 || end == 0 || end < start)\r
- throw new FtpException("Entering passive mode is unsuccessful! Wrong server reply: " + lastResponse.getMessage());\r
+ throw new FtpException(\r
+ "Entering passive mode is unsuccessful! Wrong server reply: " + lastResponse.getMessage());\r
msg = msg.substring(start, end);\r
dataChannel = DataChannel.fromPort(msg);\r
passive = true;\r
\r
protected boolean port() {\r
dataChannel = new DataChannel();\r
- writeRequest(Command.PORT, dataChannel.getPortString());\r
+ writeRequest(Command.PORT, dataChannel.getPortString());\r
lastResponse = getResponse();\r
if (lastResponse.getCode() == 200)\r
return true;\r
}\r
\r
public void removeFileListener(FileEventListener listener) {\r
- listenerList.remove(FileEventListener.class, listener);\r
- }\r
- \r
+ listenerList.remove(FileEventListener.class, listener);\r
+ }\r
+\r
public boolean rmDir(String dir) {\r
writeRequest(Command.RMD, dir);\r
lastResponse = getResponse();\r
- if (lastResponse.getCode() == 250) \r
+ if (lastResponse.getCode() == 250)\r
return true;\r
return false;\r
}\r
public void upload(String target, String destination) {\r
if (passive == false) {\r
if (!port())\r
- throw new FtpException("PORT command is unsuccessful!"); \r
+ throw new FtpException("PORT command is unsuccessful!");\r
}\r
writeRequest(Command.STOR, destination);\r
lastResponse = getResponse();\r
if (!evt.isCanceled()) {\r
while ((byteCount = inputSteam.read(buf)) > 0) {\r
outputSteam.write(buf, 0, byteCount);\r
- uploadedBytes += byteCount; \r
+ uploadedBytes += byteCount;\r
int percent = (int) (uploadedBytes * 100 / f.length());\r
if (percent - prevPercent >= 5) {\r
- prevPercent = percent; \r
+ prevPercent = percent;\r
evt.setProgress(percent);\r
fireFileUploadEvent(evt);\r
if (evt.isCanceled())\r
} catch (Exception e) {\r
throw new FtpException(e.getMessage());\r
} finally {\r
- try{\r
+ try {\r
if (inputSteam != null)\r
inputSteam.close();\r
if (outputSteam != null)\r
outputSteam.close();\r
if (dataSocket != null)\r
dataSocket.close();\r
- } catch (Exception e) {}\r
+ } catch (Exception e) {\r
+ }\r
}\r
lastResponse = getResponse();\r
if (lastResponse.getCode() != 226 && !evt.isCanceled())\r
throw new FtpException("Unexpected termination of data transmission.");\r
}\r
+\r
protected void writeRequest(Command command) {\r
writeRequest(command, null);\r
}\r
- \r
+\r
protected void writeRequest(Command command, String params) {\r
try {\r
String message = command.toString();\r
message += (params == null) ? "" : " " + params;\r
outputStream.writeBytes(message + FtpConstants.EOL);\r
} catch (IOException e) {\r
- System.out.println(String.format("CLIENT# ", e.getMessage())); \r
+ System.out.println(String.format("CLIENT# ", e.getMessage()));\r
}\r
}\r
}\r
-\r
import java.util.Locale;\r
\r
/**\r
- * <b>Konstansok, mint�k.</b> A kliens �s a server �ltal haszn�lt �zenetek,\r
- * v�laszok, felsorol�sok, form�z�shoz haszn�l mint�k.\r
+ * <b>Konstansok, minták.</b> A kliens és a server által használt üzenetek,\r
+ * válaszok, felsorolások, formázáshoz használt minták.\r
* \r
* @author vasary\r
*/\r
package user.commons.ftp;\r
\r
/**\r
- * <b>Ftp kivétel.</b>\r
- * A kliens és a server is ezt használja.\r
- * \r
+ * <b>Ftp kivétel.</b> A kliens és a server is ezt használja.\r
+ * \r
* @author vasary\r
*/\r
public class FtpException extends RuntimeException {\r
import java.util.Date;\r
\r
/**\r
- * <b>Virtuális file objektum.</b>\r
- * Az Ftp kliens plusz szolgáltatása, hogy az flist() fügvény, \r
- * ilyen objektumokból álló listát ad vissza. ld. \r
+ * <b>Virtuális file objektum.</b> Az Ftp kliens plusz szolgáltatása, hogy az\r
+ * flist() függvény, ilyen objektumokból álló listát ad vissza. ld.\r
* \r
* @author vasary\r
*/\r
private boolean isDirectory = false;\r
private long size = 0;\r
private Date lastModified = null;\r
- \r
+\r
public FtpFile(String ftpReply) {\r
String s = ftpReply;\r
try {\r
import java.io.FileFilter;\r
\r
/**\r
- * <b>Ftp file lista filter.</b>\r
- * A LIST parancs paraméterébõl FileFilter-t készít a szûréshez.\r
+ * <b>Ftp file lista filter.</b> A LIST parancs paraméteréből FileFilter-t\r
+ * készít a szűréshez.\r
* \r
* @author vasary\r
*/\r
public class FtpFileFilter implements FileFilter {\r
private String params = null;\r
- private boolean forDirectories = false; \r
- \r
+ private boolean forDirectories = false;\r
+\r
FtpFileFilter(String params, boolean forDirectories) {\r
this.params = params;\r
this.forDirectories = forDirectories;\r
}\r
- \r
+\r
public boolean accept(File file) {\r
- boolean ret = false; \r
+ boolean ret = false;\r
String name = file.getName();\r
- \r
- if (forDirectories) \r
+\r
+ if (forDirectories)\r
ret = file.isDirectory();\r
else\r
ret = file.isFile();\r
- \r
+\r
if (ret == false)\r
return ret;\r
- \r
+\r
if (params == null || params.trim().length() == 0)\r
return ret;\r
- \r
+\r
if (params.startsWith("*")) {\r
ret &= name.endsWith(params.replace("*", ""));\r
return ret;\r
}\r
- \r
+\r
if (params.endsWith("*")) {\r
ret &= name.startsWith(params.replace("*", ""));\r
return ret;\r
String[] p = params.split("\\*");\r
if (p.length == 2)\r
ret &= name.startsWith(p[0]) && name.endsWith(p[1]);\r
- } else \r
+ } else\r
ret &= file.getName().equals(params);\r
- \r
+\r
return ret;\r
}\r
}\r
import user.commons.ftp.FtpServerProperties.FtpUser;\r
\r
/**\r
- * <b>Ftp protokol implementáció.</b>\r
- * A protokol leírásnak megfelelõen a beérkezõ parancsra végrehajtja a\r
- * kért mûveletet, és a szabályoknak megfelelõen válaszol.\r
- * \r
+ * <b>Ftp protokol implementáció.</b> A protokol leírásnak megfelelően a\r
+ * beérkező parancsra végrehajtja a kért műveletet, és a szabályoknak\r
+ * megfelelően válaszol.\r
+ * \r
* @author vasary\r
*/\r
public class FtpProtocol {\r
static private String currentDir = null;\r
private FtpSession session = null;\r
private DataChannel dataChannel = null;\r
- private FtpServerProperties properties = null; \r
+ private FtpServerProperties properties = null;\r
private FtpUser currentUser = null;\r
- \r
+\r
FtpProtocol(FtpSession session) {\r
this.session = session;\r
this.properties = session.getServer().getProperties();\r
return false;\r
return true;\r
}\r
- \r
+\r
protected void Confirm() {\r
writeReply(FtpConstants.MSG200);\r
}\r
String filter = null;\r
\r
if (chdir != null && chdir.isDirectory()) {\r
- // paraméterben megadott könyvtár listázás\r
+ // paraméterben megadott könyvtár listázás\r
dir = chdir;\r
} else {\r
if (params != null && params.contains("/")) {\r
- // paraméterben megadott könyvtár és szûrõ\r
+ // paraméterben megadott könyvtár és szűrő\r
String[] param = params.split("/");\r
if (param.length > 1) {\r
filter = param[param.length - 1];\r
dir = chdir;\r
}\r
} else {\r
- // aktuális munkakönyvtár listázás\r
+ // aktuális munkakönyvtár listázás\r
filter = params;\r
}\r
}\r
String name = null;\r
try {\r
dataSocket = dataChannel.getDataSocket();\r
- outputStream = new BufferedOutputStream(dataSocket\r
- .getOutputStream(), FtpConstants.BufferSize);\r
+ outputStream = new BufferedOutputStream(dataSocket.getOutputStream(), FtpConstants.BufferSize);\r
for (File d : dirs) {\r
if (namesOnly)\r
name = d.getName() + FtpConstants.EOL;\r
else\r
- name = String.format(FtpConstants.LISTFORMAT, "<DIR>", d\r
- .getName(), FtpConstants.getLDTMString(d\r
- .lastModified()));\r
+ name = String.format(FtpConstants.LISTFORMAT, "<DIR>", d.getName(),\r
+ FtpConstants.getLDTMString(d.lastModified()));\r
outputStream.write(name.getBytes());\r
}\r
for (File f : files) {\r
if (namesOnly)\r
name = f.getName() + FtpConstants.EOL;\r
else\r
- name = String.format(Locale.ENGLISH,\r
- FtpConstants.LISTFORMAT, f.length(), f.getName(),\r
+ name = String.format(Locale.ENGLISH, FtpConstants.LISTFORMAT, f.length(), f.getName(),\r
FtpConstants.getLDTMString(f.lastModified()));\r
outputStream.write(name.getBytes());\r
}\r
File f = new File(getCurrentDir() + params);\r
if (f.exists())\r
writeReply(String.format(FtpConstants.MSG213STIRNG,\r
- FtpConstants.MDTMFormatter\r
- .format(new Date(f.lastModified()))));\r
+ FtpConstants.MDTMFormatter.format(new Date(f.lastModified()))));\r
else\r
writeReply(String.format(FtpConstants.MSG550, params));\r
}\r
}\r
currentUser.authenticate(params);\r
if (currentUser.isAuthenticated()) {\r
- setRoot(properties.getServerRoot()+ currentUser.getHome());\r
+ setRoot(properties.getServerRoot() + currentUser.getHome());\r
writeReply(FtpConstants.MSG230);\r
return;\r
}\r
System.out.println("Command is not implemented.");\r
}\r
int commandLen = input[0].length();\r
- String params = (line.length() > commandLen + 1) ? line.substring(\r
- commandLen + 1).trim() : null;\r
+ String params = (line.length() > commandLen + 1) ? line.substring(commandLen + 1).trim() : null;\r
switch (cmd) {\r
case USER: {\r
User(params);\r
try {\r
dataSocket = dataChannel.getDataSocket();\r
final byte buf[] = new byte[FtpConstants.BufferSize];\r
- inputStream = new BufferedInputStream(new FileInputStream(file),\r
- FtpConstants.BufferSize);\r
- outputStream = new BufferedOutputStream(dataSocket\r
- .getOutputStream(), FtpConstants.BufferSize);\r
+ inputStream = new BufferedInputStream(new FileInputStream(file), FtpConstants.BufferSize);\r
+ outputStream = new BufferedOutputStream(dataSocket.getOutputStream(), FtpConstants.BufferSize);\r
int byteCount = 0;\r
while ((byteCount = inputStream.read(buf)) > 0) {\r
outputStream.write(buf, 0, byteCount);\r
public void setRoot(String root) {\r
File path = new File(root);\r
try {\r
- \r
+\r
String filePath = path.getCanonicalPath();\r
filePath = FtpConstants.terminatedDir(filePath);\r
if (path.exists() && path.isFile())\r
try {\r
dataSocket = dataChannel.getDataSocket();\r
final byte buf[] = new byte[FtpConstants.BufferSize];\r
- inputStream = new BufferedInputStream(dataSocket.getInputStream(),\r
- FtpConstants.BufferSize);\r
- outputStream = new BufferedOutputStream(new FileOutputStream(file),\r
- FtpConstants.BufferSize);\r
+ inputStream = new BufferedInputStream(dataSocket.getInputStream(), FtpConstants.BufferSize);\r
+ outputStream = new BufferedOutputStream(new FileOutputStream(file), FtpConstants.BufferSize);\r
int byteCount = 0;\r
while ((byteCount = inputStream.read(buf)) > 0) {\r
outputStream.write(buf, 0, byteCount);\r
} catch (Exception e) {\r
}\r
}\r
- writeReply(String\r
- .format(FtpConstants.MSG226STOR, params, file.length()));\r
+ writeReply(String.format(FtpConstants.MSG226STOR, params, file.length()));\r
}\r
\r
protected void Syst() {\r
package user.commons.ftp;\r
\r
/**\r
- * <b>Ftp server válasz.</b>\r
- * Az Ftp kliens használja, a válaszüzenetek kód/szöveg szeparálására.\r
- * \r
+ * <b>Ftp server válasz.</b> Az Ftp kliens használja, a válaszüzenetek\r
+ * kód/szöveg szeparálására.\r
+ * \r
* @author vasary\r
*/\r
public class FtpResponse {\r
FtpResponse(String message) {\r
String[] msg = message.split(" ");\r
try {\r
- this.code = Integer.parseInt(msg[0]); \r
+ this.code = Integer.parseInt(msg[0]);\r
this.message = message.replace(msg[0] + " ", "").trim();\r
- } catch (Exception e) {}\r
- \r
- System.out.println(String.format("CLIENT# (%1$d) %2$s", this.code, this.message)); \r
+ } catch (Exception e) {\r
+ }\r
+\r
+ System.out.println(String.format("CLIENT# (%1$d) %2$s", this.code, this.message));\r
}\r
- \r
+\r
public String getMessage() {\r
return message;\r
}\r
package user.commons.ftp;\r
\r
-import java.io.*;\r
-import java.net.*;\r
+import java.io.IOException;\r
+import java.net.ServerSocket;\r
+import java.net.Socket;\r
\r
/**\r
- * <b>Ftp server.</b>\r
- * Saját szálon fut, és minden kapcsolathoz külön session szálat indít. \r
+ * <b>Ftp server.</b> Saját szálon fut, és minden kapcsolathoz külön session\r
+ * szálat indít.\r
* \r
* @author vasary\r
*/\r
-public class FtpServer extends Thread{\r
+public class FtpServer extends Thread {\r
private ServerSocket serverSocket = null;\r
private String name = "FtpServer Main Thread";\r
private FtpServerProperties properties = null;\r
- \r
+\r
FtpServer() {\r
try {\r
properties = new FtpServerProperties();\r
System.out.println("Exception on new ServerSocket: " + e);\r
}\r
}\r
- \r
+\r
public FtpServerProperties getProperties() {\r
return properties;\r
- } \r
- \r
+ }\r
+\r
public void run() {\r
this.setName(name);\r
while (true) {\r
e.printStackTrace();\r
}\r
System.out.println("New client connected.");\r
- FtpSession t = new FtpSession(this, socket); \r
- System.out.println("Starting a server side client thread.");\r
+ FtpSession t = new FtpSession(this, socket);\r
+ System.out.println("Starting a server-side client thread.");\r
t.start();\r
}\r
- }\r
+ }\r
\r
public void shutdown() {\r
try {\r
} catch (IOException e) {\r
e.printStackTrace();\r
}\r
- } \r
+ }\r
}\r
import java.util.List;\r
\r
import user.commons.CommonsProperties;\r
+\r
/**\r
-* <b>Ftp server beállítások.</b>\r
-* SERVERROOT - Gyökér könyvtár. A felhasználók home könyvtárai ez alatt jönnek létre.\r
-* PORT - Port szám, amin a server fogadja a kapcsolatokat.\r
-* USERS - FtpUser lista. \r
+ * <b>Ftp server beállítások.</b> SERVERROOT - Gyökér könyvtár. A felhasználók\r
+ * home könyvtárai ez alatt jönnek létre. PORT - Port szám, amin a server\r
+ * fogadja a kapcsolatokat. USERS - FtpUser lista.\r
* \r
* @author vasary\r
*/\r
public class FtpServerProperties extends CommonsProperties {\r
\r
/**\r
- * <b>Ftp felhasználó.</b>\r
- * A home SERVERROOT-hoz képest relatív (chroot). \r
+ * <b>Ftp felhasználó.</b> A home SERVERROOT-hoz képest relatív (chroot).\r
* \r
* @author vasary\r
*/\r
private String password = null;\r
private String home = null;\r
private boolean authenticated = false;\r
- \r
+\r
FtpUser(String name, String password, String home) {\r
if (name == null || name.length() == 0)\r
- throw new FtpException("User name cannot be null or empty.");\r
+ throw new FtpException("User name can not be null or empty.");\r
if (home == null)\r
- throw new FtpException("User home directory cannot be null.");\r
+ throw new FtpException("User home directory can not be null.");\r
this.name = name;\r
this.password = password;\r
this.home = home;\r
public String getName() {\r
return name;\r
}\r
- \r
+\r
public boolean isAuthenticated() {\r
return authenticated;\r
}\r
- } \r
+ }\r
\r
- static public final String USERS = "Users"; \r
- static public final String SERVERROOT = "ServerRoot"; \r
+ static public final String USERS = "Users";\r
+ static public final String SERVERROOT = "ServerRoot";\r
static public final String PORT = "Port";\r
\r
FtpServerProperties() {\r
super.add(PORT, port);\r
super.add(USERS, getDefaultUsers());\r
}\r
- \r
+\r
public FtpServerProperties(int port, String serverRoot, List<FtpUser> users) {\r
CommonsProperties.checkParameter(SERVERROOT, serverRoot);\r
CommonsProperties.checkParameter(PORT, port);\r
super.add(PORT, port);\r
super.add(USERS, users);\r
}\r
- \r
+\r
protected List<FtpUser> getDefaultUsers() {\r
List<FtpUser> defaultUsers = new ArrayList<FtpUser>();\r
defaultUsers.add(new FtpUser("ftp", null, "anonymous"));\r
FtpUser getFtpUser(String name) {\r
if (name == null || name.length() == 0)\r
return null;\r
- for (FtpUser user: getUsers()) {\r
+ for (FtpUser user : getUsers()) {\r
if (user.getName().equals(name))\r
return user;\r
}\r
return null;\r
}\r
- \r
+\r
public int getPort() {\r
return getInt(PORT);\r
}\r
- \r
- public String getServerRoot(){\r
+\r
+ public String getServerRoot() {\r
String root = getString(SERVERROOT);\r
return FtpConstants.terminatedDir(root);\r
}\r
- \r
+\r
@SuppressWarnings("unchecked")\r
- public List<FtpUser> getUsers(){\r
+ public List<FtpUser> getUsers() {\r
Object o = get(USERS);\r
return (List<FtpUser>) o;\r
}\r
import java.net.Socket;\r
\r
/**\r
- * <b>Ftp server oldali kliens session, a bejövõ parancsok kezelésére.</b> \r
- * Saját szálon fut, és minden kapcsolathoz külön session tartozik.\r
- * Quit parancsra, vagy kliens oldali kapcsolat lezárás esetén kilép.\r
+ * <b>Ftp server oldali kliens session, a bejövő parancsok kezelésére.</b> Saját\r
+ * szálon fut, és minden kapcsolathoz külön session tartozik. Quit parancsra,\r
+ * vagy kliens oldali kapcsolat lezárás esetén kilép.\r
* \r
* @author vasary\r
*/\r
private DataOutputStream outputStream = null;\r
private String name = "FtpServer Main Thread for %1$s";\r
private FtpServer server = null;\r
- \r
+\r
FtpSession(FtpServer server, Socket socket) {\r
this.server = server;\r
this.socket = socket;\r
}\r
- \r
+\r
public DataOutputStream getOutputStream() {\r
return this.outputStream;\r
}\r
\r
public void run() {\r
this.setName(String.format(name, socket.getRemoteSocketAddress()));\r
- \r
+\r
System.out.print("Trying to create streams...");\r
try {\r
byte[] buf = new byte[FtpConstants.BufferSize];\r
- inputStream = new DataInputStream(socket.getInputStream());\r
+ inputStream = new DataInputStream(socket.getInputStream());\r
outputStream = new DataOutputStream(socket.getOutputStream());\r
System.out.println("created.");\r
FtpProtocol protocol = new FtpProtocol(this);\r
- \r
+\r
while (true) {\r
int byteCount = 0;\r
String line = "";\r
line = line.trim();\r
System.out.println(line);\r
if (!protocol.ProcessCommand(line))\r
- break;//QUIT parancsra kilépés!\r
+ break;// QUIT parancsra kiLépés!\r
}\r
- \r
+\r
} catch (Exception e) {\r
System.out.println("Ftp session error: " + e.getMessage());\r
return;\r
package user.commons.ftp;\r
\r
import java.util.EventListener;\r
+\r
/**\r
- * <b>Ftp kliens file események.</b>\r
- * Egy file fel- és letöltésekor hívódik meg. \r
- * Tartalmazza a folyamat százalékos állapotát.\r
- * Visszajelzéssel megszakítható a folyamat.\r
+ * <b>Ftp kliens file események.</b> Egy file fel- és letöltésekor hívódik meg.\r
+ * Tartalmazza a folyamat százalékos állapotát. Visszajelzéssel megszakítható a\r
+ * folyamat.\r
* \r
* @author vasary\r
*/\r
public interface IProgressEventListener extends EventListener {\r
- public void progressChanged(ProgressEvent evt);\r
+ public void progressChanged(ProgressEvent evt);\r
}\r
-\r
import java.util.EventObject;\r
\r
/**\r
- * <b>File eseménykezelõ.</b>\r
+ * <b>File eseménykezelő.</b>\r
* \r
* @author vasary\r
*/\r
--Hiányzó parancsok és átviteli módok implementálása\r
+-Hiányzó parancsok és átviteli módok implementálása\r
http://www.faqs.org/rfcs/rfc959.html\r
RNFR, RNTO, SMNT, STOU, ACCT, REIN, ABOR, STRU, MODE, APPE, ALLO, REST, SITE, STAT\r
--Proxy és fix adatcsatorna port támogatás\r
+-Proxy és fix adatcsatorna port támogatás\r
-FXP\r
-Log\r
--Integrált autentikáció\r
+-Integrált autentikáció\r
of when the media was recorded 8\r
1 Codec Where Recorded The video server name and channel where the media was recorded 19\r
2 Legacy Field Used only in Nexio Browse 1.0 and older low-res systems to link \r
- a low-res clip to its matching high-res clip�s 8-byte ID handle. 8\r
+ a low-res clip to its matching high-res clip's 8-byte ID handle. 8\r
3 UMID Unique Media Identifier 64\r
4 Video Info Extended video format and frame rate in a bit-wise algorithm \r
of 128 bits 16\r
17 User-definable Field #4 UNICODE-stored 25-character user entry field 50\r
18 External Controller UID A field reserved for external controllers needing a place \r
to store their own unique identifiers 16\r
-19 Video ARC A series of seven 2-byte values defining a clip�s video \r
+19 Video ARC A series of seven 2-byte values defining a clip's video \r
aspect ratio conversion when loaded into \r
a channel of opposite resolution. \r
This field also sets whether to override existing AFD data and whether \r
- to override an SD clip�s native aspect ratio. 14\r
+ to override an SD clip's native aspect ratio. 14\r
20 Modified Timestamp A FILETIME structure representing the time and date stamp when \r
the media was last modified. See below for list of protocol \r
commands which trigger this timestamp. 8\r
the QuiC software application 2\r
22 User Segments In Use Used for managing the information stored \r
in user data segments, part of the DTA modes. \r
- The 2 bytes represent a bitmask of �in use� user data slots 2\r
+ The 2 bytes represent a bitmask of "in use" user data slots 2\r
23 Audio Track Compression Info A series of 1-byte data per audio track (up to 32 tracks) to indicate \r
- each track�s compression type and channel count 32\r
+ each track's compression type and channel count 32\r
24 Audio Track Tag Info A series of 1-byte data per audio track (up to 32 tracks) \r
to identify the content of each track using special audio tags 32*/\r
public class GetExtendedFieldCommand extends Command {\r
import user.commons.ItemSource;\r
\r
/***\r
- * Rhozet Carbon Coder illeszt�s.\r
+ * Rhozet Carbon Coder illesztés.\r
*/\r
public class RCCClient {\r
private static final Logger logger = LogManager.getLogger();\r
private PrintStream outputStream;\r
\r
/***\r
- * Rhozet Carbon Coder illeszt�s l�trehoz�sa. A kommunik�ci� a TCP/1120\r
- * porton zajlik.\r
+ * Rhozet Carbon Coder illesztés létrehozása. A kommunikáció a TCP/1120 porton\r
+ * zajlik.\r
* \r
- * @param host\r
- * A t�voli transzk�dol� alrendszer h�l�zati neve, vagy IP c�me\r
+ * @param host A távoli transzkódoló alrendszer hálózati neve, vagy IP-címe\r
*/\r
\r
public RCCClient(String host) {\r
this.port = 1120;\r
this.hostName = "localhost";\r
if (StringUtils.isEmpty(host)) {\r
- logger.info("RCC server not specified, defaulting to localhost:1120");\r
+ logger.info("RCC server is not specified, defaulting to localhost:1120");\r
} else {\r
String data[] = host.split("\\:");\r
if (data.length == 1) {\r
this.hostName = host;\r
- logger.info("RCC server port not specified, defaulting to port 1120");\r
+ logger.info("RCC server port is not specified, defaulting to port 1120");\r
}\r
if (data.length == 2) {\r
this.hostName = data[0];\r
}\r
\r
/***\r
- * Transzk�dol�si folyamat megszak�t�sa.\r
+ * Transzkódolási folyamat megszakítása.\r
* \r
- * @param id\r
- * A megszak�tand� folyamat azonos�t�ja.\r
- * @return RCCResponseJobCommand t�pus� v�lasz\r
+ * @param id A megszakítandó folyamat azonosítója.\r
+ * @return RCCResponseJobCommand típusú válasz\r
*/\r
public RCCResponseJobCommand cancelJob(String id) {\r
RCCResponseJobCommand result = null;\r
}\r
\r
/***\r
- * Transzk�dol�si folyamat ind�t�sa.\r
+ * Transzkódolási folyamat indítása.\r
* \r
- * @param jobName\r
- * A folyamat tetsz�leges neve.\r
- * @param inputFilePath\r
- * A forr�s m�dia el�r�si �tja.\r
- * @param outputDir\r
- * A c�l m�dia kimeneti mapp�ja.\r
- * @param profileGuid\r
- * A profil azonos�t�ja.\r
- * @param id\r
- * Jelenleg nem haszn�lt mez�. �rt�ke tetsz�leges, pl. 0\r
- * @param priority\r
- * Priorit�s. �rt�ke 0-9 k�z�tt a priorit�st hat�rozza meg, 255\r
- * eset�n azonnali ind�t�st.\r
+ * @param jobName A folyamat tetszőleges neve.\r
+ * @param inputFilePath A forrás média elérési útja.\r
+ * @param outputDir A cél média kimeneti mappája.\r
+ * @param profileGuid A profil azonosítója.\r
+ * @param id Jelenleg nem használt mező. értéke tetszőleges, pl. 0\r
+ * @param priority prioritás. értéke 0-9 között a prioritást határozza meg,\r
+ * 255 esetén azonnali indítást.\r
* @return\r
*/\r
public String cueueJobByGuid(String jobName, List<ItemSource> itemSource, String outputDir, String profileGuid,\r
}\r
\r
/***\r
- * Profil azonos�t�j�nak lek�rdez�se n�v alapj�n.\r
+ * Profil azonosítójának lekérdezése név alapján.\r
* \r
- * @param name\r
- * A profil neve.\r
- * @return Eredm�nyk�nt a profil azopnos�t�j�t kapjuk, sz�veges t�pusra\r
- * konvert�lva.\r
+ * @param name A profil neve.\r
+ * @return eredményként a profil azonosítóját kapjuk, szöveges típusra\r
+ * konvertálva.\r
*/\r
public String getProfileId(String name) {\r
String result = null;\r
}\r
\r
/***\r
- * Profilok lek�rdez�se a t�voli eszk�zr�l.\r
+ * Profilok lekérdezése a távoli eszközről.\r
* \r
- * @return Az eredm�ny egy azonos�t� kulcsokb�l �s a profilok nev�b�l �ll�\r
+ * @return Az eredmény egy azonosító kulcsokból és a profilok nevéből álló\r
* lista.\r
*/\r
public Map<String, String> getProfileList() {\r
}\r
\r
/***\r
- * Adott azonos�t�j� folyamat �llapot�nak lek�rdez�se.\r
+ * Adott azonosítójú folyamat állapotának lekérdezése.\r
* \r
- * @param id\r
- * Folyamat azonos�t�ja.\r
- * @return Az eredm�ny egy RCCResponseJobCommand objektum, ami t�bbek k�z�tt\r
- * a folyamat st�tusz�t �s a feldolgozotts�g sz�zal�kos �rt�k�t is\r
+ * @param id Folyamat azonosítója.\r
+ * @return Az eredmény egy RCCResponseJobCommand objektum, ami többek között a\r
+ * folyamat státuszát és a feldolgozottság százalékos értékét is\r
* tartalmazza.\r
*/\r
public RCCResponseJobCommand queryStatus(String id) {\r
}\r
\r
/***\r
- * Profil param�tereinek lek�rdez�se.\r
+ * Profil paramétereinek lekérdezése.\r
* \r
- * @param id\r
- * A profil azonos�t�ja.\r
- * @return Az eredm�ny RCCResponseProfileCommand t�pus� objektum, ami a\r
- * r�szletes inform�ci�kat hordozza.\r
+ * @param id A profil azonosítója.\r
+ * @return Az eredmény RCCResponseProfileCommand típusú objektum, ami a\r
+ * részletes információkat hordozza.\r
*/\r
public RCCResponseProfileCommand getProfileDetails(String id) {\r
RCCResponseProfileCommand result = null;\r
import user.commons.RemoteFile;\r
\r
/***\r
- * Traszkódolási folyamat.\r
+ * Traszkódolási folyamat.\r
*/\r
public class RCCJob {\r
private String name;\r
private String errorMessage;\r
\r
/***\r
- * Új folyamat példányosítása.\r
+ * Új folyamat példányosítása.\r
* \r
- * @param client\r
- * A kapcsolódáshoz használt kliens.\r
- * @param name\r
- * A folyamat tetszõleges elnevezése.\r
- * @param data\r
- * Jelenleg nem használt. Értéke tetszõleges, pl. null.\r
- * @param id\r
- * Jelenleg nem használt. Értéke tetszõleges, pl. 0.\r
+ * @param client A kapcsolódáshoz használt kliens.\r
+ * @param name A folyamat tetszőleges elnevezése.\r
+ * @param data Jelenleg nem használt. Értéke tetszőleges, pl. null.\r
+ * @param id Jelenleg nem használt. Értéke tetszőleges, pl. 0.\r
*/\r
public RCCJob(RCCClient client, String name, Object data, long id) {\r
this.client = client;\r
}\r
\r
/***\r
- * Legutolsó hibaüzenet szövege.\r
+ * Legutolsó hibaüzenet szövege.\r
* \r
* @return\r
*/\r
}\r
\r
/***\r
- * Egyedi azonosító.\r
+ * Egyedi azonosító.\r
* \r
- * @return A transzkóder által generál egyedi folyamat azonosító.\r
+ * @return A transzkóder által generált egyedi folyamat azonosító.\r
*/\r
public String getGuid() {\r
return guid;\r
}\r
\r
/***\r
- * @return Folyamat feldolgozottság százalékos értéke.\r
+ * @return Folyamat feldolgozottság százalékos értéke.\r
*/\r
public int getProgress() {\r
return progress;\r
}\r
\r
/***\r
- * @return Folyamat státusza.\r
+ * @return Folyamat státusza.\r
*/\r
public String getStatus() {\r
return status;\r
}\r
\r
/***\r
- * @return Igaz értéket ad, ha hiba történt a folyamatban.\r
+ * @return Igaz értéket ad, ha hiba történt a folyamatban.\r
*/\r
public boolean isError() {\r
return status.equals("ERROR");\r
}\r
\r
/***\r
- * @return Igaz értéket ad, ha a folyamat fut.\r
+ * @return Igaz értéket ad, ha a folyamat fut.\r
*/\r
public boolean isRunning() {\r
refresh();\r
- return !status.equals("FAILED") && !status.equals("ERROR") && !status.equals("STOPPED") && !status.equals("COMPLETED");\r
+ return !status.equals("FAILED") && !status.equals("ERROR") && !status.equals("STOPPED")\r
+ && !status.equals("COMPLETED");\r
}\r
\r
/***\r
- * @return Igaz értéket ad, ha a folyamat sikeresen véget ért.\r
+ * @return Igaz értéket ad, ha a folyamat sikeresen véget ért.\r
*/\r
public boolean isSuccess() {\r
return status.equals("COMPLETED");\r
}\r
\r
/***\r
- * Frissítés. A folyamat paraméterei aktualizálódnak.\r
+ * Frissítés. A folyamat paraméterei aktualizálódnak.\r
*/\r
public void refresh() {\r
if (client != null) {\r
}\r
\r
/***\r
- * A folyamat megszakítása.\r
+ * A folyamat megszakítása.\r
*/\r
public void cancel() {\r
if (client != null)\r
}\r
\r
/***\r
- * Folyamat indítása, elküldése a transzkóder alrendszernek.\r
+ * Folyamat indítása, elküldése a transzkóder alrendszernek.\r
* \r
- * @param inputFilePath\r
- * A forrás média elérési útja.\r
- * @param outputDir\r
- * A cél média kimeneti mappája.\r
- * @param profileGuid\r
- * A profil azonosítója.\r
- * @return Igaz értéket ad, ha sikerült a folyamat elküldése.\r
+ * @param inputFilePath A forrás média elérési útja.\r
+ * @param outputDir A cél média kimeneti mappája.\r
+ * @param profileGuid A profil azonosítója.\r
+ * @return Igaz értéket ad, ha sikerült a folyamat elküldése.\r
*/\r
public boolean submit(String inputFilePath, String outputDir, String profileGuid) {\r
if (client != null)\r
package user.commons.rcc;\r
+\r
import org.w3c.dom.Element;\r
\r
-public class RCCMessageProfile extends RCCMessage\r
-{\r
- public RCCMessageProfile()\r
- {\r
+public class RCCMessageProfile extends RCCMessage {\r
+ public RCCMessageProfile() {\r
super();\r
\r
- if (xmlDocument == null || root == null) return;\r
+ if (xmlDocument == null || root == null)\r
+ return;\r
\r
setTaskType("ProfileList");\r
Element elem = xmlDocument.createElement("ProfileAttributes");\r
root.appendChild(elem);\r
\r
- //Destination, Filter_Audio, Filter_Video, Setting, Connection\r
- //de csak a Destination müxik\r
+ // Destination, Filter_Audio, Filter_Video, Setting, Connection\r
+ // de csak a Destination műxik\r
elem.setAttribute("ProfileType", "Destination");\r
}\r
}
\ No newline at end of file
\r
RCCResponse(String response) {\r
\r
- //logger.info(response);\r
+ // logger.info(response);\r
\r
this.response = response.replace("CarbonAPIXML1 ", "");\r
int pos = this.response.indexOf(" ");\r
checkLength = Integer.parseInt(this.response.substring(0, pos));\r
this.response = this.response.substring(pos + 1);\r
- // if (checkLength == this.responseXML.length()) mi�rt nem ugyan az???\r
+ // if (checkLength == this.responseXML.length()) miért nem ugyanaz???\r
try {\r
DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();\r
DocumentBuilder db = dbf.newDocumentBuilder();\r
\r
private static final String PATHSEPARATOR_WINDOWS = "\\";\r
private static final String PATHSEPARATOR_LINUX = "/";\r
- private static final String PATHSEPARATOR = System.getProperty("os.name").startsWith("Windows") ? PATHSEPARATOR_WINDOWS : PATHSEPARATOR_LINUX;\r
+ private static final String PATHSEPARATOR = System.getProperty("os.name").startsWith("Windows")\r
+ ? PATHSEPARATOR_WINDOWS\r
+ : PATHSEPARATOR_LINUX;\r
\r
public static String checkSlash(String data, boolean forceStart, boolean forceEnd) {\r
return checkSlash(PATHSEPARATOR, data, forceStart, forceEnd);\r
public static String checkSlash(String separator, String data, boolean forceStart, boolean forceEnd) {\r
String result = "";\r
if (data != null) {\r
- // Hibát okoz linux alatt a teljes elérési utak esetében!\r
+ // Hibát okoz linux alatt a teljes elérési utak esetében!\r
result = StringUtils.strip(data, separator);\r
result = forceStart ? separator + result : result;\r
result = forceEnd ? result + separator : result;\r
\r
- // lehetséges javítás, tesztelendõ\r
+ // lehetséges javítás, tesztelendő\r
// if (result.indexOf(separator) != 0 && forceStart)\r
// result = separator + result;\r
//\r
return combine(path1, path2, false, false);\r
}\r
\r
- public static String combine(String path1, String path2, boolean isFile, boolean forceSystemSeparator) throws Exception {\r
+ public static String combine(String path1, String path2, boolean isFile, boolean forceSystemSeparator)\r
+ throws Exception {\r
String result = "";\r
String separator = null;\r
String normalizedPath1 = null;\r
import java.util.EventObject;\r
\r
/**\r
- * <b>File eseménykezelõ.</b>\r
+ * <b>File eseménykezelő.</b>\r
* \r
* @author vasary\r
*/\r
import java.io.FileFilter;\r
\r
/**\r
- * <b>Ftp file lista filter.</b>\r
- * A LIST parancs paraméterébõl FileFilter-t készít a szûréshez.\r
+ * <b>Ftp file lista filter.</b> A LIST parancs paraméteréből FileFilter-t\r
+ * készít a szűréshez.\r
* \r
* @author vasary\r
*/\r
public class SambaFileFilter implements FileFilter {\r
private String params = null;\r
- private boolean forDirectories = false; \r
- \r
+ private boolean forDirectories = false;\r
+\r
SambaFileFilter(String params, boolean forDirectories) {\r
this.params = params;\r
this.forDirectories = forDirectories;\r
}\r
- \r
+\r
public boolean accept(File file) {\r
- boolean ret = false; \r
+ boolean ret = false;\r
String name = file.getName();\r
- \r
- if (forDirectories) \r
+\r
+ if (forDirectories)\r
ret = file.isDirectory();\r
else\r
ret = file.isFile();\r
- \r
+\r
if (ret == false)\r
return ret;\r
- \r
+\r
if (params == null || params.trim().length() == 0)\r
return ret;\r
- \r
+\r
if (params.startsWith("*")) {\r
ret &= name.endsWith(params.replace("*", ""));\r
return ret;\r
}\r
- \r
+\r
if (params.endsWith("*")) {\r
ret &= name.startsWith(params.replace("*", ""));\r
return ret;\r
String[] p = params.split("\\*");\r
if (p.length == 2)\r
ret &= name.startsWith(p[0]) && name.endsWith(p[1]);\r
- } else \r
+ } else\r
ret &= file.getName().equals(params);\r
- \r
+\r
return ret;\r
}\r
}\r
import java.util.EventObject;\r
\r
/**\r
- * <b>Státusz eseménykezelõ.</b>\r
+ * <b>Státusz eseménykezelő.</b>\r
* \r
* @author vasary\r
*/\r
\r
private static final long serialVersionUID = 1L;\r
private boolean cancel = false;\r
- \r
+\r
public boolean isCancel() {\r
return cancel;\r
}\r
cancel = true;\r
}\r
}\r
-\r
package user.commons.ftp;\r
\r
-\r
import static org.junit.Assert.assertEquals;\r
\r
import java.util.List;\r
\r
public class TestFtp {\r
private static FtpServer server = null;\r
- \r
- @BeforeClass \r
+\r
+ @BeforeClass\r
public static void beforeTest() {\r
// server = new FtpServer();\r
// server.start();\r
}\r
\r
- @AfterClass \r
+ @AfterClass\r
public static void afterTest() {\r
// server.shutdown();\r
}\r
client.disconnect();\r
}\r
\r
- @Test(expected=FtpException.class)\r
+ @Test(expected = FtpException.class)\r
public void testWrongLogin() {\r
FtpClient client = new FtpClient();\r
client.connect("localhost", 21);\r
client.login("ftpx", "xxx");\r
client.disconnect();\r
}\r
- \r
+\r
@Test\r
public void testPwd() {\r
FtpClient client = new FtpClient();\r
assertEquals(2, list.length);\r
client.disconnect();\r
}\r
- \r
+\r
@Test\r
public void testFormattedList() {\r
FtpClient client = new FtpClient();\r
assertEquals(2, list.size());\r
client.disconnect();\r
}\r
- \r
+\r
@Test\r
public void testUpload() {\r
FtpClient client = new FtpClient();\r
public void fileUpload(FileEvent evt) {\r
System.out.println("Uploaded: " + evt.getPercentComplete() + "%");\r
}\r
+\r
public void fileDownload(FileEvent evt) {\r
}\r
});\r
- \r
+\r
client.upload("c:\\junit test.txt", "junit test.txt");\r
client.disconnect();\r
}\r
client.addFileListener(new FileEventListener() {\r
public void fileUpload(FileEvent evt) {\r
System.out.println("Uploaded: " + evt.getPercentComplete() + "%");\r
- //teszt 10 százalék elérésekor megszakítva a feltöltés\r
+ // teszt 10 százalék elérésekor megszakítva a feltöltés\r
if (evt.getPercentComplete() >= 10) {\r
evt.cancel();\r
}\r
}\r
+\r
public void fileDownload(FileEvent evt) {\r
}\r
});\r
- \r
+\r
client.upload("c:\\2.avi", "2.avi");\r
client.disconnect();\r
}\r
client.addFileListener(new FileEventListener() {\r
public void fileUpload(FileEvent evt) {\r
}\r
+\r
public void fileDownload(FileEvent evt) {\r
System.out.println("Dowloaded: " + evt.getPercentComplete() + "%");\r
}\r
});\r
- \r
+\r
client.download("junit test.txt", "c:\\junit test.txt");\r
client.disconnect();\r
}\r
client.addFileListener(new FileEventListener() {\r
public void fileUpload(FileEvent evt) {\r
}\r
+\r
public void fileDownload(FileEvent evt) {\r
System.out.println("Dowloaded: " + evt.getPercentComplete() + "%");\r
- //teszt 10 százalék elérésekor megszakítva a letöltés\r
+ // teszt 10 százalék elérésekor megszakítva a letöltés\r
if (evt.getPercentComplete() >= 10) {\r
evt.cancel();\r
}\r
}\r
});\r
- \r
+\r
client.download("1.avi", "c:\\1.avi");\r
client.disconnect();\r
}\r
select * from PRG_SERIES_VW where SERIES_ID = 10024100369\r
\r
select * from PRG_PROG_VW where SERIES_ID = 10024100369\r
---SERIES_ID olyan prog id aminek az elemeit keressük\r
+--SERIES_ID olyan prog id aminek az elemeit keressük\r
\r
select * from PRG_PROG_VW where PROG_ID = 10024100369\r
\r
\r
insert into filetype (name, videocodec, audiocodec, videotracks, audiotracks, framerate) values ('hanganyag', '', 'MP3', 0, 1, 0)\r
insert into filetype (name, videocodec, audiocodec, videotracks, audiotracks, framerate) values ('film', 'MPEG2_V', 'MPEG2_A', 1, 1, 25)\r
-insert into filetype (name, videocodec, audiocodec, videotracks, audiotracks, framerate) values ('bináris', '', '', 0, 0, 0)\r
+insert into filetype (name, videocodec, audiocodec, videotracks, audiotracks, framerate) values ('bináris', '', '', 0, 0, 0)\r
\r
-insert into store (name) values ('Archívum gyorstár')\r
-insert into storeuri (storeid,uri,isstream) select id as storeid, 'ftp://localhost:4503/', 'N' as isstream from store where name='Archívum gyorstár'\r
+insert into store (name) values ('Archívum gyorstár')\r
+insert into storeuri (storeid,uri,isstream) select id as storeid, 'ftp://localhost:4503/', 'N' as isstream from store where name='Archívum gyorstár'\r
update item set created ='2011-01-01'\r
\r
\r
---insert into storeuri (storeid, uri, isstream) values ( 'bináris', '', '', 0, 0, 0)\r
+--insert into storeuri (storeid, uri, isstream) values ( 'bináris', '', '', 0, 0, 0)\r
--select id as storeid, 'ftp://localhost:4503/' from store where name='Local NAS'\r
\r
\r
select * from masterid where created = '2100-01-03'\r
\r
\r
-insert into media (id, itemid, itemtypeid, name, description, length) values (1615821, 1165826, 103, 'MPG1 média', 'MPG1 média test', 0)\r
+insert into media (id, itemid, itemtypeid, name, description, length) values (1615821, 1165826, 103, 'MPG1 média', 'MPG1 média test', 0)\r
\r
select * from mediafile where mediaid = 1165827 \r
delete from mediafile where id =1938921 \r
select * from store\r
\r
WITH NUMBEREDITEM AS (\r
-SELECT ROWNUMBER() OVER(ORDER BY md."Gyártó ország" ASC) AS RN,\r
-i.ID, i.NAME, i.DESCRIPTION, i.CREATED, i.HOUSEID, md."Kameraállás",md."Csatorna" FROM METADATA_0323 md INNER JOIN ITEM i ON (md.ID = i.ID) WHERE md.ID IN(SELECT ID FROM SESSION.SEARCHTEMP WHERE ITEMTYPEID = 323)) SELECT * FROM NUMBEREDITEM WHERE RN BETWEEN 0 AND 10\r
+SELECT ROWNUMBER() OVER(ORDER BY md."Gyártó ország" ASC) AS RN,\r
+i.ID, i.NAME, i.DESCRIPTION, i.CREATED, i.HOUSEID, md."Kameraállás",md."Csatorna" FROM METADATA_0323 md INNER JOIN ITEM i ON (md.ID = i.ID) WHERE md.ID IN(SELECT ID FROM SESSION.SEARCHTEMP WHERE ITEMTYPEID = 323)) SELECT * FROM NUMBEREDITEM WHERE RN BETWEEN 0 AND 10\r
\r
\r
WITH NUMBEREDITEM AS \r
-(SELECT ROWNUMBER() OVER(ORDER BY md."Fõszereplõ" DESC) AS RN, i.ID, i.NAME, i.DESCRIPTION, i.CREATED, i.HOUSEID, md."Fõszereplõ" FROM METADATA_0321 md INNER JOIN ITEM i ON (md.ID = i.ID) ) \r
+(SELECT ROWNUMBER() OVER(ORDER BY md."Főszereplő" DESC) AS RN, i.ID, i.NAME, i.DESCRIPTION, i.CREATED, i.HOUSEID, md."Főszereplő" FROM METADATA_0321 md INNER JOIN ITEM i ON (md.ID = i.ID) ) \r
SELECT * FROM NUMBEREDITEM\r
\r
, \r
left outer join METADATA_0322 m_0322 on (m_0322.id = m.id)\r
left outer join METADATA_0323 m_0323 on (m_0323.id = m.id)\r
left outer join METADATA_0324 m_0324 on (m_0324.id = m.id)\r
-where i_0321."Fõszereplõ" is not null\r
+where i_0321."Főszereplő" is not null\r
\r
\r
\r
\r
\r
\r
-select * from METADATA_0321 where "Fõszereplõ" is not null\r
+select * from METADATA_0321 where "Főszereplő" is not null\r
\r
\r
\r
LEFT OUTER JOIN METADATA md ON (it.ID = md.ITEMTYPEID)\r
LEFT OUTER JOIN METADATAELEMENT mde ON (md.METADATAELEMENTID = mde.ID)\r
LEFT OUTER JOIN METADATATYPE mdt ON (mde.METADATATYPEID = mdt.ID)\r
-WHERE mde.NAME = 'Fõszereplõ'\r
+WHERE mde.NAME = 'Főszereplő'\r
\r
SELECT DISTINCT i.ID FROM ITEM i LEFT OUTER JOIN MEDIA m ON (m.ITEMID = i.ID) WHERE\r
\r
) h on i.title=h.title\r
order by i.created desc\r
\r
-select * from item where title='2018.01.17 22:00 H�rad� Echo TV'\r
+select * from item where title='2018.01.17 22:00 Híradó Echo TV'\r
select * from media where itemid=30677\r
select * from media where itemid=30567\r
\r
--Delete wrong metadatas\r
\r
---Összes felülírt PGM (törölhetõek)\r
+--összes fel�l�rt PGM (törölhetőek)\r
delete from mediafile where mediaid in (\r
select i.mediaid from vw_items i inner join vw_itemduplicates id on i.mediafilehouseid=id.mediafilehouseid and i.archived!=id.maxarchived \r
where i.mediafilehouseid like '%PGM%'\r
select mediaid from mediafile\r
)\r
\r
---ELLENÕRZÉS Összes felülírt PGM (törölhetõek)\r
+--ELLENŐRZÉS összes fel�l�rt PGM (törölhetőek)\r
select count(*) from mediafile where mediaid in (\r
select i.mediaid from vw_items i inner join vw_itemduplicates id on i.mediafilehouseid=id.mediafilehouseid and i.archived!=id.maxarchived \r
where i.mediafilehouseid like '%PGM%'\r
where i.mediafilehouseid like '%PGM%'\r
order by mediafilehouseid, archived\r
\r
---Összes duplikátum számossága, legújabb verzió\r
+--összes duplikátum számossága, legűjabb verzió\r
drop view vw_itemduplicates\r
\r
create view vw_itemduplicates as \r
\r
SELECT count(*) FROM DB2ADMIN.WORKFLOWACTION where username is not null\r
\r
-SELECT count(*) FROM media left outer join itemtype on (itemtype.id=media.itemtypeid) where itemtype.name='Visszarögzített'\r
+SELECT count(*) FROM media left outer join itemtype on (itemtype.id=media.itemtypeid) where itemtype.name='Visszarögzített'\r
\r
\r
--MEDIAFILE\r
\r
\r
\r
---Összes klip\r
+--összes klip\r
select count (*) from media where created like '2017-12%'\r
select count (distinct(houseid)) from media where created like '2017-12%'\r
select distinct(houseid) from media where created like '2017-12%'\r
\r
select count(distinct(mediahouseid)) from vw_items where mediacreated like '2018-01%'\r
\r
---Octopus ID-hez rendelt manuálisan archivált klip \r
+--Octopus ID-hez rendelt manuálisan archivált klip \r
select i.created, i.houseid as ihouse, i.title as ititle, m.houseid as mhouse, m.title as mtitle from item i left outer join media m on (m.itemid = i.id) \r
select i.created, i.houseid as ihouse, i.title as ititle, m.houseid as mhouse, m.title as mtitle from item i left outer join media m on (m.itemid = i.id) where i.title like 'Echo TV%' \r
\r
select * from vw_items where itemtitle like 'Echo TV%' and mediacreated like '2018-01%'\r
select count(distinct(mediahouseid)) from vw_items where itemtitle like 'Echo TV%' and mediacreated like '2018-01%'\r
\r
---Automatikusan archivált bejátszók\r
+--Automatikusan archivált bejátszók\r
select * from vw_items where itemtitle like '%Echo TV%' and itemtitle like '2%' and mediatitle not like '%CLN%' and mediatitle not like '%PGM%' and mediacreated like '2018-01%' \r
select count(distinct(mediahouseid)) from vw_items where itemtitle like '%Echo TV%' and itemtitle like '2%' and mediatitle not like '%CLN%' and mediatitle not like '%PGM%' and mediacreated like '2018-01%' \r
\r
---ID-hez nem rendelt manuálisan archivált egyéb klip (magazin vagy forgatott)\r
+--ID-hez nem rendelt manuálisan archivált egyéb klip (magazin vagy forgatott)\r
select i.created, i.houseid as ihouse, i.title as ititle, i.description as idesc, m.houseid as mhouse, m.title as mtitle, m.description as mdesc from item i left outer join media m on (m.itemid = i.id) where i.houseid like 'MC-%' and m.houseid like 'MC-%' \r
select i.created, i.houseid as ihouse, i.title as ititle, i.description as idesc, m.houseid as mhouse, m.title as mtitle, m.description as mdesc from item i left outer join media m on (m.itemid = i.id) where i.houseid like 'MC-%' and m.houseid like 'MC-%' and m.created like '2018-01%'\r
\r
select * from vw_items where itemtitle like 'MC-%' and mediahouseid like 'MC-%'and mediacreated like '2018-01%' \r
select count(distinct(mediahouseid)) from vw_items where itemtitle like 'MC-%' and mediahouseid like 'MC-%'and mediacreated like '2018-01%' \r
\r
---Migrált archívum\r
+--Migrált archívum\r
select i.created, i.houseid as ihouse, i.title as ititle, m.houseid as mhouse, m.title as mtitle from item i left outer join media m on (m.itemid = i.id) where i.houseid not like 'MC-%' and m.houseid like 'MC-%' \r
\r
---Reklám ID-hez rendelt klip\r
+--Reklám ID-hez rendelt klip\r
select * from vw_items where mediahouseid like 'R%'and mediacreated like '2018-01%' \r
select count(distinct(mediahouseid)) from vw_items where mediahouseid like 'R%'and mediacreated like '2018-01%' \r
\r
select * from vw_items where mediahouseid like 'P%'and mediacreated like '2018-01%' \r
select count(distinct(mediahouseid)) from vw_items where mediahouseid like 'P%'and mediacreated like '2018-01%' \r
\r
---Mûsor ID-hez rendelt klip\r
+--Műsor ID-hez rendelt klip\r
select * from vw_items where mediafilehouseid like 'M%' and mediafilehouseid not like 'MC%' and mediacreated like '2018-01%'\r
select count(distinct(mediafilehouseid)) from vw_items where mediafilehouseid like 'M%' and mediafilehouseid not like 'MC%' and mediacreated like '2018-01%'\r
\r
\r
select * from recordings_summertime where x1!=x2 and x2 = '1900' order by itemtitle\r
\r
-select * from item where description like 'Javított%'\r
-update item set title = '2018.03.25 08:00 Híradó Echo TV' where id=59041\r
+select * from item where description like 'Javított%'\r
+update item set title = '2018.03.25 08:00 Híradó Echo TV' where id=59041\r
\r
\r
select * from item where id = 58968\r
\r
select * from vw_items where MEDIAFILEHOUSEID = '20180325-1900_hirado_PGM_-_V.MXF'\r
\r
-select * from item where title = '2018.03.08 19:00 Hírek Echo TV'\r
+select * from item where title = '2018.03.08 19:00 Hírek Echo TV'\r
\r
\r
update media set itemid=52063 where id=52341\r
-update item set title ='2018.03.08 19:10 Hírek Echo TV' where id=52063\r
+update item set title ='2018.03.08 19:10 Hírek Echo TV' where id=52063\r
\r
\r
\r
\r
update ftclob set text = concat(text, (select description from media where id = '40186'))\r
\r
-update ftclob set text = concat(text, ' Vásáry Dani ')\r
+update ftclob set text = concat(text, ' Vásáry Dani ')\r
\r
-SELECT id FROM ftclob WHERE CONTAINS(text, 'vásáry + dani')\r
+SELECT id FROM ftclob WHERE CONTAINS(text, 'vásáry + dani')\r
\r
\r
select length(TEXT) from ftclob\r
select id from item where title like '2%' and title like '%Echo%'\r
) group by i.title order by l desc\r
\r
-select * from item where title='2018.01.24 22:00 Híradó Echo TV'\r
+select * from item where title='2018.01.24 22:00 Híradó Echo TV'\r
select * from media where itemid = 32962\r
\r
select mediafilehouseid, count(*) as c from vw_items where mediatitle like '%PGM%' group by mediafilehouseid order by c desc\r
\r
---Napi duplikátum\r
+--Napi duplikátum\r
select mediafilehouseid, count(*) as c from vw_items where archived like '%02.%' group by mediafilehouseid order by c desc\r
---Összes klip\r
+--összes klip\r
select * from vw_items where mediacreated like '2018-01%'\r
select distinct(mediafilehouseid) from vw_items where mediacreated like '2018-01%'\r
select count(distinct(mediafilehouseid)) from vw_items where mediacreated like '2018-01%'\r
\r
select * from vw_items where mediacreated like '2018-01%'\r
\r
---Automatikusan archivált bejátszók\r
+--Automatikusan archivált bejátszók\r
select * from vw_items where itemtitle like '%Echo TV%' and itemtitle like '2%' and mediatitle not like '%CLN%' and mediatitle not like '%PGM%' and mediacreated like '2018-01%' \r
select count(distinct(mediafilehouseid)) from vw_items where itemtitle like '%Echo TV%' and itemtitle like '2%' and mediatitle not like '%CLN%' and mediatitle not like '%PGM%' and mediacreated like '2018-01%' \r
\r
---Automatikusan archivált visszarögzítések\r
+--Automatikusan archivált visszarögzítések\r
select * from vw_items where itemtitle like '%Echo TV%' and itemtitle like '2%' and (mediatitle like '%CLN%' or mediatitle like '%PGM%') and mediacreated like '2018-01%' \r
select count(distinct(mediafilehouseid)) from vw_items where itemtitle like '%Echo TV%' and itemtitle like '2%' and (mediatitle like '%CLN%' or mediatitle like '%PGM%') and mediacreated like '2018-01%' \r
\r
---ID-hez nem rendelt manuálisan archivált egyéb klip (magazin vagy forgatott)\r
+--ID-hez nem rendelt manuálisan archivált egyéb klip (magazin vagy forgatott)\r
select * from vw_items where itemtitle like 'MC-%' and mediahouseid like 'MC-%'and mediacreated like '2018-01%' \r
select count(distinct(mediafilehouseid)) from vw_items where itemtitle like 'MC-%' and mediahouseid like 'MC-%'and mediacreated like '2018-01%' \r
\r
)\r
\r
\r
---Migrált archívum\r
+--Migrált archívum\r
select i.created, i.houseid as ihouse, i.title as ititle, m.houseid as mhouse, m.title as mtitle from item i left outer join media m on (m.itemid = i.id) where i.houseid not like 'MC-%' and m.houseid like 'MC-%' \r
\r
---Reklám ID-hez rendelt klip\r
+--Reklám ID-hez rendelt klip\r
select * from vw_items where mediahouseid like 'R%'and mediacreated like '2018-01%' \r
select count(distinct(mediafilehouseid)) from vw_items where mediahouseid like 'R%'and mediacreated like '2018-01%' \r
\r
--select mediafilehouseid, count(*) from vw_items where mediahouseid like 'P%'and mediacreated like '2018-01%' group by mediafilehouseid\r
--select * from vw_items where mediahouseid like 'P%'and mediacreated like '2018-01%' and (mediafilehouseid='P001473A.MXF' or mediafilehouseid='P001479A.MXF')\r
\r
---Mûsor ID-hez rendelt klip\r
+--Műsor ID-hez rendelt klip\r
select * from vw_items where mediafilehouseid like 'M%' and mediafilehouseid not like 'MC%' and mediacreated like '2018-01%'\r
select count(distinct(mediafilehouseid)) from vw_items where mediafilehouseid like 'M%' and mediafilehouseid not like 'MC%' and mediacreated like '2018-01%'\r
\r
--- Egyéb ?\r
+-- Egyéb ?\r
\r
select mediafilehouseid, count(*) as c from vw_items where mediafilehouseid not like 'M%' and mediahouseid not like 'P%' and mediahouseid not like 'R%' and mediafilehouseid not like 'MC%' and mediacreated like '2018-01%'\r
and itemtitle not like '%Echo TV%' and itemtitle not like '2%' and mediatitle not like '%CLN%' and mediatitle not like '%PGM%'\r
select * from itemtype\r
-insert into itemtype (name, description, isstatic) values('Hír bejátszó','Hír bejátszó','N') \r
+insert into itemtype (name, description, isstatic) values('Hír bejátszó','Hír bejátszó','N') \r
\r
select count(*) from media where ITEMTYPEID in (select id from itemtype where name='Generic')\r
-select count(*) from item where ITEMTYPEID in (select id from itemtype where name='Mûsor nyersanyag')\r
+select count(*) from item where ITEMTYPEID in (select id from itemtype where name='Műsor nyersanyag')\r
\r
-delete from itemtype where ID in (select id from itemtype where name='Mûsor nyersanyag')\r
+delete from itemtype where ID in (select id from itemtype where name='Műsor nyersanyag')\r
\r
update media set itemtypeid = 81 where itemtypeid = 66\r
\r
\r
-update media set itemtypeid=(select id from itemtype where name='Visszarögzített') where ID in (select mediaid from vw_items where itemtitle like '%Echo TV%' and itemtitle like '2%' and mediatitle like '%PGM%')\r
-update media set itemtypeid=(select id from itemtype where name='Hír bejátszó') where ID in (select mediaid from vw_items where itemtitle like '%Echo TV%' and itemtitle like '2%' and mediatitle not like '%CLN%' and mediatitle not like '%PGM%')\r
-update media set itemtypeid=(select id from itemtype where name='Visszarögzített') where ID in (select mediaid from vw_items where mediatitle like '%CLN%')\r
+update media set itemtypeid=(select id from itemtype where name='Visszarögzített') where ID in (select mediaid from vw_items where itemtitle like '%Echo TV%' and itemtitle like '2%' and mediatitle like '%PGM%')\r
+update media set itemtypeid=(select id from itemtype where name='Hír bejátszó') where ID in (select mediaid from vw_items where itemtitle like '%Echo TV%' and itemtitle like '2%' and mediatitle not like '%CLN%' and mediatitle not like '%PGM%')\r
+update media set itemtypeid=(select id from itemtype where name='Visszarögzített') where ID in (select mediaid from vw_items where mediatitle like '%CLN%')\r
\r
select * from vw_items where itemtitle like '%Echo TV%' and itemtitle like '2%' and mediatitle not like '%CLN%' and mediatitle not like '%PGM%'\r
select * from vw_items where mediatitle like '%CLN%'\r
select * from vw_items where mediatitle like '%PGM%'\r
\r
-update media set itemtypeid=(select id from itemtype where name='Hír bejátszó') where ITEMTYPEID=2 and ID in ( \r
+update media set itemtypeid=(select id from itemtype where name='Hír bejátszó') where ITEMTYPEID=2 and ID in ( \r
select mediaid from vw_items where regexp_like(mediafilehouseid, '\d{8}_\d{1}-\d{8}\.MXF', 1))\r
\r
-update media set itemtypeid=(select id from itemtype where name='Hír nyers') where ITEMTYPEID=2 and ID in ( \r
+update media set itemtypeid=(select id from itemtype where name='Hír nyers') where ITEMTYPEID=2 and ID in ( \r
select mediaid from vw_items where mediatype='Generic' and MEDIAHOUSEID like 'MC-%' and MEDIAFILEHOUSEID not like 'MC-%' and regexp_like(mediafilehouseid, '\d{6}', 1) and regexp_like(itemtitle, '\d{6}', 1) and itemtitle not like 'MC-%')\r
\r
-update media set itemtypeid=(select id from itemtype where name='Mûsor') where ITEMTYPEID=2 and ID in ( \r
+update media set itemtypeid=(select id from itemtype where name='Műsor') where ITEMTYPEID=2 and ID in ( \r
select mediaid from vw_items where mediatype='Generic' and regexp_like(mediafilehouseid, 'M\d{6}.\.MXF', 1)\r
)\r
\r
select mediaid from vw_items where mediatype='Generic' and regexp_like(mediafilehouseid, 'P\d{6}.\.MXF', 1)\r
)\r
\r
-update media set itemtypeid=(select id from itemtype where name='Reklám') where ITEMTYPEID=2 and ID in ( \r
+update media set itemtypeid=(select id from itemtype where name='Reklám') where ITEMTYPEID=2 and ID in ( \r
select mediaid from vw_items where mediatype='Generic' and regexp_like(mediafilehouseid, 'R\d{6}.\.MXF', 1)\r
)\r
\r
select itemtitle, mediatitle, mediahouseid, mediafilehouseid from vw_items where mediatype='Generic' and regexp_like(mediafilehouseid, 'M\d{6}.\.MXF', 1)\r
select itemtitle, mediatitle, mediahouseid, mediafilehouseid from vw_items where mediatype='Generic' and regexp_like(mediafilehouseid, 'P\d{6}.\.MXF', 1)\r
select itemtitle, mediatitle, mediahouseid, mediafilehouseid from vw_items where mediatype='Generic' and regexp_like(mediafilehouseid, 'R\d{6}.\.MXF', 1)\r
-select itemtitle, mediatitle, mediahouseid, mediafilehouseid from vw_items where mediatype='Generic' and itemtitle like '%híradó%'\r
+select itemtitle, mediatitle, mediahouseid, mediafilehouseid from vw_items where mediatype='Generic' and itemtitle like '%híradó%'\r
\r
-select itemtitle, mediatitle, mediahouseid, mediafilehouseid, tag, username, source from vw_items, vw_workflow where mediatype='Generic' and itemtitle like '%híradó%' and filename=mediafilehouseid\r
+select itemtitle, mediatitle, mediahouseid, mediafilehouseid, tag, username, source from vw_items, vw_workflow where mediatype='Generic' and itemtitle like '%híradó%' and filename=mediafilehouseid\r
\r
select itemtitle, mediatitle, mediahouseid, mediafilehouseid, tag, username, source from vw_items \r
left outer join vw_workflow on (filename=mediafilehouseid)\r
-where mediatype='Generic' and itemtitle like '%híradó%'\r
+where mediatype='Generic' and itemtitle like '%híradó%'\r
\r
select * from vw_items \r
-where mediatype='Generic' and itemtitle like '%híradó%' and mediafilehouseid not in (select filename from vw_workflow)\r
+where mediatype='Generic' and itemtitle like '%híradó%' and mediafilehouseid not in (select filename from vw_workflow)\r
\r
---Törökõr\r
+--T�r�k�r\r
select mediatype, itemtitle, itemhouseid, mediatitle, mediahouseid, mediafilehouseid from vw_items where mediahouseid like 'MC-%' and regexp_like(itemtitle, '^\d{6}', 1) order by itemtitle asc\r
\r
drop view vw_wflog\r
package user.commons;\r
\r
/**\r
- * Commons kivétel. \r
+ * Commons kivétel.\r
*/\r
public class CommonsException extends RuntimeException {\r
private static final long serialVersionUID = -2357518580850559771L;\r
import java.util.Map;\r
\r
/**\r
- * <b>Hashtable alapú paraméter tároló.</b>\r
- * A paraméterek típus helyesen írhatóak be és vehetõek ki. \r
+ * <b>Hashtable alapú paraméter tároló.</b> A paraméterek típus helyesen\r
+ * írhatóak be és vehetőek ki.\r
*/\r
public class CommonsProperties {\r
static public void checkParameter(String name, double parameter) {\r
if (parameter == 0) {\r
- String msg = name + " cannot be 0.";\r
+ String msg = name + " can not be 0.";\r
throw new IllegalArgumentException(msg);\r
}\r
- } \r
+ }\r
\r
static public void checkParameter(String name, int parameter) {\r
if (parameter == 0) {\r
- String msg = name + " cannot be 0.";\r
+ String msg = name + " can not be 0.";\r
throw new IllegalArgumentException(msg);\r
}\r
}\r
\r
static public void checkParameter(String name, long parameter) {\r
if (parameter == 0) {\r
- String msg = name + " cannot be 0.";\r
+ String msg = name + " can not be 0.";\r
throw new IllegalArgumentException(msg);\r
}\r
}\r
\r
static public void checkParameter(String name, Object parameter) {\r
if (parameter == null) {\r
- String msg = name + " cannot be null.";\r
+ String msg = name + " can not be null.";\r
throw new IllegalArgumentException(msg);\r
}\r
}\r
\r
static public void checkParameter(String name, String parameter) {\r
if (parameter == null) {\r
- String msg = name + " cannot be null.";\r
+ String msg = name + " can not be null.";\r
throw new NullPointerException(msg);\r
}\r
if (parameter.trim().equals("")) {\r
- String msg = name + " cannot be empty.";\r
+ String msg = name + " can not be empty.";\r
throw new IllegalArgumentException(msg);\r
}\r
}\r
\r
public Object get(String key) {\r
if (properties.containsKey(key) == false)\r
- throw new CommonsException("Key not available: " + key);\r
+ throw new CommonsException("Key is not available: " + key);\r
return properties.get(key);\r
}\r
\r
public boolean getBool(String key) {\r
Object value = get(key);\r
if (!(value instanceof Boolean))\r
- throw new CommonsException("Property doesn't contains Boolean value: " + key);\r
+ throw new CommonsException("Property doesn't contain Boolean value: " + key);\r
return Boolean.parseBoolean(value.toString());\r
}\r
\r
public int getInt(String key) {\r
Object value = get(key);\r
if (!(value instanceof Integer))\r
- throw new CommonsException("Property doesn't contains Integer value." + key);\r
+ throw new CommonsException("Property doesn't contain Integer value." + key);\r
return Integer.parseInt(value.toString());\r
}\r
- \r
+\r
public long getLong(String key) {\r
Object value = get(key);\r
if (!(value instanceof Long))\r
- throw new CommonsException("Property doesn't contains Long value." + key);\r
+ throw new CommonsException("Property doesn't contain Long value." + key);\r
return Long.parseLong(value.toString());\r
}\r
\r
public String getString(String key) {\r
Object value = get(key);\r
if (!(value instanceof String))\r
- throw new CommonsException("Property doesn't contains String value." + key);\r
+ throw new CommonsException("Property doesn't contain String value." + key);\r
return value.toString();\r
}\r
}\r
package user.commons.pool;\r
\r
/**\r
- * Pool kivétel. \r
+ * Pool kivétel.\r
*/\r
public class PoolException extends RuntimeException {\r
private static final long serialVersionUID = 874798532700307318L;\r
\r
/**\r
* <b>Erőforrás kezelő.</b> <br>\r
- * Az implementációban meghatározott típusú er�forr�s objektumb�l ig�ny szerint l�trehoz annyit, amennyi enged�lyezett. <br>\r
- * Az er�forr�s objektumok k�lcs�n�zhet�ek, visszaadhat�ak thread-safe m�don. <br>\r
- * Mind�g a legr�gebben haszn�lt objektumot k�lcs�nzi ki. <br>\r
- * Ha elfogy a k�lcs�n�zhet� objektum, v�rakoztat.\r
+ * Az implementációban meghatározott típusú erőforrás objektumból igény \r
+ * szerint létrehoz annyit, amennyi engedélyezett. <br>\r
+ * Az erőforrás objektumok kölcsönözhetőek, visszaadhatóak thread-safe módon. <br>\r
+ * Mindig a legrégebben használt objektumot kölcsönzi ki. <br>\r
+ * Ha elfogy a kölcsönözhető objektum, várakoztat.\r
*/\r
\r
abstract public class ResourcePool {\r
private int resourceCounter = 0;\r
\r
/**\r
- * Konstruktor a pool l�trehoz�s�ra.\r
+ * Konstruktor a pool létrehozására.\r
*\r
* @param properties\r
- * Be�ll�t�sok.\r
+ * beállítások.\r
*/\r
protected ResourcePool(int poolSize) {\r
resourceCounter = poolSize;\r
}\r
\r
/**\r
- * Er�forr�s objektum k�lcs�nz�se.\r
+ * Erőforrás objektum kölcsönzése.\r
*\r
- * @return Kik�lcs�nz�tt er�forr�s objektum. Visszet�r�s el�tt a checkObject-el ellen�rzi, hogy haszn�lhat� e az objektum. Ha nem �jat, hoz l�tre.\r
+ * @return Kikölcsönzött erőforrás objektum. Visszetérés előtt a \r
+ * checkObject-el ellenőrzi, hogy használható-e az objektum. Ha nem, \r
+ * újat hoz létre.\r
*/\r
\r
// <dependency>\r
}\r
\r
/**\r
- * Ellen�rzi, hogy haszn�lhat� e az objektum. Implement�ci� f�gg�!\r
+ * Ellenőrzi, hogy használható-e az objektum. implementáció függő!\r
*\r
* @param resourceObject\r
- * Ellen�rizend� objektum.\r
- * @return <b>true</b> ha m�r nem haszn�lhat�\r
+ * Ellenőrizendő objektum.\r
+ * @return <b>true</b> ha már nem használható\r
* @throws SQLException\r
*/\r
abstract protected boolean checkObject(Object resourceObject);\r
\r
/**\r
- * Az �sszes nem kik�lcs�nz�tt er�forr�s objektumot, a releaseObject h�v�ssal felszabad�tja.\r
+ * Az összes nem kikölcsönzött erőforrás objektumot, a releaseObject hívással felszabadítja.\r
*/\r
public void close() {\r
if (pool == null)\r
}\r
\r
/**\r
- * L�trehozza az er�forr�s objektumot. Implement�ci� f�gg�!\r
+ * létrehozza az erőforrás objektumot. implementáció függő!\r
*\r
- * @return A l�trehozott er�forr�s objektum.\r
+ * @return A létrehozott erőforrás objektum.\r
*/\r
abstract protected Object createObject();\r
\r
/**\r
- * K�lcs�nvett er�forr�s objektum visszaszolg�ltat�sa. T�pus �s null pointer elle�rz�s a validateObject seg�ts�g�vel.\r
+ * Kölcsönvett erőforrás objektum visszaszolgáltatása. Típus és null pointer ellenőrzés a validateObject segítségével.\r
*\r
* @param value\r
- * Er�forr�s objektum.\r
+ * Erőforrás objektum.\r
*/\r
protected void lendObject(Object value) {\r
if (pool == null) {\r
- throw new IllegalStateException("Pool never initialized, or closed. Did you missed something?");\r
+ throw new IllegalStateException("Pool is never initialized, or closed. Did you miss something?");\r
}\r
if (validateObject(value)) {\r
synchronized (this) {\r
}\r
\r
/**\r
- * Er�forr�s objektum felszabad�t�sa (kapcsolat lez�r�s, haszn�lt er�forr�sok felszabad�t�sa). Implement�ci� f�gg�!\r
+ * Erőforrás objektum felszabadítása (kapcsolat lezárás, használt erőforrások felszabadítása). implementáció függő!\r
*\r
* @param resourceObject\r
- * A sz�ban forg� objektum.\r
+ * A szóban forgó objektum.\r
*/\r
abstract protected void releaseObject(Object resourceObject);\r
\r
/**\r
- * Ellen�rzi, hogy az objektum t�pusa megfelel� e.\r
+ * Ellenőrzi, hogy az objektum típusa megfelelő-e.\r
*/\r
protected boolean validateObject(Object value) {\r
return value != null;\r
import user.commons.EntityBase;
/**
- * Lista Pojo osztály.
+ * Lista Pojo osztály.
*
* @author User
*
import user.commons.EntityBase;
/**
- * Lista kategória Pojo osztály.
+ * Lista kategória Pojo osztály.
*
* @author User
*
@SuppressWarnings("unchecked")
public List<Domain> getDomains() {
if (domains == null) {
- DomainDAO dao = (DomainDAO) ItemManager.getInstance().getBaseDAO(
- Domain.class);
+ DomainDAO dao = (DomainDAO) ItemManager.getInstance().getBaseDAO(Domain.class);
domains = (List<Domain>) (List<?>) dao.getAll(getId());
}
return domains;
import com.fasterxml.jackson.annotation.JsonIgnore;\r
\r
/**\r
- * Seg�d oszt�ly a dinamikus metaadatok kezel�s�re.\r
+ * Segédosztály a dinamikus metaadatok kezelésére.\r
*/\r
public class DynamicAttributes extends JSONBase implements Serializable {\r
private static final long serialVersionUID = 1L;\r
import user.commons.EntityBase;
/**
- * Mappa Pojo osztály.
+ * Mappa Pojo osztály.
*
* @author User
*
package user.jobengine.db;\r
\r
/**\r
- * ItemManager API kivétel. Az ilyen kivételek automatikusan naplózódnak level=ERROR. \r
+ * ItemManager API kivétel. Az ilyen kivételek automatikusan naplózódnak\r
+ * level=ERROR.\r
*/\r
public class ItemManagerException extends RuntimeException {\r
\r
super(e);\r
// ItemManager.getInstance().getLogger().error(message);\r
}\r
- \r
+\r
// public ItemManagerException(String message, boolean log) {\r
// super(message);\r
// if (log)\r
import user.commons.EntityBase;
/**
- * Anyag t�pus Pojo oszt�ly.
+ * Anyag típus Pojo osztály.
*
* @author User
*
}
/**
- * Serializ�ci�s technik�val m�solatot k�sz�t egy ItemType objektumr�l.
+ * Serializációs technikával másolatot készít egy ItemType objektumról.
*
- * @deprecated Az ItemType objektum m�sol�si technik�ra nincs sz�ks�g. Az
- * objektum kliens oldalon b�v�tend� a megjelen�t�shez sz�ks�ges
+ * @deprecated Az ItemType objektum másolási technikára nincs szükség. Az
+ * objektum kliens oldalon bővítendő a megjelenítéshez szükséges
* statikus Metadata objektumokkal.
- * @return ItemType objektum m�solata.
+ * @return ItemType objektum másolata.
*/
@Deprecated
ItemType copy() {
}\r
\r
/**\r
- * Besz�rja az Item objektumhoz kapcsol�d� statikus/dinamikus Media adatokat. \r
+ * Beszúrja az Item objektumhoz kapcsolódó statikus/dinamikus Media adatokat. \r
*/\r
void addAll(DefaultContext context, IEntityBase entity) throws SQLException {\r
manager.traceIn();\r
}\r
\r
/**\r
- * Beszúrja az ItemType objektumhoz kapcsolódó Metadata adatokat. \r
+ * Beszúrja az ItemType objektumhoz kapcsolódó Metadata adatokat. \r
*/\r
void addAll(DefaultContext context, ItemType itemType) throws SQLException {\r
List<Metadata> metadatas = itemType.getMetadatas();\r
}\r
\r
/**\r
- * Törli a paraméterként kapott ItemType azonosítóhoz tartozó Metadata bejegyzéseket. \r
+ * Törli a paraméterként kapott ItemType azonosítóhoz tartozó Metadata bejegyzéseket. \r
*/\r
void removeAll(DefaultContext context, long filterId) throws SQLException {\r
manager.traceIn();\r
isDomain = metadata.isDomain();\r
String fieldName = metadata.getFieldName();\r
\r
- // BooleanConverter h�v�s\r
+ // BooleanConverter hívás\r
List<Object> convertedValues = new ArrayList<Object>();\r
for (Object value : filter.getValues()) {\r
Object convertedValue = converter.ConvertBack(value, metadata);\r
getParameters(filter.getFilters());\r
}\r
\r
- // BooleanConverter visszakonvert�l�s\r
+ // BooleanConverter visszakonvertálás\r
List<Object> convertedBackValues = new ArrayList<Object>();\r
for (Object value : filter.getValues()) {\r
Object convertedBackValue = converter.Convert(value, metadata);\r
}\r
\r
/**\r
- * Törli a paraméterként kapott Store azonosítóhoz tartozó StoreUri bejegyzéseket. \r
+ * Törli a paraméterként kapott Store azonosítóhoz tartozó StoreUri bejegyzéseket. \r
*/\r
void removeAll(DefaultContext context, long filterId) throws SQLException {\r
manager.traceIn();\r
public class TestFileType {\r
private static IItemManager itemManager = new ItemManager();\r
\r
- @BeforeClass \r
+ @BeforeClass\r
public static void setUpConnection() {\r
itemManager.connect();\r
itemManager.truncate();\r
}\r
\r
- @AfterClass \r
+ @AfterClass\r
public static void tearDownConnection() {\r
itemManager.disconnect();\r
}\r
\r
@Test\r
public void testCreate() {\r
- //Létrehozás, paraméter ellenõrzés.\r
- FileType filetypeLowres = itemManager.createFileType("Lowres", "Streamable low-res video, 512Kbps", "WMVA", "WMA", 1, 1, 25);\r
+ // Létrehozás, paraméter ellenőrzés.\r
+ FileType filetypeLowres = itemManager.createFileType("Lowres", "Streamable low-res video, 512Kbps", "WMVA",\r
+ "WMA", 1, 1, 25);\r
assertEquals("Lowres", filetypeLowres.getName());\r
assertEquals("Streamable low-res video, 512Kbps", filetypeLowres.getDescription());\r
assertEquals("WMVA", filetypeLowres.getVideoCodec());\r
filetypeLowres.add();\r
}\r
\r
- @Test(expected=NullPointerException.class)\r
+ @Test(expected = NullPointerException.class)\r
public void testCreateNullName() {\r
- //Null paraméter.\r
+ // Null paraméter.\r
itemManager.createFileType(null, "Streamable low-res video, 512Kbps", "WMVA", "WMA", 1, 1, 25);\r
}\r
\r
- @Test(expected=NullPointerException.class)\r
+ @Test(expected = NullPointerException.class)\r
public void testCreateNullVideocodec() {\r
- //Null paraméter.\r
- itemManager.createFileType("Lowres", "Streamable low-res video, 512Kbps", null, "WMA", 1, 1, 25); \r
+ // Null paraméter.\r
+ itemManager.createFileType("Lowres", "Streamable low-res video, 512Kbps", null, "WMA", 1, 1, 25);\r
}\r
\r
- @Test(expected=NullPointerException.class)\r
+ @Test(expected = NullPointerException.class)\r
public void testCreateNullAudiocodec() {\r
- //Null paraméter.\r
- itemManager.createFileType("Lowres", "Streamable low-res video, 512Kbps", "WMVA", null, 1, 1, 25); \r
+ // Null paraméter.\r
+ itemManager.createFileType("Lowres", "Streamable low-res video, 512Kbps", "WMVA", null, 1, 1, 25);\r
}\r
\r
- @Test(expected=IllegalArgumentException.class)\r
+ @Test(expected = IllegalArgumentException.class)\r
public void testCreateZeroFrameRate() {\r
- //0 paraméter.\r
- itemManager.createFileType("Lowres", "Streamable low-res video, 512Kbps", "WMVA", "WMA", 1, 1, 0); \r
+ // 0 paraméter.\r
+ itemManager.createFileType("Lowres", "Streamable low-res video, 512Kbps", "WMVA", "WMA", 1, 1, 0);\r
}\r
}\r
\r
public class TestFolder {\r
private static IItemManager itemManager = new ItemManager();\r
- \r
- @BeforeClass \r
+\r
+ @BeforeClass\r
public static void setUpConnection() {\r
itemManager.connect();\r
}\r
\r
- @AfterClass \r
+ @AfterClass\r
public static void tearDownConnection() {\r
itemManager.disconnect();\r
}\r
\r
- //Test\r
+ // Test\r
public void testCreate() {\r
- Item item = itemManager.createItem("Film", "Sorozatok", "Sorozatok tároló mappája", null);\r
+ Item item = itemManager.createItem("Film", "Sorozatok", "Sorozatok tároló mappája", null);\r
item.setIsFolder(true);\r
item.add();\r
- \r
+\r
Item i = (Item) itemManager.get(Item.class, 1165861);\r
i.setFolderId(item.getId());\r
i.modify();\r
}\r
\r
- //@Test\r
+ // @Test\r
public void testCreateSub() {\r
Item i = (Item) itemManager.get(Item.class, 1165861);\r
- Item item = itemManager.createItem("Film", "Stargate Atlantis", "A Stargate CSK-1 utódsorozata.", null);\r
+ Item item = itemManager.createItem("Film", "Stargate Atlantis", "A Stargate CSK-1 utódsorozata.", null);\r
item.setIsFolder(true);\r
item.setFolderId(i.getId());\r
item.add();\r
- \r
+\r
}\r
\r
@Test\r
public void testGetFolders() {\r
- //List<Item> folders = itemManager.getFolders();\r
+ // List<Item> folders = itemManager.getFolders();\r
}\r
}\r
manager.getStore("Low-res").add();\r
\r
if (manager.getFileType("High-res") == null) {\r
- FileType fileType = manager.createFileType("High-res", "High resolution material", "MPEG Video", "PCM", 1, 8, 25);\r
+ FileType fileType = manager.createFileType("High-res", "High resolution material", "MPEG Video", "PCM", 1,\r
+ 8, 25);\r
fileType.add();\r
}\r
if (manager.getFileType("Low-res") == null) {\r
item.appendMedia(media);\r
item.add();\r
\r
- MediaFile mf = manager.createMediaFile("low.wmv", manager.getFileType("Lowres"), manager.getStore("Local video"), media);\r
+ MediaFile mf = manager.createMediaFile("low.wmv", manager.getFileType("Lowres"),\r
+ manager.getStore("Local video"), media);\r
mf.add();\r
}\r
\r
item.appendMedia(media);\r
item.add();\r
\r
- MediaFile mf = manager.createMediaFile("low.wmv", manager.getFileType("Lowres"), manager.getStore("Local video"), media);\r
+ MediaFile mf = manager.createMediaFile("low.wmv", manager.getFileType("Lowres"),\r
+ manager.getStore("Local video"), media);\r
mf.add();\r
\r
System.out.println("Item created: " + i);\r
\r
@Test\r
public void testCreateWithAttribute() {\r
- // L�trehoz�s, dinamikus attrib�tummal.\r
+ // létrehozás, dinamikus attribútummal.\r
// Fixture\r
Item sut = manager.createItem("Film", "Hatodik érzék", "Scifi", null);\r
String value1 = "Kalapács Miklós";\r
assertTrue(sut.getId() > 0);\r
\r
Item actual = (Item) manager.get(Item.class, sut.getId());\r
- assertEquals(value1, actual.getAttribute("Főpszereplő"));\r
+ assertEquals(value1, actual.getAttribute("Főszereplő"));\r
assertEquals(value2, actual.getAttribute("Szinkron"));\r
assertEquals(value3, actual.getAttribute("Gyártás éve"));\r
}\r
// Fixture\r
Item sut = null;\r
sut = manager.createItem("Domain", "Domain teszt record", "Scifi", null);\r
- sut.setAttribute("Szereplők", Arrays.asList(new Domain("Kovács Gizi"), new Domain("Szekér Ivett"), new Domain("Hanka Barbara")));\r
+ sut.setAttribute("Szereplők",\r
+ Arrays.asList(new Domain("Kovács Gizi"), new Domain("Szekér Ivett"), new Domain("Hanka Barbara")));\r
\r
// Exercise\r
sut.add();\r
\r
@Test(expected = ItemManagerException.class)\r
public void testCreateWithUniqueAttribute() {\r
- // L�trehoz�s, unique dinamikus attrib�tummal.\r
- // Az els� besz�r�s sikeres, a m�sodik nem, mert a mez� UNIQUE\r
+ // létrehozás, unique dinamikus attribútummal.\r
+ // Az első beszúrás sikeres, a második nem, mert a mező UNIQUE\r
// Fixture\r
Item sut = null;\r
sut = manager.createItem("Adásanyag", "Nyolcadik kör", "Scifi", null);\r
Calendar begin = CalendarUtils.createZeroCalendar();\r
Calendar end = CalendarUtils.createZeroCalendar();\r
end.add(Calendar.DAY_OF_YEAR, 1);\r
- List<IEntityBase> workflowActions = dao.getWorkflowActions(new Timestamp(begin.getTimeInMillis()), new Timestamp(end.getTimeInMillis()));\r
+ List<IEntityBase> workflowActions = dao.getWorkflowActions(new Timestamp(begin.getTimeInMillis()),\r
+ new Timestamp(end.getTimeInMillis()));\r
assertEquals(1000, workflowActions.size());\r
}\r
\r
Item item = manager.createItem("Generic", "Ötödik elem", "Scifi", "");\r
Media media = manager.createMedia("Generic", "Média1", "Nagyon frankó kis mozi.", null);\r
item.appendMedia(media);\r
- MediaFile mf = manager.createMediaFile("low.wmv", manager.getFileType("Low-res"), manager.getStore("TSM"), media);\r
+ MediaFile mf = manager.createMediaFile("low.wmv", manager.getFileType("Low-res"), manager.getStore("TSM"),\r
+ media);\r
media.appendMediaFile(mf);\r
// Exercise\r
manager.mergeItemStructure(item);\r
\r
Media media = manager.createMedia("Generic", "Média1", "Nagyon frankó kis mozi.", null);\r
item.appendMedia(media);\r
- MediaFile mf = manager.createMediaFile("low.wmv", manager.getFileType("Low-res"), manager.getStore("TSM"), media);\r
+ MediaFile mf = manager.createMediaFile("low.wmv", manager.getFileType("Low-res"), manager.getStore("TSM"),\r
+ media);\r
media.appendMediaFile(mf);\r
// Exercise\r
manager.mergeItemStructure(item);\r
item.appendMedia(media);\r
item.add();\r
\r
- MediaFile mf = manager.createMediaFile("low.wmv", manager.getFileType("Low-res"), manager.getStore("TSM"), media);\r
+ MediaFile mf = manager.createMediaFile("low.wmv", manager.getFileType("Low-res"), manager.getStore("TSM"),\r
+ media);\r
media.appendMediaFile(mf);\r
// Exercise\r
manager.mergeItemStructure(item);\r
// Fixture\r
Item item = null;\r
item = manager.createItem("Domain", "Domain teszt record", "Scifi", null);\r
- item.setAttribute("Szereplők", Arrays.asList(new Domain("Kovács Gizi"), new Domain("Szekér Ivett"), new Domain("Hanka Barbara")));\r
+ item.setAttribute("Szereplők",\r
+ Arrays.asList(new Domain("Kovács Gizi"), new Domain("Szekér Ivett"), new Domain("Hanka Barbara")));\r
item.add();\r
\r
// Exercise\r
// Fixture\r
Item sut = null;\r
sut = manager.createItem("Domain", "Domain teszt record", "Scifi", null);\r
- sut.setAttribute("Szereplők", Arrays.asList(new Domain("Kovács Gizi"), new Domain("Szekér Ivett"), new Domain("Hanka Barbara")));\r
+ sut.setAttribute("Szereplők",\r
+ Arrays.asList(new Domain("Kovács Gizi"), new Domain("Szekér Ivett"), new Domain("Hanka Barbara")));\r
sut.add();\r
\r
// Exercise\r
\r
@Test\r
public void testSetAttributeWithWrongType() {\r
- // L�tez� dinamikus attrib�tum rossz adatttal val� felt�lt�se.\r
+ // létező dinamikus attribútum rossz adatttal való feltöltése.\r
// Fixture\r
Item item = manager.createItem("Film", "Ötödik elem", "Scifi", null);\r
\r
// Exercise\r
- item.setAttribute("F�szerepl�", 10);\r
+ item.setAttribute("Főszereplő", 10);\r
\r
// Verify\r
- assertNull(item.getAttribute("F�szerepl�"));\r
+ assertNull(item.getAttribute("Főszereplő"));\r
}\r
\r
@Test\r
// Fixture\r
Item sut = null;\r
sut = manager.createItem("Domain", "Domain teszt record", "Scifi", null);\r
- sut.setAttribute("Szereplők", Arrays.asList(new Domain("Kovács Gizi"), new Domain("Szekér Ivett"), new Domain("Hanka Barbara")));\r
+ sut.setAttribute("Szereplők",\r
+ Arrays.asList(new Domain("Kovács Gizi"), new Domain("Szekér Ivett"), new Domain("Hanka Barbara")));\r
sut.add();\r
\r
// Exercise\r
- sut.setAttribute("Szerepl�k", null);\r
+ sut.setAttribute("Szereplők", null);\r
sut.modify();\r
\r
// Verify\r
public void testGetSystemStore() {\r
// Fixture\r
Store expected = manager.createStore("Store1", true, false);\r
- StoreUri uri = manager.createStoreUri(RemoteStoreProtocol.LOCAL, "c:/temp", 0, false, true, false, null, null, null);\r
+ StoreUri uri = manager.createStoreUri(RemoteStoreProtocol.LOCAL, "c:/temp", 0, false, true, false, null, null,\r
+ null);\r
expected.appendStoreUri(uri);\r
expected.add();\r
\r
public void testGetSystemStore_Lowres() {\r
// Fixture\r
Store expected = manager.createStore("Store1", true, true);\r
- StoreUri uri = manager.createStoreUri(RemoteStoreProtocol.LOCAL, "c:/temp", 0, false, true, false, null, null, null);\r
+ StoreUri uri = manager.createStoreUri(RemoteStoreProtocol.LOCAL, "c:/temp", 0, false, true, false, null, null,\r
+ null);\r
expected.appendStoreUri(uri);\r
expected.add();\r
\r
// public void testSearchItem_Folders() {\r
// // Fixture\r
// ItemType itemType = manager.getStaticItemType();\r
- // Metadata orderMetadata = itemType.getMetadata("Anyag c�m");\r
+ // Metadata orderMetadata = itemType.getMetadata("Anyag cím");\r
//\r
// RenderParameter parameters = new RenderParameter();\r
// parameters.setOrderBy(orderMetadata);\r
// MetadataType mdt = manager.createMetadataType("big integer",\r
// BaseType.BIGINT, "java.lang.Long", "BIGINT");\r
// MetadataElement mde = manager.createMetadataElement("Folder ID",\r
- // "Mappa azonos�t�", mdt);\r
+ // "Mappa azonosító", mdt);\r
// Metadata metadata = manager.createMetadata(mde, ListType.LABEL,\r
// GuiType.LABEL, "PARENTID", StaticTables.FOLDER, "parentId",\r
// MdType.SEARCH);\r
itemManager.truncate();\r
mdt = itemManager.createMetadataType("string100", BaseType.VARCHAR, "java.lang.String", "VARCHAR", 100);\r
mdt.add();\r
- mde1 = itemManager.createMetadataElement("Ország", "A gyártó ország", mdt);\r
+ mde1 = itemManager.createMetadataElement("Ország", "A gyártó ország", mdt);\r
mde1.add();\r
- mde2 = itemManager.createMetadataElement("Város", "?", mdt);\r
+ mde2 = itemManager.createMetadataElement("Város", "?", mdt);\r
mde2.add();\r
}\r
\r
\r
@Test\r
public void testCreate() {\r
- //Létrehozás, paraméter ellenõrzés.\r
+ // Létrehozás, paraméter ellenőrzés.\r
md1 = itemManager.createMetadata(mde1);\r
ItemType it = itemManager.createItemType("Itemtype1", "Itemtype1 description");\r
assertEquals("Itemtype1", it.getName());\r
\r
@Test(expected = IllegalStateException.class)\r
public void testCreateWithNoMetadata() {\r
- //Létrehozás kapcsolódó tartalom nélkül.\r
+ //Létrehozás kapcsolódó tartalom nélkül.\r
ItemType itemType = itemManager.createItemType("Itemtype1", "Itemtype1 description");\r
itemType.add();\r
}\r
\r
@Test(expected = NullPointerException.class)\r
public void testCreateWithNullName() {\r
- //Null paraméter.\r
+ //Null paraméter.\r
itemManager.createItemType(null, "Itemtype1 description");\r
}\r
\r
@Test(expected = NullPointerException.class)\r
public void testCreateWithNullDescription() {\r
- //Null paraméter.\r
+ //Null paraméter.\r
itemManager.createItemType("Itemtype1", null);\r
}\r
\r
@Test\r
public void testRemove() {\r
- //Törlés.\r
+ //Törlés.\r
md1 = itemManager.createMetadata(mde1);\r
md2 = itemManager.createMetadata(mde2);\r
ItemType itemType = itemManager.createItemType("Itemtype4", "Itemtype4 description");\r
\r
@Test\r
public void testCreate() {\r
- // Létrehozás, paraméter ellenõrzés.\r
- Item item = itemManager.createItem("Film", "Ötödik elem", "Scifi", null);\r
- Media media = itemManager.createMedia("Adásanyag", "Média1", "Nagyon frankó kis mozi.", null);\r
+ // Létrehozás, paraméter Ellenőrzős.\r
+ Item item = itemManager.createItem("Film", "Ötödik elem", "Scifi", null);\r
+ Media media = itemManager.createMedia("Adásanyag", "média1", "Nagyon frankó kis mozi.", null);\r
item.appendMedia(media);\r
item.add();\r
assertEquals(1, item.getMedias().size());\r
\r
@Test\r
public void testsetAttribute() {\r
- // Dinamikus attribútum ellenõrzés.\r
- Media media = itemManager.createMedia("Adásanyag", "Média1", "Nagyon frankó kis mozi.", null);\r
- media.setAttribute("Kameraállás", "Kamera1");\r
- assertEquals("Kamera1", media.getAttribute("Kameraállás"));\r
+ // Dinamikus attribútum ellenőrzés.\r
+ Media media = itemManager.createMedia("Adásanyag", "média1", "Nagyon frankó kis mozi.", null);\r
+ media.setAttribute("Kameraállás", "Kamera1");\r
+ assertEquals("Kamera1", media.getAttribute("Kameraállás"));\r
}\r
\r
@Test(expected = IllegalArgumentException.class)\r
public void testSetNonExistingAttribute() {\r
- // Nem létezõ dinamikus attribútum beállítása.\r
- Media media = itemManager.createMedia("Adásanyag", "Média1", "Nagyon frankó kis mozi.", null);\r
- media.setAttribute("Rendezõ", "Kalapács Miklós");\r
+ // Nem létező dinamikus attribútum beállítása.\r
+ Media media = itemManager.createMedia("Adásanyag", "média1", "Nagyon frankó kis mozi.", null);\r
+ media.setAttribute("Rendező", "Kalapács Miklós");\r
}\r
\r
@Test(expected = ItemManagerException.class)\r
public void testsetAttributeWithWrongType() {\r
- // Létezõ dinamikus attribútum rossz adatttal való feltöltése.\r
- Media media = itemManager.createMedia("Adásanyag", "Média1", "Nagyon frankó kis mozi.", null);\r
- media.setAttribute("Kameraállás", 10);\r
+ // létező dinamikus attribútum rossz adatttal való feltöltése.\r
+ Media media = itemManager.createMedia("Adásanyag", "média1", "Nagyon frankó kis mozi.", null);\r
+ media.setAttribute("Kameraállás", 10);\r
}\r
\r
@Test\r
public void testCreateWithAttribute() {\r
- // Létrehozás, dinamikus attribútummal.\r
- Item item = itemManager.createItem("Film", "Ötödik elem", "Scifi", null);\r
- Media media = itemManager.createMedia("Adásanyag", "Média1", "Nagyon frankó kis mozi.", null);\r
- media.setAttribute("Kameraállás", "bal");\r
+ // Létrehozás, dinamikus attribútummal.\r
+ Item item = itemManager.createItem("Film", "Ötödik elem", "Scifi", null);\r
+ Media media = itemManager.createMedia("Adásanyag", "média1", "Nagyon frankó kis mozi.", null);\r
+ media.setAttribute("Kameraállás", "bal");\r
media.setAttribute("Csatorna", 10);\r
item.appendMedia(media);\r
item.add();\r
\r
@Test(expected = ItemManagerException.class)\r
public void testCreateWithUniqueAttribute() {\r
- // Létrehozás, unique dinamikus attribútummal.\r
- // Az elsõ beszúrás sikeres, a második nem, mert a Szinkron mezõ UNIQUE\r
+ // Létrehozás, unique dinamikus attribútummal.\r
+ // Az első beszúrás sikeres, a második nem, mert a Szinkron mező UNIQUE\r
Item item = null;\r
- item = itemManager.createItem("Film", "Nyolcadik kör", "Scifi", null);\r
- Media media = itemManager.createMedia("Adásanyag", "Média1", "Nagyon frankó kis mozi.", null);\r
- media.setAttribute("Kameraállás", "jobb");\r
+ item = itemManager.createItem("Film", "Nyolcadik kör", "Scifi", null);\r
+ Media media = itemManager.createMedia("Adásanyag", "média1", "Nagyon frankó kis mozi.", null);\r
+ media.setAttribute("Kameraállás", "jobb");\r
media.setAttribute("Csatorna", 10);\r
item.appendMedia(media);\r
- media = itemManager.createMedia("Adásanyag", "Média2", "Nagyon frankó kis mozi.", null);\r
- media.setAttribute("Kameraállás", "jobb");\r
+ media = itemManager.createMedia("Adásanyag", "média2", "Nagyon frankó kis mozi.", null);\r
+ media.setAttribute("Kameraállás", "jobb");\r
media.setAttribute("Csatorna", 10);\r
item.appendMedia(media);\r
item.add();\r
\r
@Test\r
public void testCreate() {\r
- // Létrehozás, paraméter ellenõrzés.\r
- Item item = itemManager.createItem("Film", "Hastánc oktató 1", "Ez egy full rekord teszt.", null);\r
- Media media = itemManager.createMedia("Adásanyag", "Média1", "Nagyon frankó kis mozi.", null);\r
+ // Létrehozás, paraméter ellenőrzés.\r
+ Item item = itemManager.createItem("Film", "Hastánc oktató 1", "Ez egy full rekord teszt.", null);\r
+ Media media = itemManager.createMedia("Adásanyag", "média1", "Nagyon frankó kis mozi.", null);\r
item.appendMedia(media);\r
item.add();\r
\r
\r
@Test\r
public void testModify() {\r
- // Módosítás.\r
- Item item = itemManager.createItem("Film", "Hastánc oktató 2", "Ez egy full rekord teszt.", null);\r
- Media media = itemManager.createMedia("Adásanyag", "Média2", "Nagyon frankó kis mozi.", null);\r
+ // Módosítás.\r
+ Item item = itemManager.createItem("Film", "Hastánc oktató 2", "Ez egy full rekord teszt.", null);\r
+ Media media = itemManager.createMedia("Adásanyag", "média2", "Nagyon frankó kis mozi.", null);\r
item.appendMedia(media);\r
item.add();\r
\r
private static MetadataType mdt = null;\r
private static MetadataElement mde = null;\r
\r
- @Before \r
+ @Before\r
public void cleanup() {\r
HelperDAO.foreignKeysOff();\r
manager.truncate(Metadata.class);\r
manager.truncate(MetadataType.class);\r
HelperDAO.foreignKeysOn();\r
}\r
- \r
- @BeforeClass \r
+\r
+ @BeforeClass\r
public static void initializie() {\r
mdt = manager.createMetadataType("string100", BaseType.VARCHAR, "java.lang.String", "VARCHAR", 100);\r
mdt.add();\r
- mde = manager.createMetadataElement("Vágó", "A mûsor vágója", mdt);\r
+ mde = manager.createMetadataElement("Vágó", "A műsor vágója", mdt);\r
mde.add();\r
}\r
\r
@Test\r
public void testCreate() {\r
- //Létrehozás, paraméter ellenõrzés.\r
+ // Létrehozás, paraméter ellenőrzés.\r
Metadata metadata = manager.createMetadata(mde);\r
assertEquals(false, metadata.getIsDbIndex());\r
assertEquals(false, metadata.getIsDbUnique());\r
public class TestMetadataElement {\r
private static IItemManager itemManager = new ItemManager();\r
private static MetadataType mdt = null;\r
- \r
- @BeforeClass \r
+\r
+ @BeforeClass\r
public static void setUpConnection() {\r
itemManager.connect();\r
itemManager.truncate();\r
mdt.add();\r
}\r
\r
- @AfterClass \r
+ @AfterClass\r
public static void tearDownConnection() {\r
itemManager.disconnect();\r
}\r
\r
@Test\r
public void testCreate() {\r
- //Létrehozás, paraméter ellenõrzés.\r
- MetadataElement mde = itemManager.createMetadataElement("Ország", "A gyártó ország", mdt);\r
- assertEquals("Ország", mde.getName());\r
- assertEquals("A gyártó ország", mde.getDescription());\r
+ // Létrehozás, paraméter ellenőrzés.\r
+ MetadataElement mde = itemManager.createMetadataElement("Ország", "A gyártó ország", mdt);\r
+ assertEquals("Ország", mde.getName());\r
+ assertEquals("A gyártó ország", mde.getDescription());\r
assertEquals(mdt.getId(), mde.getMetadataTypeId());\r
mde.add();\r
}\r
\r
@Test\r
public void testModify() {\r
- //Módosítás.\r
- MetadataElement mde = itemManager.createMetadataElement("Ország2", "A gyártó ország2", mdt);\r
+ // Módosítás.\r
+ MetadataElement mde = itemManager.createMetadataElement("Ország2", "A gyártó ország2", mdt);\r
mde.add();\r
\r
mdt = itemManager.createMetadataType("string101", BaseType.VARCHAR, "java.lang.String", "VARCHAR", 101);\r
mdt.add();\r
- mde.setName("Város");\r
+ mde.setName("Város");\r
mde.setDescription("Comment");\r
mde.setMetadataType(mdt);\r
mde.modify();\r
- \r
+\r
MetadataElement mde1 = itemManager.getMetadataElement(mde.getId());\r
- assertEquals("Város", mde1.getName());\r
+ assertEquals("Város", mde1.getName());\r
assertEquals("Comment", mde1.getDescription());\r
assertEquals(mdt.getId(), mde1.getMetadataTypeId());\r
}\r
- \r
+\r
@Test(expected = NullPointerException.class)\r
public void testCreateWithNullMetadataType() {\r
- //Null paraméter.\r
- itemManager.createMetadataElement("Ország", "A gyártó ország", null);\r
+ // Null paraméter.\r
+ itemManager.createMetadataElement("Ország", "A gyártó ország", null);\r
}\r
\r
@Test(expected = NullPointerException.class)\r
public void testCreateWithNullName() {\r
- //Null paraméter.\r
- itemManager.createMetadataElement(null, "A gyártó ország", mdt);\r
+ // Null paraméter.\r
+ itemManager.createMetadataElement(null, "A gyártó ország", mdt);\r
}\r
- \r
+\r
@Test\r
public void testRemove() {\r
- //Törlés.\r
- MetadataElement mde = itemManager.createMetadataElement("Ország1", "A gyártó ország1", mdt);\r
+ // Törlés.\r
+ MetadataElement mde = itemManager.createMetadataElement("Ország1", "A gyártó ország1", mdt);\r
mde.add();\r
mde.remove();\r
}\r
\r
@Test\r
public void testCreate() {\r
- //Létrehozás, paraméter elenõrzés.\r
+ //Létrehozás, paraméter ellenőrzés.\r
MetadataType mdt = itemManager.createMetadataType("string100", BaseType.VARCHAR, "java.lang.String", "VARCHAR", 100);\r
assertEquals("string100", mdt.getName());\r
assertEquals(BaseType.VARCHAR, mdt.getDataType());\r
\r
@Test\r
public void testModify() {\r
- //Módosítás.\r
+ //Módosítás.\r
MetadataType mdt = itemManager.createMetadataType("string101", BaseType.VARCHAR, "java.lang.String", "VARCHAR", 101);\r
mdt.add();\r
\r
\r
@Test(expected = ItemManagerException.class)\r
public void testCreateWithInvalidConstructor1() {\r
- //Hibás konstruktor: a hossz nincs megadva.\r
+ //Hibás konstruktor: a hossz nincs megadva.\r
itemManager.createMetadataType("string100", BaseType.VARCHAR, "java.lang.String", "VARCHAR");\r
}\r
\r
@Test(expected = ItemManagerException.class)\r
public void testCreateWithInvalidConstructor2() {\r
- //Hibás konstruktor: a hossz meg van adva, pedig nem kell.\r
+ //Hibás konstruktor: a hossz meg van adva, pedig nem kell.\r
itemManager.createMetadataType("bigint", BaseType.BIGINT, "java.lang.Long", "BIGINT", 1);\r
}\r
\r
@Test(expected = NullPointerException.class)\r
public void testCreateWithNullName() {\r
- //Null paraméter.\r
+ //Null paraméter.\r
itemManager.createMetadataType(null, BaseType.VARCHAR, null, null, 100);\r
}\r
\r
@Test\r
public void testRemove() {\r
- //Törlés.\r
+ //Törlés.\r
MetadataType mdt = itemManager.createMetadataType("string90", BaseType.VARCHAR, "java.lang.String", "VARCHAR", 90);\r
mdt.add();\r
mdt.remove();\r
// itemManager.truncate();\r
// TestDB.createStructure();\r
// TestDB.createItemTypes();\r
-// item = itemManager.createItem("Film", "Ötödik elem", "Scifi", null);\r
-// media = itemManager.createMedia("Adásanyag", "Média1", "Nagyon frankó kis mozi.", null);\r
+// item = itemManager.createItem("Film", "Ötödik elem", "Scifi", null);\r
+// media = itemManager.createMedia("Adásanyag", "média1", "Nagyon frankó kis mozi.", null);\r
// item.appendMedia(media);\r
// item.add();\r
-// shot1 = itemManager.createShot("Leírás1", 1000L, 1001L, media);\r
+// shot1 = itemManager.createShot("Leírás1", 1000L, 1001L, media);\r
// shot1.add();\r
-// shot2 = itemManager.createShot("Leírás2", 1003L, 1004L, media);\r
+// shot2 = itemManager.createShot("Leírás2", 1003L, 1004L, media);\r
// shot2.add();\r
// }\r
\r
\r
// @Test\r
// public void testCreate() {\r
-// //Létrehozása, paraméter ellenõrzés.\r
-// Scene scene = manager.createScene("Vágólista");\r
-// assertEquals("Vágólista", scene.getName());\r
+// //létrehozása, paraméter Ellenőrzős.\r
+// Scene scene = manager.createScene("Vágólista");\r
+// assertEquals("Vágólista", scene.getName());\r
// SceneContent sceneContent = manager.createSceneContent(shot1);\r
// scene.appendSceneContent(sceneContent);\r
// scene.add();\r
\r
// @Test(expected=NullPointerException.class)\r
// public void testCreateWithNullName() {\r
-// //Null paraméter.\r
+// //Null paraméter.\r
// manager.createScene(null);\r
// }\r
//\r
// @Test(expected=IllegalStateException.class)\r
// public void testCreateWithoutContent() {\r
-// //Tartalom nélkül.\r
-// Scene scene = manager.createScene("Vágólista");\r
+// //Tartalom nélkül.\r
+// Scene scene = manager.createScene("Vágólista");\r
// scene.add();\r
// }\r
\r
// @Test\r
// public void testRemove() {\r
-// //Törlése a kapcsolódó tartalommal együtt.\r
-// Scene scene = manager.createScene("Vágólista1");\r
+// //Törlése a kapcsolódó tartalommal együtt.\r
+// Scene scene = manager.createScene("Vágólista1");\r
// SceneContent sceneContent = manager.createSceneContent(shot2);\r
// scene.appendSceneContent(sceneContent);\r
// scene.add();\r
TestDB.createStructure();\r
TestDB.createItemTypes();\r
\r
- item = itemManager.createItem("Film", "Ötödik elem", "Scifi", null);\r
- media = itemManager.createMedia("Adásanyag", "Média1", "Nagyon frankó kis mozi.", null);\r
+ item = itemManager.createItem("Film", "Ötödik elem", "Scifi", null);\r
+ media = itemManager.createMedia("Adásanyag", "média1", "Nagyon frankó kis mozi.", null);\r
item.appendMedia(media);\r
item.add();\r
- shot = itemManager.createShot("Leírás1", 1000L, 1001L, 1, null);\r
+ shot = itemManager.createShot("Leírás1", 1000L, 1001L, 1, null);\r
shot.add();\r
}\r
\r
\r
@Test(expected=NullPointerException.class)\r
public void testCreateWithNullShot() {\r
- //Null paraméter.\r
+ //Null paraméter.\r
itemManager.createSceneContent(null, 0, 0);\r
}\r
\r
@Test(expected=ItemManagerException.class)\r
public void testRemove() {\r
- //Törlés. Direktben nem hívható.\r
- Scene scene = itemManager.createScene("Vágólista1");\r
+ //Törlés. Direktben nem hívható.\r
+ Scene scene = itemManager.createScene("Vágólista1");\r
SceneContent sceneContent = itemManager.createSceneContent(shot, 1, 1);\r
scene.appendSceneContent(sceneContent);\r
scene.add();\r
public class TestShot {\r
private static IItemManager itemManager = new ItemManager();\r
private static Item item = null;\r
- private static Media media = null; \r
+ private static Media media = null;\r
\r
- @BeforeClass \r
+ @BeforeClass\r
public static void setUpConnection() {\r
itemManager.connect();\r
itemManager.truncate();\r
TestDB.createStructure();\r
TestDB.createItemTypes();\r
- item = itemManager.createItem("Film", "Ötödik elem", "Scifi", null);\r
- media = itemManager.createMedia("Adásanyag", "Média1", "Nagyon frankó kis mozi.", null);\r
+ item = itemManager.createItem("Film", "Ötödik elem", "Scifi", null);\r
+ media = itemManager.createMedia("Adásanyag", "média1", "Nagyon frankó kis mozi.", null);\r
item.appendMedia(media);\r
item.add();\r
}\r
\r
- @AfterClass \r
+ @AfterClass\r
public static void tearDownConnection() {\r
itemManager.disconnect();\r
}\r
\r
@Test\r
public void testCreate() {\r
- //Létrehozása, paraméter ellenõrzés.\r
- Shot shot = itemManager.createShot("Leírás", 1000L, 1001L, 1, new byte[1]);\r
- assertEquals("Leírás", shot.getDescription());\r
+ // Létrehozása, paraméter ellenőrzés.\r
+ Shot shot = itemManager.createShot("Leírás", 1000L, 1001L, 1, new byte[1]);\r
+ assertEquals("Leírás", shot.getDescription());\r
assertEquals(1000L, shot.getInPoint());\r
assertEquals(1001L, shot.getOutPoint());\r
shot.add();\r
}\r
\r
- @Test(expected=NullPointerException.class)\r
+ @Test(expected = NullPointerException.class)\r
public void testCreateWithNullDescription() {\r
- //Null paraméter.\r
+ // Null paraméter.\r
itemManager.createShot(null, 1000L, 1001L, 1, new byte[1]);\r
}\r
\r
- @Test(expected=NullPointerException.class)\r
+ @Test(expected = NullPointerException.class)\r
public void testCreateWithNullMedia() {\r
- //Null paraméter.\r
- itemManager.createShot("Leírás", 1000L, 1001L, 1, new byte[1]);\r
+ // Null paraméter.\r
+ itemManager.createShot("Leírás", 1000L, 1001L, 1, new byte[1]);\r
}\r
\r
- @Test(expected=IllegalArgumentException.class)\r
+ @Test(expected = IllegalArgumentException.class)\r
public void testCreateWithZeroOut() {\r
- //0 paraméter.\r
- itemManager.createShot("Leírás", 1000L, 0, 1, new byte[1]);\r
+ // 0 paraméter.\r
+ itemManager.createShot("Leírás", 1000L, 0, 1, new byte[1]);\r
}\r
\r
- @Test(expected=ItemManagerException.class)\r
+ @Test(expected = ItemManagerException.class)\r
public void testCreateWithWrongInOut() {\r
- //Inkonzisztens paraméter.\r
- itemManager.createShot("Leírás", 1001L, 1000L, 1, new byte[1]);\r
+ // Inkonzisztens paraméter.\r
+ itemManager.createShot("Leírás", 1001L, 1000L, 1, new byte[1]);\r
}\r
}\r
\r
@Test\r
public void testCreate() {\r
- // Paraméter ellenõrzés.\r
+ // Paraméter ellenőrzés.\r
StoreUri storeUri = itemManager.createStoreUri(RemoteStoreProtocol.HTTP, "elgekko-pc/lowres/");\r
assertEquals("http://elgekko-pc/lowres/", storeUri.toString());\r
assertEquals(true, storeUri.isStream());\r
\r
@Test(expected = NullPointerException.class)\r
public void testCreateWithNullUri() {\r
- // Null paraméter.\r
+ // Null paraméter.\r
itemManager.createStoreUri(null, null);\r
}\r
}\r
import java.util.EventListener;\r
\r
/**\r
- * Folyamat státusz változás eseményfigyelõ interface. \r
+ * Folyamat státusz változás eseményfigyelő interface.\r
*/\r
public interface IJobStatusChangedListener extends EventListener {\r
void statusChanged(JobStatusChangedEvent event);\r
import java.util.concurrent.atomic.AtomicLong;\r
\r
/**\r
- * Comagoló osztály a JobRuntime prioritás biztosítására.\r
- * lapesetben FIFO elemként mûködik, de az IncrementPriority\r
- * metódussal prioritást lehet biztosítani. \r
+ * Csomagoló osztály a JobRuntime prioritás biztosítására. Alapesetben FIFO\r
+ * elemként működik, de az IncrementPriority metódussal prioritást lehet\r
+ * biztosítani.\r
+ * \r
* @author vasary\r
*\r
* @param <E>\r
*/\r
-public class PriorityEntry<E extends Comparable<? super E>> implements\r
- Comparable<PriorityEntry<E>> {\r
+public class PriorityEntry<E extends Comparable<? super E>> implements Comparable<PriorityEntry<E>> {\r
\r
final static AtomicLong counter1 = new AtomicLong();\r
final long priority1;\r
if (other.priority2 != priority2)\r
res = (priority2 < other.priority2 ? 1 : -1);\r
else\r
- res = (priority1 < other.priority1 ? -1 : 1);\r
+ res = (priority1 < other.priority1 ? -1 : 1);\r
return res;\r
}\r
}\r
public enum JobAction {
/**
- * Le�ll�t�s.
+ * Leállítás.
*/
CANCEL(0x0001),
/**
- * L�p�s futtat�s.
+ * Lépés futtatás.
*/
EXECUTE(0x0002),
/**
- * L�p�s k�sz: t�nyleges befejez�s, vagy a megszak�t�s/felf�ggeszt�s k�relem v�grehajt�sa ut�n.
+ * Lépés kész: tényleges befejezés, vagy a megszakítás/felfüggesztés kérelem
+ * végrehajtása után.
*/
DONE(0x0003),
/**
- * Folytat�s.
+ * Folytatás.
*/
RESUME(0x0004),
/**
- * Folyamat futtat�s.
+ * Folyamat futtatás.
*/
RUN(0x0005),
/**
- * Felf�ggeszt�s.
+ * Felfüggesztés.
*/
SUSPEND(0x0006),
/**
- * Felhaszn�l�i �zenet.
+ * felhasználói üzenet.
*/
MESSAGE(0x0007),
/**
- * V�lasz felhaszn�l�i �zenetre.
+ * válasz felhasználói üzenetre.
*/
REPLY(0x0008),
/**
- * K�sz.
+ * Kész.
*/
FINISH(0x0009), RESTART(0x000A), SKIP(0x000B);
package user.jobengine.server.ast;\r
\r
/**\r
- * Felhasználói üzenet küldése parancs.\r
+ * felhasználói üzenet küldése parancs.\r
*/\r
public class SendUserMessageCommand extends Command {\r
\r
private ParameterSequence outputParameterSequence = null;\r
private String catalogName;\r
private int messageNumber;\r
- \r
+\r
public SendUserMessageCommand() {\r
}\r
\r
/**\r
- * Példányosítás a paraméter gyûjtemények megadásával.\r
+ * Példányosítás a paraméter gyűjtemények megadásával.\r
* \r
- * @param ips\r
- * Bemeneti paraméter gyûjtemény.\r
- * @param ops\r
- * Kimeneti paraméter gyûjtemény.\r
+ * @param ips Bemeneti paraméter gyűjtemény.\r
+ * @param ops Kimeneti paraméter gyűjtemény.\r
*/\r
public SendUserMessageCommand(ParameterSequence ips, ParameterSequence ops, String catalogName, int messageNumber) {\r
this.inputParameterSequence = ips;\r
}\r
\r
/**\r
- * Bemeneti paraméter gyûjtemény lekérdezése.\r
+ * Bemeneti paraméter gyűjtemény lekérdezése.\r
* \r
- * @return paraméter gyûjtemény.\r
+ * @return paraméter gyűjtemény.\r
*/\r
public ParameterSequence getInputParameterSequence() {\r
return inputParameterSequence;\r
}\r
\r
/**\r
- * Kimeneti paraméter gyûjtemény lekérdezése.\r
+ * Kimeneti paraméter gyűjtemény lekérdezése.\r
* \r
- * @return Kimeneti paraméter gyûjtemény.\r
+ * @return Kimeneti paraméter gyűjtemény.\r
*/\r
public ParameterSequence getOutputParameterSequence() {\r
return outputParameterSequence;\r
}\r
\r
/**\r
- * Bemeneti paraméter gyûjtemény beállítása.\r
+ * Bemeneti paraméter gyűjtemény beállítása.\r
* \r
- * @param parameterSequence\r
- * Bementi paraméter gyûjtemény.\r
+ * @param parameterSequence Bemeneti paraméter gyűjtemény.\r
*/\r
public void setInputParameterSequence(ParameterSequence parameterSequence) {\r
this.inputParameterSequence = parameterSequence;\r
}\r
\r
/**\r
- * Kimeneti paraméter gyûjtemény beállítása.\r
+ * Kimeneti paraméter gyűjtemény beállítása.\r
* \r
- * @param outputParameterSequence\r
- * Kimeneti paraméter gyûjtemény.\r
+ * @param outputParameterSequence Kimeneti paraméter gyűjtemény.\r
*/\r
- public void setOutputParameterSequence(\r
- ParameterSequence outputParameterSequence) {\r
+ public void setOutputParameterSequence(ParameterSequence outputParameterSequence) {\r
this.outputParameterSequence = outputParameterSequence;\r
}\r
\r
import user.jobengine.server.IJobRuntime;
/**
- * Folyamat paraméter ellenõrzése utasítás.
+ * Folyamat paraméter ellenőrzése utasítás.
*/
public class CheckParameterInstruction extends Instruction {
@Override
import user.jobengine.server.IJobRuntime;
/**
- * Felhasználói üzenet küldése utasítás.
+ * felhasználói üzenet küldése utasítás.
*/
public class SendMessageToUserInstruction extends Instruction {
@Override
import user.jobengine.server.IJobEngine;\r
\r
/**\r
- * Folyamat fel�breszt�se rendszer�zenet.\r
+ * Folyamat felébresztése rendszerüzenet.\r
*/\r
public class CancelRequest extends JobMessage {\r
\r
import user.jobengine.server.IJobEngine;
/**
- * Rendszer�zenet interface.
+ * Rendszerüzenet interface.
*/
public interface IJobMessage {
* @param obj Vizsgálandó üzenet, mely az aktuális példánnyal kerül
* összehasonlításra.
* @return Igen - két üzenet megegyezik, ha típusa és paraméterei megegyeznek,
- * Nem - tÃpus, vagy paraméter értük különbség esetén.
+ * Nem - tÃpus, vagy paraméter érték különbség esetén.
*/
@Override
public boolean equals(Object obj);
import user.jobengine.server.IJobEngine;
/**
- * Rendszerüzenet õsosztály.
+ * Rendszerüzenet ősosztály.
*/
public abstract class JobMessage implements IJobMessage {
private final long jobId;
/**
- * Példányosítás az egyedi aonosító megadásával.
+ * Példányosítás az egyedi azonosító megadásával.
*
* @param jobId
*/
boolean result = false;
result = (obj == null) ? false : this.getClass().equals(obj.getClass());
if (result)
- result = (this.getJobId() == ((JobMessage) obj).getJobId()) ? true
- : false;
+ result = (this.getJobId() == ((JobMessage) obj).getJobId()) ? true : false;
return result;
}
import user.jobengine.server.IJobEngine;
/**
- * Folyamat l�p�s k�sz rendszer�zenet.
+ * Folyamat lépés kész rendszerüzenet.
*/
public class JobStepCompletedMessage extends JobMessage {
private final Object[] outputs;
/**
- * Peldanyositas az egyedi azonositoval es a lepes visszataresi ertekeivel
+ * Példányosítás az egyedi azonosítóval és a lépés visszatérési értékeivel
*
* @param jobId
* @param outputs
import user.jobengine.server.IJobEngine;\r
\r
/**\r
- * Folyamat felébresztése rendszerüzenet.\r
+ * Folyamat felébresztése rendszerüzenet.\r
*/\r
public class RestartRequest extends JobMessage {\r
\r
import user.jobengine.server.IJobEngine;\r
\r
/**\r
- * Folyamat felébresztése rendszerüzenet.\r
+ * Folyamat felébresztése rendszerüzenet.\r
*/\r
public class ResumeRequest extends JobMessage {\r
\r
import user.jobengine.server.IJobEngine;\r
\r
/**\r
- * Folyamat felfüggesztés kérelem rendszerüzenet.\r
+ * Folyamat felfüggesztés kérelem rendszerüzenet.\r
*/\r
public class SuspendRequest extends JobMessage {\r
\r
import user.jobengine.server.IJobEngine;\r
\r
/**\r
- * Felhasználói válasz rendszerüzenet.\r
+ * Felhasználói válasz rendszerüzenet.\r
*/\r
public class UserReplyMessage extends JobMessage {\r
-//TODO jobid helyett messageid alapú\r
+//TODO jobid helyett messageid alapú\r
private Object reply = null;\r
private long messageId = 0;\r
\r
}
@Test
- // els� jobstep el�tt
+ // első jobstep előtt
public void testWait_Executor_Stage1() throws Exception {
// Fixture
final JobStatus status = JobStatus.WAIT_EXECUTOR;
}
@Test
- // els� jobstep el�tt
+ // első jobstep előtt
public void testSuspend_Stage1() throws Exception {
// Fixture
final JobStatus status = JobStatus.SUSPENDED;
}
@Test
- // els� jobstep
+ // első jobstep
public void testExecuting_Stage1() throws Exception {
// Fixture
final JobStatus status = JobStatus.EXECUTING;
}
@Test
- // els� jobstep ut�n
+ // első jobstep után
public void testRunnable_Stage1() throws Exception {
// Fixture
final JobStatus status = JobStatus.RUNNABLE;
}
@Test
- // els� jobstep ut�n, user v�laszra v�rva
+ // első jobstep után, user válaszra várva
public void testWait_UserMessage() throws Exception {
// Fixture
final JobStatus status = JobStatus.WAIT_USERMESSAGE;
}
@Test
- // user v�lasz ut�n, m�sodik jobstep el�tt
+ // user válasz után, második jobstep előtt
public void testRunnable_Stage2() throws Exception {
// Fixture
final JobStatus status = JobStatus.RUNNABLE;
}
@Test
- // m�sodik jobstep el�tt
+ // második jobstep előtt
public void testWait_Executor_Stage2() throws Exception {
// Fixture
final JobStatus status = JobStatus.WAIT_EXECUTOR;
}
@Test
- // m�sodik jobstep
+ // második jobstep
public void testExecuting_Stage2() throws Exception {
// Fixture
final JobStatus status = JobStatus.EXECUTING;
}
@Test
- // m�sodik jobstep k�zben suspend
+ // második jobstep közben suspend
public void testSuspend_Stage2() throws Exception {
// Fixture
parameters.put(STEPRUN_IN_SECONDS, 10);
}
@Test
- // m�sodik jobstep k�zben suspend/resume
+ // második jobstep közben suspend/resume
public void testResume_Stage2() throws Exception {
// Fixture
parameters.put(STEPRUN_IN_SECONDS, 1);
}
@Test
- // els� jobstep ut�n
+ // első jobstep után
public void testFinished() throws Exception {
// Fixture
final JobStatus status = JobStatus.FINISHED;
import java.util.concurrent.Semaphore;\r
\r
/**\r
- * Szál számláló. \r
- * A waitFinish csak akkor tér vissza, amikor a konstruktorban átadott számú increment hívás megtörtént. \r
+ * Szál számláló. A waitFinish csak akkor tér vissza, amikor a konstruktorban\r
+ * átadott számú increment hívás megtörtént.\r
*/\r
public class ThreadCounter {\r
private Semaphore semaphore = null;\r
private final int permits;\r
- \r
+\r
public ThreadCounter() {\r
this.permits = 1;\r
init();\r
import java.util.concurrent.locks.ReentrantLock;\r
\r
/**\r
- * Szál szinkronizáló. \r
- * A waitSuspend csak akkor tér vissza, amikor egy suspend hívás megtörtént. \r
- * A suspend-et hívó szál ezután egy resume hívás esetén fog folytatódni.\r
+ * Szál szinkronizáló. A waitSuspend csak akkor tér vissza, amikor egy suspend\r
+ * hívás megtörtént. A suspend-et hívó szál ezután egy resume hívás esetén fog\r
+ * folytatódni.\r
*/\r
public class ThreadSynchronizer {\r
private final ReentrantLock lock;\r
- private final Condition suspendCondition; \r
- private final Condition resumeCondition; \r
- \r
+ private final Condition suspendCondition;\r
+ private final Condition resumeCondition;\r
+\r
public ThreadSynchronizer() {\r
lock = new ReentrantLock();\r
suspendCondition = lock.newCondition();\r
}\r
\r
/**\r
- *Call from Thread2 to suspend this thread, and awake Thread1\r
+ * Call from Thread2 to suspend this thread, and awake Thread1\r
*/\r
public void suspend() {\r
try {\r
lock.lock();\r
suspendCondition.signal();\r
resumeCondition.await();\r
- } catch (InterruptedException e) { \r
- \r
+ } catch (InterruptedException e) {\r
+\r
} finally {\r
lock.unlock();\r
}\r
}\r
\r
/**\r
- *Call from Thread1, before suspend() \r
+ * Call from Thread1, before suspend()\r
*/\r
public void waitSuspend() {\r
try {\r
lock.lock();\r
suspendCondition.await();\r
- } catch (InterruptedException e) { \r
- \r
+ } catch (InterruptedException e) {\r
+\r
} finally {\r
lock.unlock();\r
}\r
}\r
\r
/**\r
- *Call from Thread1, cleanup \r
+ * Call from Thread1, cleanup\r
*/\r
public void resume() {\r
lock.lock();\r
//\r
// //Specify the LDAP search filter\r
// String searchFilter = "(&(objectClass=person)(objectCategory=Person)(CN=" +\r
- // name + "))"; //p�ld�k:\r
+ // name + "))"; //példák:\r
// "(&(objectClass=person)(objectCategory=Person)(CN=y011216s))";\r
// "(&(objectClass=group)(objectCategory=Group)(CN=Users))";\r
//\r
https://git.useribm.hu / mediacube.git / commitdiff