Skip to content

Commit

Permalink
update samples
Browse files Browse the repository at this point in the history
  • Loading branch information
@marianzalewski
marianzalewski committed Dec 6, 2021
1 parent 06ed803 commit d5d9188
Show file tree
Hide file tree
Showing 3 changed files with 42 additions and 16 deletions.
3 changes: 2 additions & 1 deletion Java/Connecting to Databases/.classpath
View file
Original file line number Diff line number Diff line change
Expand Up @@ -8,10 +8,11 @@
</classpathentry>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.7">
<attributes>
<attribute name="module" value="true"/>
<attribute name="maven.pomderived" value="true"/>
</attributes>
</classpathentry>
<classpathentry kind="con" path="org.eclipse.jst.server.core.container/org.eclipse.jst.server.tomcat.runtimeTarget/Apache Tomcat v8.0">
<classpathentry kind="con" path="org.eclipse.jst.server.core.container/org.eclipse.jst.server.tomcat.runtimeTarget/Apache Tomcat v8.5">
<attributes>
<attribute name="owner.project.facets" value="jst.web"/>
</attributes>
Expand Down
2 changes: 1 addition & 1 deletion Java/Connecting to Databases/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.33</version>
<version>5.1.17</version>
</dependency>
</dependencies>
</project>
53 changes: 39 additions & 14 deletions Java/Connecting to Databases/src/com/stimulsoft/js/adapter/JSDataAdapter.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,18 +20,19 @@
import com.stimulsoft.base.json.JSONException;
import com.stimulsoft.base.json.JSONObject;
import com.stimulsoft.base.system.StiSqlTypes;
import com.stimulsoft.lib.base64.StiBase64DecoderUtil;

/**
* Copyright Stimulsoft
*/
public class JSDataAdapter {

private static final List<String> USERS_KEYS = Arrays.asList(
new String[] { "jdbc.username", "username", "uid", "user", "user id", "userId", "connection.username" });
new String[] { "jdbc.username", "username", "uid", "user", "user id", "userid", "connection.username" });
private static final List<String> PASSWORD_KEYS = Arrays.asList(new String[] { "jdbc.password", "pwd", "password", "connection.password" });
private static final List<String> HOST_KEY = Arrays.asList(new String[] { "host", "server", "location" });
private static final List<String> PORT_KEY = Arrays.asList(new String[] { "port" });
private static final List<String> DATABASE_KEY = Arrays.asList(new String[] { "database", "database name", "databaseName", "data source" });
private static final List<String> DATABASE_KEY = Arrays.asList(new String[] { "database", "database name", "databasename", "data source" });
protected static final List<String> URL_KEYS = Arrays.asList(new String[] { "jdbc.url", "connectionurl", "url", "connection.url" });

private static String onError(Exception e) {
Expand All @@ -56,20 +57,25 @@ private static String connect(JSONObject command) throws SQLException {
info.setProperty("characterEncoding", "UTF-8");
}
info.putAll(params);
String url = getUrl(params);

if ("MySQL".equals(dbName)) {
Class.forName("com.mysql.jdbc.Driver");
// connectionURL = String.format("jdbc:mysql://%s:%s/%s", getHost(params),
// getPort(params), getDatabase(params));
if (url == null) {
url = String.format("jdbc:mysql://%s:%s/%s", getHost(params), getPort(params, "3306"), getDatabase(params));
}
} else if ("MS SQL".equals(dbName)) {
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
// connectionURL = String.format("jdbc:sqlserver://%s:%s;databaseName=%s",
// getHost(params), getPort(params), getDatabase(params));
if (url == null) {
url = String.format("jdbc:sqlserver://%s:%s;databaseName=%s", getHost(params), getPort(params, "1433"), getDatabase(params));
}
} else if ("PostgreSQL".equals(dbName)) {
Class.forName("org.postgresql.Driver");
// connectionURL = String.format("jdbc:postgresql://%s:%s/%s", getHost(params),
// getPort(params), getDatabase(params));
if (url == null) {
url = String.format("jdbc:postgresql://%s:%s/%s", getHost(params), getPort(params, "5432"), getDatabase(params));
}
}
con = DriverManager.getConnection(getUrl(params), info);
con = DriverManager.getConnection(url, info);
return onConnect(command, con);
} catch (Exception e) {
return onError(e);
Expand Down Expand Up @@ -186,6 +192,10 @@ public static String process(InputStream is) throws IOException, SQLException, J
while ((str = r.readLine()) != null) {
command.append(str);
}
if (command.charAt(0) != '{') {
byte[] decoded = StiBase64DecoderUtil.decode(rot13(command).toString());
command = new StringBuilder(new String(decoded, "UTF-8"));
}
return connect(new JSONObject(command.toString()));
}

Expand All @@ -206,17 +216,15 @@ private static String getUrl(Map<String, String> params) {
return getLeastOne(params, URL_KEYS);
}

@SuppressWarnings("unused")
private static String getDatabase(Map<String, String> params) {
return getLeastOne(params, DATABASE_KEY);
}

@SuppressWarnings("unused")
private static String getPort(Map<String, String> params) {
return getLeastOne(params, PORT_KEY);
private static String getPort(Map<String, String> params, String def) {
String result = getLeastOne(params, PORT_KEY);
return result != null ? result : def;
}

@SuppressWarnings("unused")
private static String getHost(Map<String, String> params) {
return getLeastOne(params, HOST_KEY);
}
Expand All @@ -240,4 +248,21 @@ private static String getLeastOne(Map<String, String> params, List<String> keys)
return null;
}

private static StringBuilder rot13(StringBuilder str) {
StringBuilder result = new StringBuilder();
for (int i = 0; i < str.length(); i++) {
char c = str.charAt(i);
if (c >= 'a' && c <= 'm')
c += 13;
else if (c >= 'A' && c <= 'M')
c += 13;
else if (c >= 'n' && c <= 'z')
c -= 13;
else if (c >= 'N' && c <= 'Z')
c -= 13;
result.append(c);
}
return result;
}

}

0 comments on commit d5d9188

Please sign in to comment.