使用 Java 将 Bloomberg API 数据附加到 MySQL table 的最简单方法
Simplest way to append Bloomberg API data to a MySQL table using Java
我想使用 Java.
将 Bloomberg API 回复附加到 MySQL 数据库
目前我查询 API 并使用以下代码显示响应:
session.sendRequest(request, null);
while (true) {
Event event = session.nextEvent();
MessageIterator msgIter = event.messageIterator();
while (msgIter.hasNext()) {
Message msg = msgIter.next();
new JSONObject(msg);
System.out.println(msg);
}
if (event.eventType() == Event.EventType.RESPONSE) {
break;
}
}
我希望能够将 msg
对象附加到 MySQL 数据库中的 table。 msg
对象看起来像是 JSON 格式(尽管我不确定如何确认这一点)。
我使用 JDBC.
连接到 MySQL table 也没有问题
第 5 步与 select 查询相连,在您的情况下,第 4 步需要使用更新查询,不需要第 5 步。您需要从 json 获取字段值并将它们放入更新语句中。要从 json 获取值:
//example json string
String json = "{paramsArray: [\"first\", 100],"
+ "paramsObj: {one: \"two\", three: \"four\"},"
+ "paramsStr: \"some string\"}";
JSONParser parser = new JSONParser();
Object obj = parser.parse(json);
JSONObject jsonObj = (JSONObject) obj;
System.out.println(jsonObj.get("paramsStr"));
JsonObject jo = jsonObj.get("paramsObj");
System.out.println(jo.get("three"));
// output will be 'four'
此处引用 mysql 中的更新查询:https://dev.mysql.com/doc/refman/5.0/en/update.html
我想使用 Java.
将 Bloomberg API 回复附加到 MySQL 数据库目前我查询 API 并使用以下代码显示响应:
session.sendRequest(request, null);
while (true) {
Event event = session.nextEvent();
MessageIterator msgIter = event.messageIterator();
while (msgIter.hasNext()) {
Message msg = msgIter.next();
new JSONObject(msg);
System.out.println(msg);
}
if (event.eventType() == Event.EventType.RESPONSE) {
break;
}
}
我希望能够将 msg
对象附加到 MySQL 数据库中的 table。 msg
对象看起来像是 JSON 格式(尽管我不确定如何确认这一点)。
我使用 JDBC.
连接到 MySQL table 也没有问题第 5 步与 select 查询相连,在您的情况下,第 4 步需要使用更新查询,不需要第 5 步。您需要从 json 获取字段值并将它们放入更新语句中。要从 json 获取值:
//example json string
String json = "{paramsArray: [\"first\", 100],"
+ "paramsObj: {one: \"two\", three: \"four\"},"
+ "paramsStr: \"some string\"}";
JSONParser parser = new JSONParser();
Object obj = parser.parse(json);
JSONObject jsonObj = (JSONObject) obj;
System.out.println(jsonObj.get("paramsStr"));
JsonObject jo = jsonObj.get("paramsObj");
System.out.println(jo.get("three"));
// output will be 'four'
此处引用 mysql 中的更新查询:https://dev.mysql.com/doc/refman/5.0/en/update.html