Android Seoul OpenAPI example

안드로이드에서 서울 OpenAPI에 접속하여 가져온 데이터를 Sqlite 데이터베이스에 저장하는 예

서울안심먹거리 목록 중에서 50개 항목을 가져와서 데이터베이스에 저장하는 내용

res/layout/main.xml

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    android:id="@+id/linearLayout"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:orientation="vertical" >

    <ScrollView
        android:id="@+id/scrollView1"
        android:layout_width="match_parent"
        android:layout_height="wrap_content" >

            <TextView
                android:id="@+id/textView1"
                android:layout_width="match_parent"
                android:layout_height="wrap_content"
                android:text="분실물 검색" />

	</ScrollView>

</LinearLayout>

AndroidManifest.xml 파일 설정 <uses-permission android:name="android.permission.INTERNET"/>

MainActivity.java

package com.example.androidapp;
import java.io.*;
import java.net.*;
import java.util.*;

import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.DefaultHttpClient;
import org.xmlpull.v1.XmlPullParser;
import org.xmlpull.v1.XmlPullParserFactory;

import android.app.*;
import android.database.sqlite.SQLiteDatabase;
import android.os.*;
import android.util.*;
import android.widget.*;

public class MainActivity extends Activity {
	String auth_code = "개발자 인증 코드";

	TextView tv;
	Handler handler = new Handler();
	ArrayList<HashMap<String,String>> list;
	HashMap<String,String>map;
	DatabaseHelper dbHelper;
	SQLiteDatabase db;
	
    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        
        list = new ArrayList<HashMap<String,String>>();
        setContentView(R.layout.main);
        tv = (TextView) findViewById(R.id.textView1);

        new Thread() {
        	public void run() {
        		dbHelper = new DatabaseHelper(MainActivity.this, "SeoulPublic.db", null, 1);
        		dbHelper.setSrcData(getPublicData());
        		db = dbHelper.getReadableDatabase();
        	}
        }.start();
    }
    
    StringBuilder strBuilder = new StringBuilder();
    String typeName, ctfName, ctfAddr, ctfTel;
    private ArrayList<HashMap<String,String>> getPublicData() {
    	try{
    	    String service = URLEncoder.encode("서울안심먹거리 목록", "UTF-8");
    	    String strUrl = "http://openapi.seoul.go.kr:8088/xml/"+auth_code+"/"+service+"/1/50/";
    	    HttpClient httpClient = new DefaultHttpClient();
    	    HttpGet httpGet = new HttpGet(strUrl);
    	    HttpResponse response = httpClient.execute(httpGet);
    		
    	    InputStream is = response.getEntity().getContent();

    	    XmlPullParserFactory factory = XmlPullParserFactory.newInstance();
            factory.setNamespaceAware(true);
            XmlPullParser xpp = factory.newPullParser();
            xpp.setInput(is, "utf-8");
            
    	    while(xpp.getEventType()!=XmlPullParser.END_DOCUMENT){
    	        if(xpp.getEventType()==XmlPullParser.START_TAG){
    		    if(xpp.getName().equals("CTF_TYPE_NAME")){
    		        xpp.next(); // 텍스트로 이동
    		    	typeName = xpp.getText(); // 텍스트 가져옴
    		    	while(true) {
    		    	    xpp.next();	
    		    	    if(xpp.getEventType()==XmlPullParser.START_TAG && xpp.getName().equals("CTF_NAME")){
    		    	        xpp.next();
    		    		ctfName = xpp.getText();
    		    		break;
    		    	    }
    		    	 }
    		    	 while(true) {
    		    	     xpp.next();	
    		    	     if(xpp.getEventType()==XmlPullParser.START_TAG && xpp.getName().equals("CTF_ADDR")){
    		    		xpp.next();
    		    		ctfAddr = xpp.getText();
    		    		break;
    		    	     }
    		    	 }
    		    	 while(true) {
    		    	     xpp.next();	
    		    	     if(xpp.getEventType()==XmlPullParser.START_TAG && xpp.getName().equals("CTF_TEL")){
    		    		xpp.next();
    		    		ctfTel = xpp.getText()==null || xpp.getText().equals("") ? "" : xpp.getText();
    		    		break;
    		    	     }
    		    	 }
    		    	 map = new HashMap<String,String>();
    		    	 map.put("CTF_TYPE_NAME", typeName);
    		    	 map.put("CTF_NAME", ctfName);
    		    	 map.put("CTF_ADDR", ctfAddr);
    		    	 map.put("CTF_TEL", ctfTel);
    		    	 list.add(map);
    		    } // end of if(STF_TYPE_NAME)
    		} // end of if( START_TAG)
    	        xpp.next();
    	    } // end of while()
    	    return list;
    	}catch(Exception ex) {
    	    ex.printStackTrace();
    	    Log.e("접속오류", ex.toString());
    	}
    	return null;
    }

}

DatabaseHelper.java

package com.example.androidapp;

import java.util.*;

import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteDatabase.CursorFactory;
import android.database.sqlite.SQLiteOpenHelper;
import android.util.Log;

public class DatabaseHelper extends SQLiteOpenHelper {

	private final String TABLE_NAME = "SeoulSafeFoods";
	private ArrayList<HashMap<String,String>> list;
	
	public DatabaseHelper(Context context, String name, CursorFactory factory,	int version) {
		super(context, name, factory, version);
	}

	@Override
	public void onCreate(SQLiteDatabase db) {
		String sql = "drop table if exists "+TABLE_NAME;
		db.execSQL(sql);
		sql = "create table "+TABLE_NAME +
				" ( _id integer PRIMARY KEY autoincrement, " +
				"ctf_type_name text, " +
				"ctf_name text, " +
				"ctf_addr text, " +
				"ctf_tel text )";
		db.execSQL(sql);
		Log.d("테이블 생성", "테이블 생성에 성공했습니다");
		sql = "insert into "+TABLE_NAME +" ( " +
				"ctf_type_name, ctf_name, ctf_addr, ctf_tel " +
				" )" +
				"values ( ?, ?, ?, ? )";
		String[] bindArgs = null;
		for(int i=0;i<list.size();i++) {
			bindArgs = new String[] { 
					list.get(i).get("CTF_TYPE_NAME"),
					list.get(i).get("CTF_NAME"),
					list.get(i).get("CTF_ADDR"),
					list.get(i).get("CTF_TEL")
			};
			db.execSQL(sql, bindArgs);
		}
		Log.d("데이터입력 성공", "먹거리 정보 저장 성공");
	}

	@Override
	public void onOpen(SQLiteDatabase db) {
		super.onOpen(db);
		Log.d("데이터베이스 열기", "성공");
	}
	
	@Override
	public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
		if(newVersion > 1) {
			db.execSQL("drop table if exists "+TABLE_NAME);
			onCreate(db);
		}
	}

	public void setSrcData(ArrayList<HashMap<String,String>> list) {
		this.list = list;
	}
}