diff --git a/process/ImporterMappingFunctions_lib/process.js b/process/ImporterMappingFunctions_lib/process.js
index 5500aa69c906c58d13b2580312cca6114070a43d..f1e01b6faf78079bf497745c1ae3b8d1e4597ea9 100644
--- a/process/ImporterMappingFunctions_lib/process.js
+++ b/process/ImporterMappingFunctions_lib/process.js
@@ -289,7 +289,7 @@ function iComm(pObject) {
     var sql = "select " + this.getColumnCase("communicationid") + " from " + this.getTableCase("communication")
         +" where " + this.getColumnCase("contact_id") + " = ? and " + this.getColumnCase("medium_id") + " = ? and "
         + this.getColumnCase("standard") + " = ? and " + this.getColumnCase("addr") + " = ?"
-    var id = db.cell([sql, [[contact, SQLTYPES.CHAR], [medium, SQLTYPES.INTEGER], 
+    var id = db.cell([sql, [[contact, SQLTYPES.CHAR], [medium, SQLTYPES.CHAR], //TODO: define types dynamically and not hardcoded
             [standard, SQLTYPES.SMALLINT], [address, SQLTYPES.VARCHAR]]], this.Config.AliasTo);
     if (id == "" || id == null) {
         var columns = [this.getColumnCase("communicationid"), this.getColumnCase("addr"),