diff --git a/src/java/azkaban/database/DataSourceUtils.java b/src/java/azkaban/database/DataSourceUtils.java
index 7a7ed19..a18f1cf 100644
--- a/src/java/azkaban/database/DataSourceUtils.java
+++ b/src/java/azkaban/database/DataSourceUtils.java
@@ -124,7 +124,9 @@ public class DataSourceUtils {
private MySQLBasicDataSource(String host, int port, String dbName, String user, String password, int numConnections) {
super();
- String url = "jdbc:mysql://" + (host + ":" + port + "/" + dbName + "?useUnicode=yes&characterEncoding=UTF-8");
+ String url = "jdbc:mysql://" + (host + ":" + port + "/" + dbName);
+ addConnectionProperty("useUnicode","yes");
+ addConnectionProperty("characterEncoding","UTF-8");
setDriverClassName("com.mysql.jdbc.Driver");
setUsername(user);
setPassword(password);