2021年8月27日 星期五

how to query OSM data in Java? 

開放街圖OSM的公共圖資可以透過overpass-turbo介面查詢獲得。
若想利用Java程式碼查詢，可參考以下查詢範例。
其中，查詢指令可參考overpass-turbo範例指令，測試成功再代入程式。


  1.  
  2. /*
  3.   QueryOSM.java
  4.         展示如何用retrofit套件，同步及非同步(適用於Android)，存取如下OSM圖資服務
  5.                 http://overpass-api.de/api/interpreter?data=xxx
  6.  
  7.         // 建立服務連線客戶端及請求內容
  8.         OverpassService requestClient = OverpassServiceProvider.get();
  9.         String request = composeRequest();
  10.         
  11.         // 非同步查詢圖資，適用於手機平板Android平台
  12.         asyncRequest(requestClient, request);
  13.         
  14.         // 同步查詢圖資，適用於桌機Application應用
  15.         OverpassQueryResult result = syncRequest(requestClient, request);
  16.         postProcess(result);
  17.  
  18. 執行步驟:
  19.   javac QueryOSM.java
  20.   java QueryOSM
  21. run:
  22. [out:json][timeout:25];
  23. (
  24. node[tourism](25.1735, 121.446, 25.1775, 121.455);
  25. relation[!highway][type!='route'][!boundary](25.1735, 121.446, 25.1775, 121.455);
  26. );
  27. out center;
  28. end of asyncRequest()
  29. 21 elements...
  30. 1. id:4326372453, type:node, lat:25.1761808, lon:121.4490491, name:五虎碑, wheelchair:limited
  31. 2. id:4384988658, type:node, lat:25.1750071, lon:121.4522078, name:文錙藝術中心, wheelchair:yes
  32. 3. id:4492221396, type:node, lat:25.1736267, lon:121.4473809, name:三化牆
  33. 4. id:4492221397, type:node, lat:25.1744069, lon:121.4474037, name:地球村雕像, wheelchair:limited
  34. 5. id:4492221399, type:node, lat:25.1735175, lon:121.4484658, name:淡江大學花牆
  35. 6. id:4492221425, type:node, lat:25.1749949, lon:121.450678, name:閱讀的少女, wheelchair:yes
  36. 7. id:4502075211, type:node, lat:25.1751384, lon:121.4523232, name:旅者
  37. 8. id:4502075212, type:node, lat:25.1739938, lon:121.4505047, name:李雙澤紀念碑, wheelchair:yes
  38. 9. id:4502075213, type:node, lat:25.1761919, lon:121.4499374, name:福園金鷹銅雕, wheelchair:no
  39. 10. id:4502075222, type:node, lat:25.1738907, lon:121.4475716, name:驚聲銅像, wheelchair:limited
  40. 11. id:4507662408, type:node, lat:25.1741082, lon:121.4474671, name:溫馨, wheelchair:yes
  41. 12. id:5012978611, type:node, lat:25.1741784, lon:121.4507282, name:黃河母親, wheelchair:no
  42. 13. id:5072580167, type:node, lat:25.1769149, lon:121.4495309
  43. 14. id:5130535622, type:node, lat:25.1757202, lon:121.4496844, name:會文館, wheelchair:yes
  44. 15. id:5132288341, type:node, lat:25.1741586, lon:121.4508061
  45. 16. id:5132288342, type:node, lat:25.174208, lon:121.4475417
  46. 17. id:6050843218, type:node, lat:25.1770813, lon:121.449821
  47. 18. id:8991981256, type:node, lat:25.1750049, lon:121.4480033, name:淡江願景牆, wheelchair:yes
  48. 19. id:3974590, type:relation, lat:0.0, lon:0.0, type:multipolygon, name:操場
  49. 20. id:3983402, type:relation, lat:0.0, lon:0.0, type:multipolygon, name:松濤廣場
  50. 21. id:7530081, type:relation, lat:0.0, lon:0.0, type:multipolygon
  51.  
  52. Response{protocol=http/1.1, code=200, message=OK, url=http://overpass-api.de/api/interpreter?data=%5Bout%3Ajson%5D%5Btimeout%3A25%5D%3B%0A%28%0Anode%5Btourism%5D%2825.1735%2C%20121.446%2C%2025.1775%2C%20121.455%29%3B%0Arelation%5B%21highway%5D%5Btype%21%3D%27route%27%5D%5B%21boundary%5D%2825.1735%2C%20121.446%2C%2025.1775%2C%20121.455%29%3B%0A%29%3B%0Aout%20center%3B}
  53. end of syncRequest()
  54. 21 elements...
  55. 1. id:4326372453, type:node, lat:25.1761808, lon:121.4490491, name:五虎碑, wheelchair:limited
  56. 2. id:4384988658, type:node, lat:25.1750071, lon:121.4522078, name:文錙藝術中心, wheelchair:yes
  57. 3. id:4492221396, type:node, lat:25.1736267, lon:121.4473809, name:三化牆
  58. 4. id:4492221397, type:node, lat:25.1744069, lon:121.4474037, name:地球村雕像, wheelchair:limited
  59. 5. id:4492221399, type:node, lat:25.1735175, lon:121.4484658, name:淡江大學花牆
  60. 6. id:4492221425, type:node, lat:25.1749949, lon:121.450678, name:閱讀的少女, wheelchair:yes
  61. 7. id:4502075211, type:node, lat:25.1751384, lon:121.4523232, name:旅者
  62. 8. id:4502075212, type:node, lat:25.1739938, lon:121.4505047, name:李雙澤紀念碑, wheelchair:yes
  63. 9. id:4502075213, type:node, lat:25.1761919, lon:121.4499374, name:福園金鷹銅雕, wheelchair:no
  64. 10. id:4502075222, type:node, lat:25.1738907, lon:121.4475716, name:驚聲銅像, wheelchair:limited
  65. 11. id:4507662408, type:node, lat:25.1741082, lon:121.4474671, name:溫馨, wheelchair:yes
  66. 12. id:5012978611, type:node, lat:25.1741784, lon:121.4507282, name:黃河母親, wheelchair:no
  67. 13. id:5072580167, type:node, lat:25.1769149, lon:121.4495309
  68. 14. id:5130535622, type:node, lat:25.1757202, lon:121.4496844, name:會文館, wheelchair:yes
  69. 15. id:5132288341, type:node, lat:25.1741586, lon:121.4508061
  70. 16. id:5132288342, type:node, lat:25.174208, lon:121.4475417
  71. 17. id:6050843218, type:node, lat:25.1770813, lon:121.449821
  72. 18. id:8991981256, type:node, lat:25.1750049, lon:121.4480033, name:淡江願景牆, wheelchair:yes
  73. 19. id:3974590, type:relation, lat:0.0, lon:0.0, type:multipolygon, name:操場
  74. 20. id:3983402, type:relation, lat:0.0, lon:0.0, type:multipolygon, name:松濤廣場
  75. 21. id:7530081, type:relation, lat:0.0, lon:0.0, type:multipolygon
  76.  
  77. end of main()
  78. BUILD SUCCESSFUL (total time: 1 minute 2 seconds)
  79.  
  80.   參考:
  81.   a. Retrofit 2 – Synchronous and asynchronous call example
  82.         https://howtodoinjava.com/retrofit2/retrofit-sync-async-calls/
  83.   b. https://github.com/zsoltk/overpasser
  84.         hu.supercluster.overpasser.adapter
  85.             OverpassQueryResult
  86.             OverpassQueryResult.Element
  87.             OverpassQueryResult.Element.Tags
  88.             OverpassService
  89.   c. 引用函數庫
  90.       compile/run: 
  91.         okhttp-3.14.9.jar
  92.         okio-1.17.2.jar
  93.         converter-gson-2.10.2.jar
  94.         gson-2.8.5.jar
  95.         retrofit-2.10.2.jar
  96.       compile/run tests:
  97.         byte-buddy-1.11.3.jar
  98.         byte-buddy-agent-1.11.3.jar
  99.         mockito-core-3.11.2.jar
  100.         objenesis-3.2.jar
  101.  */
  102. import com.google.gson.Gson;
  103. import com.google.gson.GsonBuilder;
  104.  
  105. import retrofit2.Call;
  106. import retrofit2.Callback;
  107. import retrofit2.Response;
  108. import retrofit2.Retrofit;
  109. import retrofit2.converter.gson.GsonConverterFactory;
  110.  
  111. import hu.supercluster.overpasser.library.output.OutputFormat;
  112. import hu.supercluster.overpasser.library.output.OutputModificator;
  113. import hu.supercluster.overpasser.library.output.OutputOrder;
  114. import hu.supercluster.overpasser.library.output.OutputVerbosity;
  115. import hu.supercluster.overpasser.library.query.OverpassQuery;
  116.  
  117. import hu.supercluster.overpasser.adapter.OverpassQueryResult;
  118. import hu.supercluster.overpasser.adapter.OverpassQueryResult.Element;
  119. import hu.supercluster.overpasser.adapter.OverpassQueryResult.Element.Tags;
  120. import hu.supercluster.overpasser.adapter.OverpassService;
  121. import hu.supercluster.overpasser.adapter.OverpassServiceProvider;
  122.  
  123. import java.lang.reflect.Field;
  124. import java.util.List;
  125. /**
  126.  *
  127.  * @author seke
  128.  */
  129.  
  130. public class QueryOSM {
  131.     
  132.     // 可利用下址測試查詢指令
  133.     //     http://overpass-turbo.eu/
  134.     public static String composeRequest()
  135.     {
  136. /* 查詢範例1: 
  137.         在(47.48047027491862,19.039797484874725,47.51331674014172,19.07404761761427)範圍內
  138.         列出所有非私人停車場
  139.         
  140.     A. 查詢指令
  141.     ["out":"json"]["timeout":"30"];
  142.     (
  143.         node
  144.             ["amenity"="parking"]
  145.             ["access"!="private"]
  146.             (47.48047027491862,19.039797484874725,47.51331674014172,19.07404761761427);
  147.             <;
  148.     );
  149.     out body center qt 100;
  150.  
  151.     B. 組合查詢指令方法
  152.       String query = new OverpassQuery()
  153.         .format(OutputFormat.JSON)
  154.         .timeout(30)
  155.         .filterQuery()
  156.             .node()
  157.             .amenity("parking")
  158.             .tagNot("access", "private")
  159.             .boundingBox(
  160.                 47.48047027491862, 19.039797484874725,
  161.                 47.51331674014172, 19.07404761761427
  162.             )
  163.         .end()
  164.         .output(OutputVerbosity.BODY, OutputModificator.CENTER, OutputOrder.QT, 100)
  165.         .build()
  166.         ;
  167. */
  168.  
  169. /* 查詢範例2: 
  170.         在(25.1735, 121.446, 25.1775, 121.455)範圍內，撈取
  171.            非座椅設施，商店，觀光點，辦公室，繄急設施之節點
  172.            屬於大學設施之線條，關係
  173.            不屬於公路、路線、森林、邊界之線條，關係
  174.         列出其中心位置及相關屬性(標籤)
  175.  
  176.         A. 查詢指令
  177.     [out:json][timeout:25];
  178.     // gather results
  179.     (
  180.       node[amenity][amenity!=bench](25.1735, 121.446, 25.1775, 121.455);
  181.       node[shop](25.1735, 121.446, 25.1775, 121.455);
  182.       node[tourism](25.1735, 121.446, 25.1775, 121.455);
  183.       node[office](25.1735, 121.446, 25.1775, 121.455);
  184.       node[emergency](25.1735, 121.446, 25.1775, 121.455);
  185.       //way[amenity="university"](25.1735, 121.446, 25.1775, 121.455);
  186.       relation[amenity="university"](25.1735, 121.446, 25.1775, 121.455);
  187.       way[!highway][type!="route"][landuse!="forest"][!boundary](25.1735, 121.446, 25.1775, 121.455);
  188.       relation[!highway][type!="route"][!boundary](25.1735, 121.446, 25.1775, 121.455);
  189.     );
  190.     // print results
  191.     out center;
  192. ---
  193.   註:  淡江大學之範圍為 25.1735, 121.446, 25.1775, 121.455
  194. */       
  195.        String query = String.join("\n",
  196.                "[out:json][timeout:25];",
  197.                "(",
  198. //               "node[amenity][amenity!=bench](25.1735, 121.446, 25.1775, 121.455);",
  199. //               "node[shop](25.1735, 121.446, 25.1775, 121.455);",
  200.                "node[tourism](25.1735, 121.446, 25.1775, 121.455);",
  201. //               "node[office](25.1735, 121.446, 25.1775, 121.455);",
  202. //               "node[emergency](25.1735, 121.446, 25.1775, 121.455);",
  203. //               "relation[amenity='university'](25.1735, 121.446, 25.1775, 121.455);",
  204. //               "way[!highway][type!='route'][landuse!='forest'][!boundary](25.1735, 121.446, 25.1775, 121.455);",
  205.                "relation[!highway][type!='route'][!boundary](25.1735, 121.446, 25.1775, 121.455);",
  206.                ");",
  207.                "out center;");
  208.  
  209.         System.out.println(query);
  210.         return query;
  211.     }
  212.     
  213.     public static void asyncRequest(OverpassService apiClient, String request)
  214.     {
  215.        //Call call = service.interpreter(query);
  216.        apiClient.interpreter(request).enqueue(new Callback()
  217.        {
  218.         @Override
  219.         public void onResponse(Call call, Response response)
  220.         {
  221.             if(response.isSuccessful()==false)
  222.             {
  223.                 System.out.println("asyncRequest: response.isSuccessful(): false");
  224.                 System.out.println(response.errorBody());
  225.                 return;
  226.             }
  227.             
  228.             OverpassQueryResult result = response.body();
  229.             postProcess(result);
  230.          }
  232.         public void onFailure(Call call, Throwable t) {
  233.         // DO failure handling 
  234.           System.out.println("onFailure");
  235.           System.out.println(t.getLocalizedMessage());
  236.         }
  237.        });
  238.        
  239.        System.out.println("end of asyncRequest()");
  240.     }
  241.     
  242.     public static OverpassQueryResult syncRequest(OverpassService apiClient, String request)
  243.     {
  244.         OverpassQueryResult result = null;
  245.         Call callSync =   apiClient.interpreter(request); 
  247.         try
  248.         {
  249.             Response response = callSync.execute();
  250.             //OverpassQueryResult apiResponse = response.body();
  251.      
  252.             //API response
  253.             System.out.println(response);
  254.             result = response.body();
  255.         }
  256.         catch (Exception ex) 
  257.         { 
  258.             ex.printStackTrace();
  259.         }
  260.         
  261.         System.out.println("end of syncRequest()");
  262.         return result;
  263.     }
  264.     
  265.     public static void postProcess(OverpassQueryResult result)
  266.     {
  267.         if(result==null) return;
  269.         // DO success handling 
  270.         StringBuilder sb = new StringBuilder();
  271.         System.out.println(result.elements.size() + " elements...");
  272.         int count = 1;
  273.         for (Element p : result.elements) 
  274.         {
  275.             sb.append(count); count++;
  276.             sb.append(String.format(". id:%s, type:%s, lat:%s, lon:%s", p.id, p.type, p.lat, p.lon));
  277.             Tags tags = p.tags;
  278.             for (Field f : tags.getClass().getFields()) {
  279.                 f.setAccessible(true);
  280.                 try 
  281.                 {
  282.                     if (f.get(tags) != null) {
  283.                        sb.append(String.format(", %s:%s", f.getName(), f.get(tags)));
  284.                     }
  285.                 }
  286.                 catch (IllegalAccessException e)
  287.                 { // shouldn't happen because I used setAccessible
  288.                 }
  290.             }
  291.             //if(p.tags. != null)
  292.             //  sb.append(String.format("tags:%s", p.tags.name));
  293.             sb.append("\n");
  294.         }
  295.         System.out.println(sb.toString());
  296.     }
  297.     
  298.     public static void main(String args[])
  299.     {
  300.         // 建立服務連線客戶端及請求內容
  301.         OverpassService requestClient = OverpassServiceProvider.get();
  302.         String request = composeRequest();
  303.         
  304.         // 非同步請求
  305.         asyncRequest(requestClient, request);
  306.         
  307.         // 同步請求
  308.         OverpassQueryResult result = syncRequest(requestClient, request);
  309.         postProcess(result);
  310.         
  311.         System.out.println("end of main()");
  312.     }
  313. }
at
Labels: , ,

1 則留言:

Richard Alwin 提到...

This post gave me a lot of information on this topic. Keep it up and keep sharing this type of information with us. Try to explore our services towards digital transformation.

Data Analytics Solutions

Data Engineering Solutions

Artificial Intelligence (AI) Solutions

2021年10月5日 下午4:44

張貼留言

訂閱： 張貼留言 (Atom)