Mercurial > hg > ltpda
diff m-toolbox/classes/+utils/@repository/insertObjMetadata.m @ 13:e05504b18072 database-connection-manager
Move more functions to utils.repository
author | Daniele Nicolodi <nicolodi@science.unitn.it> |
---|---|
date | Mon, 05 Dec 2011 16:20:06 +0100 |
parents | m-toolbox/classes/+utils/@jmysql/insertObjMetadata.m@f0afece42f48 |
children |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/m-toolbox/classes/+utils/@repository/insertObjMetadata.m Mon Dec 05 16:20:06 2011 +0100 @@ -0,0 +1,124 @@ +function insertObjMetadata(conn, obj, objid) +% an utility to insert entries for various object metadata in the +% corresponding tables. differs from insertObjMetadataV1() by +% the use of the new v3.0 database structure +% +% MUST BE KEPT IN SYNC WITH updateObjMetadata() +% +% conn - Java database connection object +% obj - object +% objid - unique ID of the object in the database +% +% VERSION: $Id: insertObjMetadata.m,v 1.9 2011/11/09 18:45:14 mauro Exp $ +% + + import utils.const.* + + if nargin < 3 + error('### incorrect usage'); + end + if ~isjava(conn) + error('### incorrect usage'); + end + + % class of object + cl = class(obj); + utils.helper.msg(msg.PROC2, 'making meta data entry for %s object', cl); + + switch cl + case 'ao' + + % call recursively to insert the data object info + utils.repository.insertObjMetadata(conn, obj.data, objid); + + % insert the AO info + stmt = conn.prepareStatement(... + 'INSERT INTO ao (obj_id, data_type, description) VALUES (?, ?, ?)'); + stmt.setObject(1, objid); + stmt.setObject(2, java.lang.String(class(obj.data))); + + desc = obj.description; + if length(desc)>65535 + warning('Object description length exceeded. Truncating to 65535 characters'); + desc = desc(1:65535); + end + stmt.setObject(3, java.lang.String(desc)); + stmt.execute(); + stmt.close(); + + case 'cdata' + + stmt = conn.prepareStatement(... + 'INSERT INTO cdata (obj_id, yunits) VALUES (?, ?)'); + stmt.setObject(1, objid); + stmt.setObject(2, java.lang.String(char(obj.yunits))); + stmt.execute(); + stmt.close(); + + case 'fsdata' + + % possible bad entries + fs = obj.fs; + if ~isfinite(fs) + fs = []; + end + + stmt = conn.prepareStatement(... + 'INSERT INTO fsdata (obj_id, xunits, yunits, fs) VALUES (?, ?, ?, ?)'); + stmt.setObject(1, objid); + stmt.setObject(2, java.lang.String(char(obj.xunits))); + stmt.setObject(3, java.lang.String(char(obj.yunits))); + stmt.setObject(4, fs); + stmt.execute(); + stmt.close(); + + case 'tsdata' + + stmt = conn.prepareStatement(... + 'INSERT INTO tsdata (obj_id, xunits, yunits, fs, t0, nsecs, toffset) VALUES (?, ?, ?, ?, ?, ?, ?)'); + stmt.setObject(1, objid); + stmt.setObject(2, java.lang.String(char(obj.xunits))); + stmt.setObject(3, java.lang.String(char(obj.yunits))); + stmt.setObject(4, obj.fs); + stmt.setObject(5, java.lang.String(format(obj.t0 + obj.toffset/1000, 'yyyy-mm-dd HH:MM:SS', 'UTC'))); + stmt.setObject(6, obj.nsecs); + stmt.setObject(7, obj.toffset); + stmt.execute(); + stmt.close(); + + case 'xydata' + + stmt = conn.prepareStatement(... + 'INSERT INTO xydata (obj_id, xunits, yunits) VALUES (?, ?, ?)'); + stmt.setObject(1, objid); + stmt.setObject(2, java.lang.String(char(obj.xunits))); + stmt.setObject(3, java.lang.String(char(obj.yunits))); + stmt.execute(); + stmt.close(); + + case 'mfir' + + stmt = conn.prepareStatement(... + 'INSERT INTO mfir (obj_id, in_file, fs) VALUES (?, ?, ?)'); + stmt.setObject(1, objid); + stmt.setObject(2, java.lang.String(obj.infile)); + stmt.setObject(3, obj.fs); + stmt.execute(); + stmt.close(); + + case 'miir' + + stmt = conn.prepareStatement(... + 'INSERT INTO miir (obj_id, in_file, fs) VALUES (?, ?, ?)'); + stmt.setObject(1, objid); + stmt.setObject(2, java.lang.String(obj.infile)); + stmt.setObject(3, obj.fs); + stmt.execute(); + stmt.close(); + + otherwise + utils.helper.msg(msg.PROC2, 'no meta data table for %s object', cl); + + end + +end