in shardingsphere-benchmark/src/main/java/org/apache/shardingsphere/benchmark/jmeter/JMeterBenchmarkBase.java [71:119]
public static void initSqlConfig() {
Properties sqlProp = new Properties();
try {
InputStream in = PropertiesUtil.class.getResourceAsStream("/config/sqlconfig.properties");
BufferedReader br = new BufferedReader(new InputStreamReader(in));
sqlProp.load(in);
String values = "";
Iterator<String> it = sqlProp.stringPropertyNames().iterator();
while (it.hasNext()) {
String key = it.next();
if (key.contains(".values")) {
values = sqlProp.getProperty(key);
if (values != null && values.length() > 0) {
String[] arrayValues = values.split(",");
List listValues = new ArrayList();
for (int i = 0; i < arrayValues.length; i++) {
String[] subs = arrayValues[i].split(":");
if ("Int".equals(subs[0])) {
listValues.add(Integer.valueOf(subs[1]).intValue());
} else if ("Float".equals(subs[0])) {
listValues.add(Float.valueOf(subs[1]).floatValue());
} else if ("Long".equals(subs[0])) {
listValues.add(Long.valueOf(subs[1]).longValue());
} else if ("String".equals(subs[0])) {
listValues.add(String.valueOf(subs[1]));
} else if ("".equals(((String) arrayValues[i]))) {
listValues.add((String) arrayValues[i]);
} else {
listValues.add((String) subs[1]);
}
}
sqlConfig.put(key, listValues);
} else {
sqlConfig.put(key, sqlProp.getProperty(key));
}
} else {
sqlConfig.put(key, sqlProp.getProperty(key));
}
}
in.close();
br.close();
} catch (Exception ex) {
ex.printStackTrace();
}
}