1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
package org.openslx.satellitedaemon.db;
import java.util.List;
/**
* Represents an image in the satellite's database (mostly from
* m_VLData_imageInfo)
*/
public class DbImage
{
public final String guid;
public final String name;
public final int rid;
public final String path;
public final String creator;
public final long fileSize;
public final long changeTime;
public final long createTime;
public final int contentOperatingSystem;
public final boolean isValid;
public final boolean isDeleted;
public enum Status
{
only_local, to_be_published, being_published, successfully_published, to_be_decentralized, being_decentralized, successfully_decentralized
}
public DbImage(
String guid, String name, Integer rid, String path, String creator,
Long fileSize, Long createTime, Long changeTime, Integer contentOperatingSystem,
Boolean isValid, Boolean isDeleted)
{
if ( rid == null )
rid = -1;
if ( fileSize == null )
fileSize = (long) -1;
this.guid = guid;
this.name = name;
this.rid = rid;
this.path = path;
this.creator = creator;
this.fileSize = fileSize;
this.createTime = createTime;
this.changeTime = changeTime;
this.contentOperatingSystem = contentOperatingSystem;
this.isValid = isValid;
this.isDeleted = isDeleted;
}
/**
* Returns a list of all images on this satellite that should be
* uploaded to the central server.
*
* @return list of images that are marked for upload, where the upload
* was either not started yet, or is incomplete
*/
public static List<DbImage> getAllMarkedForUpload()
{
return MySQL.findAll( DbImage.class, "SELECT image.GUID_imageID, image.image_name, image.imageVersion, image.image_path," +
" user.loginName AS userID, image.image_filesize, UNIX_TIMESTAMP(image.rec_create_time), UNIX_TIMESTAMP(image.rec_change_time)," +
" image.content_operatingSystem, image.status_isValid, image.status_isDeleted" +
" FROM m_VLData_imageInfo image" +
" INNER JOIN m_user user ON (image.image_owner = user.userID)" +
" INNER JOIN m_institution institution ON (institution.institutionID = user.institution)" +
" WHERE image_syncMode = 'to_be_published'" );
}
/**
* Returns a list of all images on this satellite that should be
* downloaded from the central server.
*
* @return list of images that are marked for download, where the download
* was either not started yet, or is incomplete
*/
public static List<DbImage> getAllMarkedForDownload()
{
return MySQL.findAll( DbImage.class, "SELECT image.GUID_imageID, image.image_name, image.imageVersion, image.image_path," +
" user.loginName AS userID, image.image_filesize, UNIX_TIMESTAMP(image.rec_create_time), UNIX_TIMESTAMP(image.rec_change_time)," +
" image.content_operatingSystem, image.status_isValid, image.status_isDeleted" +
" FROM m_VLData_imageInfo image" +
" INNER JOIN m_user user ON (image.image_owner = user.userID)" +
" INNER JOIN m_institution institution ON (institution.institutionID = user.institution)" +
" WHERE image_syncMode = 'to_be_decentralized'" );
}
/**
* Method for updating the status of an Image in the db. For example after a succesfull upload.
*
* @param status : possible statuses are : "only_local, to_be_published, being_published,
* successfully_published, to_be_decentralized, being_decentralized, successfully_decentralized"
*/
public void updateStatus( Status status )
{
MySQL.update( "UPDATE m_VLData_imageInfo SET image_syncMode=? WHERE GUID_imageID=?", status.toString(), this.guid);
}
/**
* Method for updating the size of an Image in the db.
*
* @param filesize is the size of the file
*/
public void updateFilesize( long filesize )
{
MySQL.update( "UPDATE m_VLData_imageInfo SET image_filesize=? WHERE GUID_imageID=?", filesize, this.guid );
}
}
|
