Les requêtes SQL

Si votre source n'est pas un Database Reader et que vous souhaitez faire un requête SQL dans le transformer de la partie source afin de vous en servir comme flux d'entrée, en modifiant la variable msg disponible nativement,

Fonction sqlQueryToXML

La fonction sqlQueryToXML execute la requête SQL sur la connexion donnée en paramètre, et retourne un contenu de type XML compatible avec la variable msg

Ajouter cette fonction dans le Code Template dans la ressource de votre choix.

/**
	Executes a SQL query and transforms the result set into an Mirth XML Datatype.
	
	This function iterates through all rows and columns of the provided query results. Date and
	Timestamp columns are automatically converted to ISO 8601 strings with timezone offset (e.g.,
	yyyy-MM-dd'T'HH:mm:ss.SSSXXX).

	@param {com.mirth.connect.server.util.DatabaseConnection} dbConn - The Mirth database connection
		object.
	@param {string} sqlQuery - The SQL SELECT statement to execute.
	@return {XML|null} An E4X XML object containing the results, or null if an error occurs.
*/
function sqlQueryToXML(dbConn, sqlQuery) {
	res = null;
	if (dbConn == null) {
	    logger.error("Error sqlQueryToXML : Unable to connect to the database.");
	}
	
	try {
		var results = dbConn.executeCachedQuery(sqlQuery);
		var metaData = results.getMetaData();
		var colCount = metaData.getColumnCount();

		var xmlOutput = new XML('<results></results>');

		while (results.next()) {
			var row = new XML('<result></result>');
			
			for (var i = 1; i <= colCount; i++) {
				var colName = metaData.getColumnLabel(i); // Utilise l'alias SQL si présent au lieu du nom de colonne
				var colType = metaData.getColumnTypeName(i).toUpperCase();
				var value = "";

				if (colType.indexOf("DATE") !== -1 || colType.indexOf("TIMESTAMP") !== -1) {
					var javaDate = results.getTimestamp(i);
					if (javaDate != null) {
						// Formater la date en String au format ISO avec le timezone
						value = DateUtil.formatDate("yyyy-MM-dd'T'HH:mm:ss.SSSXXX", javaDate);
					}
				} else {
					value = (results.getString(i) || "").trim();
				}

				row[colName] = value;
			}
			xmlOutput.appendChild(row);
		}

		res = xmlOutput;

	} catch (e) {
		logger.error("Error sqlQueryToXML : " + e.toString());
	}	
	
	return res;
}

Pour utiliser cette requête, aller dans l'onglet Source , puis dans Edit transformer , et faite Add New Step , choisisser le type de Step Javascript, et copier coller le code ci dessous (changer la requête SQL bien sûr).

var query = "SELECT nom, prenom, date_naissance, ipp, episode FROM patient";

msg = sqlQueryToXML(dbConn, query);

Cela donne l'équivalent du Inbound Message Template suivant:

<results>
  <result>
    <nom>Doe</nom>
    <prenom>John</prenom>
    <date_naissance>1970-01-01T01:01:00.001</date_naissance>
    <ipp>PAT001</ipp>
    <episode>SEJ001</episode>
  </result>
</results>

TIP

La balise <results> indique que le résultat peut retourner plusieurs lignes de données si vous souhaitez recupérer qu'un seule ligne, vous pouvez adapter avec le code ci-dessous

msg = sqlQueryToXML(dbConn, query);
if (msg) {
    msg = msg['result'][0];
}

Fonction sqlQueryAppendXML

Cette fonction va vous permettre d'exécuter une requête SQL et de retourner un ensemble de lignes en personnalisant la racine XML.

/**
	Executes a SQL query and transforms the result set into an Mirth XML Datatype.
	
	This function iterates through all rows and columns of the provided query results. Date and
	Timestamp columns are automatically converted to ISO 8601 strings with timezone offset (e.g.,
	yyyy-MM-dd'T'HH:mm:ss.SSSXXX).

	@param {com.mirth.connect.server.util.DatabaseConnection} dbConn - The Mirth database connection
		object.
	@param {string} sqlQuery - The SQL SELECT statement to execute.
	@param {string} elGroup - XML element to repeat per line
	@return {XML|null} An E4X XML object containing the results, or null if an error occurs.
*/
function sqlQueryAppendXML(dbConn, sqlQuery, elGroup) {
	res = null;
	var count = 0;
	if (dbConn == null) {
	    logger.error("Error sqlQueryToXML : Unable to connect to the database.");
	}
	elGroup = (typeof elGroup !== 'undefined') ? elGroup : "result";
	
	try {
		var results = dbConn.executeCachedQuery(sqlQuery);
		var metaData = results.getMetaData();
		var colCount = metaData.getColumnCount();

		var xmlOutput = new XML('<root></root>');

		while (results.next()) {
			var row = new XML('<' + elGroup +'></' + elGroup +'>');
			count += 1;
			for (var i = 1; i <= colCount; i++) {
				var colName = metaData.getColumnLabel(i); 
				var colType = metaData.getColumnTypeName(i).toUpperCase();
				var value = "";

				if (colType.indexOf("DATE") !== -1 || colType.indexOf("TIMESTAMP") !== -1) {
					var javaDate = results.getTimestamp(i);
					if (javaDate != null) {
						// Formater la date en String au format ISO avec le timezone
						value = DateUtil.formatDate("yyyy-MM-dd'T'HH:mm:ss.SSSXXX", javaDate);
					}
				} else {
					value = (results.getString(i) || "").trim();
				}

				row[colName] = value;
			}
			xmlOutput.appendChild(row);
		}

		res = xmlOutput;

	} catch (e) {
		logger.error("Error sqlQueryToXML : " + e.toString());
	}
	// on retourne l'élément parent vide lorsqu'il n'y a pas de ligne retournée
	if (res === null || count === 0) {
		return new XML('<' + elGroup +'></' + elGroup +'>');;
	}
	return res.children();
}

Imaginons que la variable msg est alimenté via une précédente requête, et que l'on souhaite y ajouter les détails des séjours par exemple, nous allons pouvoir ajouter le code suivant

query = "SELECT episode, service, chambre, lit FROM sejour WHERE ipp = " + msg['ipp'].toString();

var res = sqlQueryAppendXML(dbConn, query, 'sejour');
msg.appendChild(res);

TIP

Les exemples montrent l'utilisation direct de la variable msg, mais je recommenderais d'utiliser une variable temporaire pour faire toute des manipulations (ex: tmpMsg), en ensuite à la fin de surcharger msg

var tmpMsg;
var res;
...
tmpMsg = sqlQueryToXML(dbConn, query);
if (tmpMsg) {
    tmpMsg = tmpMsg['result'][0];
}
...
res = sqlQueryAppendXML(dbConn, query, 'sejour');
tmpMsg.appendChild(res);

msg = tmpMsg;