package osm.jp;
import osm.jp.api.HttpGET;
+
import javax.xml.parsers.*;
import javax.xml.transform.TransformerException;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
+import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
// 近くのバス停を探す範囲（バス停を中心としたNEER×２ｍ四方の領域
static final int NEER = 75;
- static boolean nocheck = false;
+ static boolean nocheck = true;
/**
* メイン
*
+ * java -cp .:ConvBusstop.jar:hayashi_0225.jar:hsqldb_2.2.9.jar osm.jp.ConvBusstop <option>
+ * OPTION: -nocheck OSMデータ上に既存のバス停が存在するかどうかをチェックしない
+ * OPTION: -check OSMデータ上に既存のバス停が存在するかどうかをチェックする
+ *
* @throws IOException
* @throws SQLException
* @throws ClassNotFoundException
public static void main(String[] args) throws FileNotFoundException, ClassNotFoundException, SQLException, IOException, ParserConfigurationException, SAXException, TransformerException
{
int index = 0;
- boolean updateDb = true;
if (args.length > index) {
- if (args[index].equals("-exp")) {
- updateDb = false;
+ if (args[index].equals("-check")) {
+ ConvBusstop.nocheck = false;
index++;
}
if (args[index].equals("-nocheck")) {
* > java -jar ConvBusstop.jar <オプション>
* オプション： -exp 実行する直前にデータベースを初期化する（省略可能）
*/
+ File dbdir = new File("database");
+ if (!dbdir.isDirectory()) {
+ dbdir.mkdir();
+ }
+
Connection con = DatabaseTool.openDb("database");
+ ConvBusstop.initDb(con);
+
try {
/**
* バス停データ変換のメイン処理
File iFile = new File(args[index]);
fcounter++;
- ConvBusstop.initDb(con);
inputFile(con, iFile);
String iStr = iFile.getName();
outputDb(con, iStr.substring(0, iStr.length() - 4));
}
else {
- if (updateDb) {
- File dbdir = new File("database");
- if (dbdir.isDirectory()) {
- dbdir.delete();
- }
- dbdir.mkdir();
- }
-
File dir = new File(".");
File[] files = dir.listFiles();
-
for (File iFile : files) {
- ConvBusstop.initDb(con);
if (checkFile(iFile)) {
fcounter++;
+ ConvBusstop.clearDb(con);
inputFile(con, iFile);
- }
- }
- // ローカルデータベース内の情報を出力する
- for (File iFile : files) {
- if (checkFile(iFile)) {
+
+ // ローカルデータベース内の情報を出力する
String iStr = iFile.getName();
outputDb(con, iStr.substring(0, iStr.length() - 4));
}
* @throws ClassNotFoundException
* @throws SQLException
* @throws IOException
+ * @throws ParserConfigurationException
+ * @throws SAXException
*/
- public static void inputFile (Connection con, File iFile) throws FileNotFoundException, ClassNotFoundException, SQLException, IOException {
+ public static void inputFile (Connection con, File iFile) throws FileNotFoundException, ClassNotFoundException, SQLException, IOException, ParserConfigurationException, SAXException {
int iCounter = 0;
String timeStampStr = null;
Node root;
iCounter = 0;
- try {
- factory = DocumentBuilderFactory.newInstance();
- builder = factory.newDocumentBuilder();
- factory.setIgnoringElementContentWhitespace(true);
- factory.setIgnoringComments(true);
- factory.setValidating(true);
- root = builder.parse(iStr);
-
- iCounter += showNodes(con, root, iStr.substring(0, iStr.length() - 4), timeStampStr);
- } catch (ParserConfigurationException e0) {
- System.out.println(e0.getMessage());
- } catch (SAXException e1){
- System.out.println(e1.getMessage());
- } catch (IOException e2) {
- System.out.println(e2.getMessage());
- } catch (SQLException e2) {
- System.out.println(e2.getMessage());
- }
+ factory = DocumentBuilderFactory.newInstance();
+ builder = factory.newDocumentBuilder();
+ factory.setIgnoringElementContentWhitespace(true);
+ factory.setIgnoringComments(true);
+ factory.setValidating(true);
+ root = builder.parse(iStr);
+
+ iCounter += showNodes(con, root, iStr.substring(0, iStr.length() - 4), timeStampStr);
System.out.println("バス停数["+ iCounter +"]");
}
- public static void initDb(Connection con) {
-
- try {
- if (DB_INIT) {
- DbBusstop.drop(con); // 'table.BUS_STOP'を削除する
- }
- }
- catch (SQLException e) {
- System.out.println("table [bus_stop] is not created.");
- }
-
- try {
- if (DB_INIT) {
- String createSt = "DROP TABLE bus_course;";
- PreparedStatement ps = con.prepareStatement(createSt);
- ps.executeUpdate();
- ps.close();
- }
- }
- catch (SQLException e) {
- System.out.println("table [bus_course] is not created.");
- }
+ public static void clearDb(Connection con) throws SQLException {
+ Statement stmt = con.createStatement();
+ long count = stmt.executeUpdate("delete from bus_stop");
+ System.out.println("'bus_stop'から "+ count +" 件のデータを削除しました。");
+
+ count = stmt.executeUpdate("delete from bus_course");
+ System.out.println("'bus_course'から "+ count +" 件のデータを削除しました。");
+
+ count = stmt.executeUpdate("delete from bus_ref");
+ System.out.println("'bus_ref'から "+ count +" 件のデータを削除しました。");
+ stmt.close();
+ }
- try {
- if (DB_INIT) {
- String createSt = "DROP TABLE bus_ref;";
- PreparedStatement ps = con.prepareStatement(createSt);
- ps.executeUpdate();
- ps.close();
- }
- }
- catch (SQLException e) {
- System.out.println("table [bus_ref] is not created.");
- }
+ public static void initDb(Connection con) throws SQLException {
+ String createSt;
+ PreparedStatement ps;
// 'table.BUS_STOP'を新規に作る
- try {
- DbBusstop.create(con);
- }
- catch (SQLException e) {
- System.out.println("table [bus_stop] is already created.");
- }
-
- try {
- String createSt = "CREATE TABLE bus_course (code int, type int, corp VARCHAR(128) NOT NULL, course VARCHAR(512), ifile VARCHAR(128), CONSTRAINT bus_course_pk PRIMARY KEY(code));";
- PreparedStatement ps = con.prepareStatement(createSt);
- ps.executeUpdate();
- ps.close();
- }
- catch (SQLException e) {
- System.out.println("table [bus_course] is already created.");
- }
-
- try {
- String createSt = "CREATE TABLE bus_ref (idref VARCHAR(12), code INT);";
- PreparedStatement ps = con.prepareStatement(createSt);
- ps.executeUpdate();
- ps.close();
- }
- catch (SQLException e) {
- System.out.println("table [bus_ref] is already created.");
- }
+ DbBusstop.create(con);
+
+ createSt = "CREATE TABLE bus_course (code int, type int, corp VARCHAR(128) NOT NULL, course VARCHAR(512), ifile VARCHAR(128), CONSTRAINT bus_course_pk PRIMARY KEY(code));";
+ System.out.println(createSt);
+ ps = con.prepareStatement(createSt);
+ ps.executeUpdate();
+ ps.close();
+
+ createSt = "CREATE TABLE bus_ref (idref VARCHAR(12), code INT);";
+ System.out.println(createSt);
+ ps = con.prepareStatement(createSt);
+ ps.executeUpdate();
+ ps.close();
}
BufferedWriter ow = null;
BufferedWriter gw = null;
+ BufferedWriter hw = null;
+ BufferedWriter ww = null;
+ // HTML header
File htmlFile = new File(iCode +".html");
- BufferedWriter hw = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(htmlFile), "UTF-8"));
+ hw = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(htmlFile), "UTF-8"));
hw.write("<!DOCTYPE html>");
hw.newLine();
hw.write("<html><head><meta charset=\"utf-8\" /></head>");
hw.write("</tr>");
hw.newLine();
- PreparedStatement ps7 = con.prepareStatement("SELECT code,type,corp,course,ifile FROM bus_course WHERE ifile=? ORDER BY corp,course");
+ // Wiki header
+ File wikiFile = new File(iCode +".wiki.txt");
+ ww = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(wikiFile), "UTF-8"));
+ ww.write("= バス路線毎のマッピング状況 =");
+ ww.newLine();
+ ww.newLine();
+
+ String maeCorp = "";
+ boolean firstCorp = true;
+
+ PreparedStatement ps7 = con.prepareStatement("SELECT code,type,corp,course,ifile FROM bus_course WHERE ifile=? ORDER BY type,corp,course");
PreparedStatement ps9 = con.prepareStatement("SELECT idref FROM bus_ref WHERE code=?");
PreparedStatement ps8 = con.prepareStatement("SELECT name,lat,lon,fixed FROM bus_stop WHERE idref=?");
ps7.setString(1, iCode);
int type = rset7.getInt(2);
String corp = rset7.getString(3);
String course = rset7.getString(4);
+
File osmFile = new File(dir, iCode + String.format("_%1$08d", code) +".osm");
File gpxFile = new File(dir, iCode + String.format("_%1$08d", code) +".gpx");
hw.write("<td><a href='"+ dir.getName() +"/"+ osmSample.getName() +"'>"+ osmSample.getName() +"</a></td>");
hw.newLine();
+ //--------------------------------------------
+ // Wiki見出し２: 運行会社
+ //------------
+ if (!maeCorp.equals(corp)) {
+ if (firstCorp == false) {
+ ww.write("|}");
+ ww.newLine();
+ ww.newLine();
+ }
+ firstCorp = false;
+
+ ww.write("=== "+ corp +" ===");
+ ww.newLine();
+ ww.newLine();
+
+ ww.write(":{{JA:Tag|network||"+ corp +"}}");
+ ww.newLine();
+ ww.write(":{{JA:Tag|operator||"+ corp +"}}");
+ ww.newLine();
+ ww.newLine();
+
+ ww.write("{| class=\"wikitable sortable\" style=\"table-layout: fixed; width: 100%\"");
+ ww.newLine();
+ ww.write("!style=\"width: 100px\"| ref");
+ ww.newLine();
+ ww.write("!class=\"unsortable\" style=\"width: 152px\"| 編集状況(マスタ)");
+ ww.newLine();
+ ww.write("!class=\"unsortable\" style=\"width: 152px\"| 編集状況(往路)");
+ ww.newLine();
+ ww.write("!class=\"unsortable\" style=\"width: 152px\"| 編集状況(復路)");
+ ww.newLine();
+ ww.write("!class=\"unsortable\"| 備考");
+ ww.newLine();
+
+ maeCorp = new String(corp);
+ }
+
+ // Wiki
+ ww.write("|-");
+ ww.newLine();
+ ww.write("| "+ course +" "); // ref
+ ww.write("|| {{State Route|r=0}} {{relation|0|tools=no}} "); // 編集状況 (マスタ)
+ ww.write("|| {{State Route|r=0|h=0}} {{relation|0|tools=no}} "); // 編集状況 (往路)
+ ww.write("|| {{State Route|r=0|h=0}} {{relation|0|tools=no}} "); // 編集状況 (復路)
+ ww.write("|| "); // 備考
+ ww.newLine();
+
+
// OSM file header
ow = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(osmFile), "UTF-8"));
ow.write("<?xml version=\"1.0\" encoding=\"UTF-8\" ?>");
ow.newLine();
- ow.write("<osm version=\"0.5\" generator=\"ReadKIBAN\">");
+ ow.write("<osm version=\"0.6\" generator=\"ReadKIBAN\">");
ow.newLine();
// GPX file header
if (lon < minLon) {
minLon = lon;
}
-
- System.out.println("\tway point = "+ idref);
+
+ System.out.println("\tway point = "+ idref +", lat="+ lat +", lon="+ lon +", name="+ name);
fixedCount += fixed;
if (fixed == 0) {
unfixedCount++;
ow.newLine();
// TEXT node
- File txtFile = new File(dir, iCode + idref +".txt");
- BufferedWriter gw2 = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(txtFile), "UTF-8"));
- gw2.write(osm_node);
- gw2.newLine();
- gw2.close();
+ //File txtFile = new File(dir, iCode + idref +".txt");
+ //BufferedWriter gw2 = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(txtFile), "UTF-8"));
+ //gw2.write(osm_node);
+ //gw2.newLine();
+ //gw2.close();
// GPX waypoint
gw.write("<wpt lat=\""+ lat +"\" lon=\""+ lon +"\">\n");
gw.write(" <time>"+ timeStampStr +"Z</time>\n");
gw.write(" <name><![CDATA["+ name +"]]></name>\n");
- gw.write(" <link href=\""+ txtFile.getName() +"\"><text>"+ idref +"</text></link>\n");
+ //gw.write(" <link href=\""+ txtFile.getName() +"\"><text>"+ idref +"</text></link>\n");
gw.write("</wpt>\n");
gw.newLine();
}
}
rset7.close();
+ // Wiki footer
+ ww.close();
+
// index file footer
hw.write("</table></body></html>");
hw.newLine();
}
public static String nodeBusstop(int code, String name, Double lat, Double lon, String timeStampStr) {
- String osm_node = ("<node id=\"-"+ code +"\" timestamp=\""+ timeStampStr +"Z\" lat=\""+ lat +"\" lon=\""+ lon +"\">\n");
+ String osm_node = ("<node id=\""+ code +"\" timestamp=\""+ timeStampStr +"Z\" lat=\""+ lat +"\" lon=\""+ lon +"\">\n");
osm_node += "<tag k=\"name\" v=\""+ name +"\"/>\n";
+ osm_node += "<tag k=\"fixme\" v=\"このバス停を正しい位置に移動させて\"/>\n";
+ osm_node += "<tag k=\"source\" v=\"KSJ2\"/>\n";
+ osm_node += "<tag k=\"source_ref\" v=\"http://nlftp.mlit.go.jp/ksj/gml/datalist/KsjTmplt-P11.html\"/>\n";
+ osm_node += "<tag k=\"created_by\" v=\"National-Land-Numerical-Information_MLIT_Japan\"/>\n";
+ osm_node += "<tag k=\"note\" v=\"National-Land Numerical Information (Bus stop) 2012, MLIT Japan\"/>\n";
+ osm_node += "<tag k=\"note:ja\" v=\"国土数値情報（バス停留所）平成２４年 国土交通省\"/>\n";
+ osm_node += "<tag k=\"public_transport\" v=\"platform\"/>\n";
osm_node += "<tag k=\"highway\" v=\"bus_stop\"/>\n";
osm_node += "<tag k=\"bus\" v=\"yes\"/>\n";
- osm_node += "<tag k=\"fixme\" v=\"このバス停を正しい位置に移動させて\"/>\n";
- osm_node += ("<tag k=\"source\" v=\"KSJ2\"/>\n");
- osm_node += ("<tag k=\"source_ref\" v=\"http://nlftp.mlit.go.jp/ksj/gml/datalist/KsjTmplt-P11.html\"/>\n");
- osm_node += ("<tag k=\"created_by\" v=\"National-Land-Numerical-Information_MLIT_Japan\"/>\n");
- osm_node += ("<tag k=\"note\" v=\"National-Land Numerical Information (Bus stop) 2012, MLIT Japan\"/>\n");
- osm_node += ("<tag k=\"note:ja\" v=\"国土数値情報（バス停留所）平成２４年 国土交通省\"/>\n");
- osm_node += ("<tag k=\"public_transport\" v=\"stop_position\"/>\n");
- osm_node += ("</node>\n");
+ osm_node += "</node>\n";
return osm_node;
}
if (node2.getNodeName().equals("jps:GM_Point")) {
showGmPoint(con, node2);
}
+ else if (node2.getNodeName().equals("gml:Point")) {
+ showGmlPoint(con, node2);
+ }
+
else if (node2.getNodeName().equals("ksj:ED01")) {
iCounter++;
showED01(con, node2, iFileName);
}
+ else if (node2.getNodeName().equals("ksj:BusStop")) {
+ iCounter++;
+ showBusStop(con, node2, iFileName);
+ }
+
else {
iCounter += showNodes(con, node2, iFileName, timeStampStr);
}
}
// idref と nameStr をデータベースに格納する
- boolean insert = false;
+ boolean insert = true;
ps1.setString(1, idrefStr);
ResultSet rset = ps1.executeQuery();
- if (!rset.next()) {
- insert = true;
+ if (rset.next()) {
+ insert = false;
}
rset.close();
ps2.setString(1, idrefStr);
ps2.setString(2, nameStr);
ps2.setString(3, iFileName);
+ System.out.println("INSERT INTO bus_stop (idref,name,ifile) VALUES ('"+ idrefStr +"','"+ nameStr +"','"+ iFileName +"')");
ps2.executeUpdate();
}
ps5.close();
}
+ /**
+ * <ksj:BusStop gml:id="ED01_1">
+ * <ksj:position xlink:href="#n1"/>
+ * <ksj:busStopName>城堀</ksj:busStopName>
+ * <ksj:busRouteInformation>
+ * <ksj:BusRouteInformation>
+ * <ksj:busType>1</ksj:busType>
+ * <ksj:busOperationCompany>箱根登山バス</ksj:busOperationCompany>
+ * <ksj:busLineName>小01</ksj:busLineName>
+ * </ksj:BusRouteInformation>
+ * </ksj:busRouteInformation>
+ * <ksj:busRouteInformation>
+ * <ksj:BusRouteInformation>
+ * <ksj:busType>1</ksj:busType>
+ * <ksj:busOperationCompany>箱根登山バス</ksj:busOperationCompany>
+ * <ksj:busLineName>湯07</ksj:busLineName>
+ * </ksj:BusRouteInformation>
+ * </ksj:busRouteInformation>
+ * <ksj:busRouteInformation>
+ * <ksj:BusRouteInformation>
+ * <ksj:busType>1</ksj:busType>
+ * <ksj:busOperationCompany>箱根登山バス</ksj:busOperationCompany>
+ * <ksj:busLineName>湯11</ksj:busLineName>
+ * </ksj:BusRouteInformation>
+ * </ksj:busRouteInformation>
+ * </ksj:BusStop>
+ *
+ * @param con
+ * @param node
+ * @param iFileName // ソースファイル名（拡張子を含まない）
+ * @throws IOException
+ * @throws SQLException
+ */
+ public static void showBusStop(Connection con, Node node, String iFileName) throws IOException, SQLException {
+ String idrefStr = "";
+ String nameStr = "";
+ PreparedStatement ps2 = con.prepareStatement("UPDATE bus_stop SET name=?,ifile=? WHERE idref=?");
+ PreparedStatement ps3 = con.prepareStatement("SELECT code FROM bus_course WHERE course=? AND corp=? AND ifile=?");
+ PreparedStatement ps4 = con.prepareStatement("INSERT INTO bus_course (code,type,corp,course,ifile) VALUES (?,?,?,?,?)");
+ PreparedStatement ps5 = con.prepareStatement("INSERT INTO bus_ref (idref,code) VALUES (?,?)");
+ PreparedStatement ps6 = con.prepareStatement("SELECT max(code) FROM bus_course WHERE ifile=?");
+
+ ArrayList<String[]> bris = new ArrayList<String[]>();
+ NodeList nodes = node.getChildNodes();
+ for (int i=0; i < nodes.getLength(); i++) {
+ Node node2 = nodes.item(i);
+ if (node2.getNodeName().equals("ksj:position")) {
+ NamedNodeMap nodeMap = node2.getAttributes();
+ if (null != nodeMap) {
+ for ( int j=0; j < nodeMap.getLength(); j++ ) {
+ if (nodeMap.item(j).getNodeName().equals("xlink:href")) {
+ idrefStr = nodeMap.item(j).getNodeValue();
+ idrefStr = idrefStr.substring(1);
+ System.out.println("found idref='"+ idrefStr +"'");
+ break;
+ }
+ }
+ }
+ }
+ else if (node2.getNodeName().equals("ksj:busStopName")) {
+ nameStr = node2.getTextContent();
+ }
+ else if (node2.getNodeName().equals("ksj:busRouteInformation")) {
+ String[] rtn = anaCommJGD(node2);
+ if (rtn != null) {
+ bris.add(rtn);
+ }
+ }
+ }
+
+ // idref と nameStr をデータベースに格納する
+ ps2.setString(1, nameStr);
+ ps2.setString(2, iFileName);
+ ps2.setString(3, idrefStr);
+ ps2.executeUpdate();
+
+ for (String[] rtn : bris) {
+ int code = 0;
+ ps3.setString(1, rtn[1]);
+ ps3.setString(2, rtn[2]);
+ ps3.setString(3, iFileName);
+ ResultSet rset = ps3.executeQuery();
+ if (rset.next()) {
+ code = rset.getInt(1);
+ }
+ rset.close();
+
+ if (code == 0) {
+ ps6.setString(1, iFileName);
+ ResultSet rset6 = ps6.executeQuery();
+ if (rset6.next()) {
+ code = rset6.getInt(1);
+ }
+ rset6.close();
+ code++;
+
+ System.out.println("course="+ code +" : "+ rtn[0] +" : "+ rtn[1] +" : "+ rtn[2] );
+ ps4.setInt(1, code);
+ ps4.setInt(2, Integer.parseInt(rtn[0]));
+ ps4.setString(3, rtn[2]);
+ ps4.setString(4, rtn[1]);
+ ps4.setString(5, iFileName);
+ ps4.executeUpdate();
+ }
+
+ ps5.setString(1, idrefStr);
+ ps5.setInt(2, code);
+ ps5.executeUpdate();
+ }
+
+ ps2.close();
+ ps3.close();
+ ps4.close();
+ ps5.close();
+ }
+
public static String[] anaComm(Node briNode) {
String[] rtn = new String[3];
rtn[0] = ""; // corp type
return rtn;
}
+ /**
+ *
+ * <ksj:busRouteInformation>
+ * <ksj:BusRouteInformation>
+ * <ksj:busType>1</ksj:busType>
+ * <ksj:busOperationCompany>箱根登山バス</ksj:busOperationCompany>
+ * <ksj:busLineName>小01</ksj:busLineName>
+ * </ksj:BusRouteInformation>
+ * </ksj:busRouteInformation>
+ *
+ * @param briNode
+ * @return
+ */
+ public static String[] anaCommJGD(Node briNode) {
+ String[] rtn = new String[3];
+ int vcnt = 0;
+
+ NodeList nodes2 = briNode.getChildNodes();
+ for (int i=0; i < nodes2.getLength(); i++) {
+ Node node2 = nodes2.item(i);
+ if (node2.getNodeName().equals("ksj:BusRouteInformation")) {
+ NodeList nodes3 = node2.getChildNodes();
+ for (int j=0; j < nodes3.getLength(); j++) {
+ Node node3 = nodes3.item(j);
+ if (node3.getNodeName().equals("ksj:busType")) {
+ rtn[0] = new String(node3.getTextContent());
+ vcnt++;
+ }
+ else if (node3.getNodeName().equals("ksj:busLineName")) {
+ rtn[1] = new String(node3.getTextContent());
+ vcnt++;
+ }
+ else if (node3.getNodeName().equals("ksj:busOperationCompany")) {
+ rtn[2] = new String(node3.getTextContent());
+ vcnt++;
+ }
+ }
+ }
+ }
+
+ if (vcnt > 0) {
+ return rtn;
+ }
+ return null;
+ }
+
public static void showGmPoint(Connection con, Node node) throws IOException, SQLException {
String positionStr = "";
String latStr = "";
ps6.setDouble(2, lon);
ps6.setInt(3, (ConvBusstop.nocheck ? 0 : HttpGET.getMap(lat, lon, NEER)));
ps6.setString(4, idStr);
+ System.out.println("UPDATE bus_stop("+ idStr +") lat="+ lat +", lon="+ lon +", fixed="+ (ConvBusstop.nocheck ? 0 : HttpGET.getMap(lat, lon, NEER)));
ps6.executeUpdate();
+ ps6.close();
+ }
+ }
+ }
+
+ /**
+ * <gml:Point gml:id="n1">
+ * <gml:pos>35.14591397 139.10569573</gml:pos>
+ * </gml:Point>
+ *
+ * @param con
+ * @param node
+ * @throws IOException
+ * @throws SQLException
+ */
+ public static void showGmlPoint(Connection con, Node node) throws IOException, SQLException {
+ String positionStr = "";
+ String latStr = "";
+ String lonStr = "";
+ String idStr = "";
+
+ NamedNodeMap nodeMap = node.getAttributes();
+ if ( null != nodeMap ) {
+ for ( int j=0; j<nodeMap.getLength(); j++ ) {
+ if (nodeMap.item(j).getNodeName().equals("gml:id")) {
+ idStr = nodeMap.item(j).getNodeValue();
+ }
+ }
+ }
+
+ NodeList nodes = node.getChildNodes();
+ for (int i=0; i < nodes.getLength(); i++) {
+ Node node2 = nodes.item(i);
+ if (node2.getNodeName().equals("gml:pos")) {
+ positionStr = node2.getTextContent().trim();
+ String[] str4Ary = positionStr.split(" ");
+ latStr = str4Ary[0];
+ lonStr = str4Ary[1];
+
+ PreparedStatement ps6 = con.prepareStatement("INSERT INTO bus_stop (lat,lon,fixed,idref) VALUES (?,?,?,?)");
+ double lat = Double.parseDouble(latStr);
+ double lon = Double.parseDouble(lonStr);
+ System.out.println("INSERT INTO bus_stop (lat,lon,fixed,idref) VALUES ('"+ latStr +"','"+ lonStr +"','"+ (ConvBusstop.nocheck ? 0 : HttpGET.getMap(lat, lon, NEER)) +"','"+ idStr +"')");
+
+ ps6.setDouble(1, lat);
+ ps6.setDouble(2, lon);
+ ps6.setInt(3, (ConvBusstop.nocheck ? 0 : HttpGET.getMap(lat, lon, NEER)));
+ ps6.setString(4, idStr);
+ ps6.executeUpdate();
+ ps6.close();
}
}
}
}
return true;
}
-
-
}
\ No newline at end of file
OSDN Git Service
