Mercurial > hg > ltpda
view m-toolbox/classes/+utils/@mysql/connect.m @ 51:9d5c88356247 database-connection-manager
Make unit tests database connection parameters configurable
author | Daniele Nicolodi <nicolodi@science.unitn.it> |
---|---|
date | Wed, 07 Dec 2011 17:24:37 +0100 |
parents | 977eb37f31cb |
children |
line wrap: on
line source
function conn = connect(hostname, database, username, password) % CONNECT Opens a connection to the given database. % % CALL: % % conn = utils.mysql.connect(hostname, database, username, password) % % This function returns a Java java.sql.Connection object. % % On authetication error an utils:mysql:connect:AccessDenied exception % is thrown. On other errors an utils:mysql:connect:ConnectionError % exception is thrown. % informative message import utils.const.* utils.helper.msg(msg.PROC1, 'connection to mysql://%s/%s username=%s', hostname, database, username); % connection credential uri = sprintf('jdbc:mysql://%s/%s', hostname, database); db = javaObject('com.mysql.jdbc.Driver'); pl = javaObject('java.util.Properties'); pl.setProperty(db.USER_PROPERTY_KEY, username); pl.setProperty(db.PASSWORD_PROPERTY_KEY, password); try % connect conn = db.connect(uri, pl); catch ex % exceptions handling in matlab sucks if strcmp(ex.identifier, 'MATLAB:Java:GenericException') % extract exception class and message lines = regexp(ex.message, '\n', 'split'); p = strfind(lines{2}, ': '); id = lines{2}(1:p(1)-1); message = lines{2}(p(1)+2:end); % some notable cases switch id case 'java.sql.SQLException' throwAsCaller(MException('utils:mysql:connect:AccessDenied', '### access denied: %s', message)) case 'com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException' throwAsCaller(MException('utils:mysql:connect:ConnectionError', '### connection error: %s. check database name', message)) case 'com.mysql.jdbc.exceptions.jdbc4.CommunicationsException' throwAsCaller(MException('utils:mysql:connect:ConnectionError', '### connection error: %s. check hostname', message)) end % user friendlier exception throwAsCaller(MException('utils:mysql:connect:ConnectionError', '### connection error: %s: %s', id, message)) end rethrow(ex); end end