원본출처: 티스토리 바로가기
이전 포스팅에서 제주버스의 정보를 수집했다.
https://billcorea.tistory.com/111
이제 그 정보를 나의 앱에 넣는 작업을 해 봐야겠다. 일단은 데이터를 저장할 table 을 구성해 보았다. 뭐 말그대로 앞전 포스팅에서 작성한 class 중에서 item 이 들어 있는 class 구조를 그대로 적용해 보면 될 것 같다.
import android.content.Context; import android.database.sqlite.SQLiteDatabase; import android.database.sqlite.SQLiteOpenHelper; import android.util.Log; public class DBHelper extends SQLiteOpenHelper { private static final String DB_NAME = "opdGangDB"; private static final int DB_Ver = 4; private static final String TAG = "DBHelper"; public DBHelper(Context context) { super(context, DB_NAME, null, DB_Ver); } /** * aClassCode, bClassCode, cClassCode : 코드 분류 1,2,3 차 * cntData : 위치별-상호별 중복 건수 * infoData : 상세 정보 y,x,place_name 으로 cntData 와 연계 * @param db */ @Override public void onCreate(SQLiteDatabase db) { StringBuffer sb = new StringBuffer(); sb.append("create table ClassCode"); sb.append("( _id integer primary key autoincrement, "); sb.append(" classNameA text, "); sb.append(" classNameB text, "); sb.append(" classNameC text "); sb.append(" ) "); db.execSQL(sb.toString()); sb = new StringBuffer(); sb.append("create table cntData"); sb.append("( _id integer primary key autoincrement, "); sb.append(" y text, "); sb.append(" x text, "); sb.append(" place_name text, "); sb.append(" atCnt number "); sb.append(" ) "); db.execSQL(sb.toString()); sb = new StringBuffer(); sb.append("create table infoData"); sb.append("( _id integer primary key autoincrement, "); sb.append(" y text, "); sb.append(" x text, "); sb.append(" address_name text, "); sb.append(" category_group_code text, "); sb.append(" category_group_name text, "); sb.append(" category_name text, "); sb.append(" distance text, "); sb.append(" id text, "); sb.append(" phone text, "); sb.append(" place_name text, "); sb.append(" place_url text, "); sb.append(" road_address_name text, "); sb.append(" url text, "); sb.append(" regTime text, "); sb.append(" likeCnt text, "); sb.append(" unlikeCnt text "); sb.append(" ) "); db.execSQL(sb.toString()); /** * 제주 버스 정류소 정보 수집 2021.12.20 ~ */ sb = new StringBuffer(); sb.append("create table stationItem "); sb.append("( _id integer primary key autoincrement, "); sb.append(" dirTp text, "); sb.append(" govNm text, "); sb.append(" localX real, "); sb.append(" localY real, "); sb.append(" mobiNum text, "); sb.append(" stationId text, "); sb.append(" stationNm text, "); sb.append(" upd text, "); sb.append(" useYn text "); sb.append(" ) "); db.execSQL(sb.toString()); } /** * @param db * @param oldVersion * @param newVersion */ @Override public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) { StringBuffer sb = new StringBuffer(); Log.e(TAG, "newVersion=" + newVersion) ; switch (newVersion) { case 4: sb = new StringBuffer(); sb.append("create table stationItem "); sb.append("( _id integer primary key autoincrement, "); sb.append(" dirTp text, "); sb.append(" govNm text, "); sb.append(" localX real, "); sb.append(" localY real, "); sb.append(" mobiNum text, "); sb.append(" stationId text, "); sb.append(" stationNm text, "); sb.append(" upd text, "); sb.append(" useYn text "); sb.append(" ) "); db.execSQL(sb.toString()); break; case 3: db.execSQL("alter table infoData add column likeCnt text "); db.execSQL("alter table infoData add column unlikeCnt text "); break; } } }sqlite 에서 데이터를 구성해 앱을 만들다 보면 나중에 추가 하거나 구조를 변경 하게 되는 경우가 있는데, 그 때 마다 data을 다 지우고 다시 만들면 사용자도 힘들고, 개발자도 힘들고 ... 그래서 db을 생성할 때 버전에 따라서 변하게 하는 것이 좋을 듯 하다. 그러면 이전 앱을 설치한 사용자도 upgrade 되면 새로 데이터를 넣지 않아도 되기 때문이다.
이 앱은 벌써 데이터 구조를 3, 4 버전까지 늘렸다. 2 버전은 어디 갔는 지 모르겠지만... (사실은 한번 잘못 빌드를 했다가.. 실폐를 해서 ) 아무튼 새로 버전을 받더라도 사용자는 아무런 의심 없이 사용하게 될 것이다.
이번에는 이 데이터를 불러서 사용할 것들을 정리해 봐야겠다.
import android.content.ContentValues; import android.content.Context; import android.database.Cursor; import android.database.SQLException; import android.database.sqlite.SQLiteDatabase; import android.util.Log; import com.billcoreatech.opdgang1127.JejuBusInfo.StationItemBean; import com.billcoreatech.opdgang1127.JejuFD6.JejuFD6infoBean; import com.billcoreatech.opdgang1127.Utils.StringUtils; public class DBHandler extends RuntimeException { DBHelper helper ; SQLiteDatabase db ; String TAG = "DBHandler"; public DBHandler(Context context) { helper = new DBHelper(context) ; db = helper.getWritableDatabase() ; } public static DBHandler open (Context ctx) throws SQLException { DBHandler handler = new DBHandler(ctx) ; return handler ; } public void close() { helper.close(); } ... /** * 제주 버스 정류소 정보 2021.12.20 ~ * @param station * @return */ public long appendBusStation(StationItemBean station) { long result = 0 ; Cursor rs = selectBusStation(station.getStationId()); if (rs.moveToNext()) { result = updateBusStation(station); } else { result = insertBusStation(station); } rs.close(); return result ; } /** * 제주 버스 정류소 정보 2021.12.20 ~ * @param busStation * @return */ public Cursor selectBusStation(String busStation) { StringBuffer sb = new StringBuffer(); sb.append("select * from stationItem "); if (!"".equals(busStation)) { sb.append(" where stationId = '" + busStation.trim() + "' "); } return db.rawQuery(sb.toString(), null); } /** * 주변 정류소 찾기 * @param x : 경도 * @param y : 위도 * @param roundValue : 주변범위 m * @return */ public Cursor selectBusStationArea(double x, double y, int roundValue) { double x1 = x - StringUtils.LongitudeInDifference(y, roundValue); double x2 = x + StringUtils.LongitudeInDifference(y, roundValue); double y1 = y - StringUtils.LatitudeInDifference(roundValue) ; double y2 = y + StringUtils.LatitudeInDifference(roundValue) ; StringBuffer sb = new StringBuffer(); sb.append("select * from stationItem "); sb.append(" where (localX >= " + x1 + " and localX <= " + x2 + ") "); sb.append(" and (localY >= " + y1 + " and localY <= " + y2 + ") "); sb.append(" and useYn = 'Y' "); Log.e(TAG, sb.toString()); return db.rawQuery(sb.toString(), null); } /** * 제주 버스 정류소 정보 2021.12.20 ~ * @param station * @return */ public long insertBusStation(StationItemBean station) { ContentValues values = new ContentValues(); values.put("dirTp", station.getDirTp()); values.put("govNm", station.getGovNm()); values.put("localX", station.getLocalX()); values.put("localY", station.getLocalY()); values.put("mobiNum", station.getMobiNum()); values.put("stationId", station.getStationId()); values.put("stationNM", station.getStationNm()); values.put("upd", station.getUpd()) ; values.put("useYn", station.getUseYn()) ; return db.insert("stationItem", null, values) ; } /** * 제주 버스 정류소 정보 2021.12.20 ~ * @param station * @return */ public long updateBusStation(StationItemBean station) { ContentValues values = new ContentValues(); values.put("dirTp", station.getDirTp()); values.put("govNm", station.getGovNm()); values.put("localX", station.getLocalX()); values.put("localY", station.getLocalY()); values.put("mobiNum", station.getMobiNum()); values.put("stationNM", station.getStationNm()); values.put("upd", station.getUpd()) ; values.put("useYn", station.getUseYn()) ; return db.update("stationItem", values, "stationId = '" + station.getStationId() + "' ", null) ; } }이렇게 insert, update, select 을 구성했고, append 도 추가 했다. append 는 새로 데이터를 받아온 다음 그것을 저장하기 위해서,
이제 데이터를 받아와서 저장하는 구현을 해 봐야지.
@Override public boolean onOptionsItemSelected(@NonNull MenuItem item) { switch (item.getItemId()) { case R.id.actionGetBusStation: fd6Binding = Updatejejufd6infoViewBinding.inflate(getLayoutInflater()); fd6Binding.adView.loadAd(adRequest); AlertDialog.Builder builder1 = new AlertDialog.Builder(MainActivity.this, R.style.ThemeDialog) .setTitle(getString(R.string.titleUpdateBusStation) + "(last:" + sp.getString("lastUpdateBusStation", "1970-01-01") + ")") .setView(fd6Binding.getRoot()) .setPositiveButton(getString(R.string.OK), new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialogInterface, int i) { doGetBusStation(); } }) .setNegativeButton(getString(R.string.CLOSE), new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialogInterface, int i) { } }); AlertDialog dialog1 = builder1.create(); dialog1.show(); break; } return super.onOptionsItemSelected(item); }option menu 를 선택 하면 아래 처럼 데이터를 수신 받고 그것을 이용해서 저장하는 for 문을 구성 하였다.
/** * 2021.12.20 제주 버스 정류소 정보 수집 기능 추가 */ private void doGetBusStation() { binding.baseProgressBar.setVisibility(View.VISIBLE); retrofit = new Retrofit.Builder() .baseUrl(RetrofitApi.baseURL) .client(new OkHttpClient()) .addConverterFactory(SimpleXmlConverterFactory.create()) .build(); service = retrofit.create(RetrofitApi.class); String lastUpdateDate = sp.getString("lastUpdateBusStation", "1970-01-01"); service.getStationInfo(lastUpdateDate).enqueue(new Callback<StationBean>() { @Override public void onResponse(Call<StationBean> call, Response<StationBean> response) { Log.e(TAG, "response=" + response.code() + " Total=" + response.body().getBodyClass().getTotalCount() + "\n" + response.message()); if (!"0".equals(response.body().getBodyClass().getTotalCount())) { dbHandler = DBHandler.open(getApplicationContext()); for (StationItemBean item : response.body().getBodyClass().getItems()) { Log.e(TAG, item.getStationNm()); long cnt = dbHandler.appendBusStation(item); Log.e(TAG, cnt + " " + item.getStationNm()); } dbHandler.close(); editor = sp.edit(); editor.putString("lastUpdateBusStation", StringUtils.getToday()); editor.commit(); } binding.baseProgressBar.setVisibility(View.GONE); } @Override public void onFailure(Call<StationBean> call, Throwable t) { Log.e(TAG, "ERROR=" + t.toString()) ; } }); }저번과 달라진 부분은 service 호출할 때 최종 변경일자를 구해서 전달하도록 수정한 부분이다. 그래서 retrofit api 에서도 다음과 같이 날자를 받아서 파라미터로 전달 하도록 구성을 변경 하였다.
import retrofit2.Call; import retrofit2.http.GET; import retrofit2.http.Query; public interface RetrofitApi { String baseURL = "http://busopen.jeju.go.kr"; String getStation = "/OpenAPI/service/bis/Station"; @GET(getStation) Call<StationBean> getStationInfo(@Query(value="last") String lastUpdate); }이렇게 하면 저번 포스팅에서 보았던 제주버스api 에 최종 변경된 정보만 수집하는 모양으로 작업을 할 수 있다.
이제 가져온 데이터가 앱에서 어떻게 활용이 되는 지 잠시 보도록 하겠다.
이렇게 앱에 버스 정류소를 표시할 수 있는 자료가 만들어 졌다. 다음은 뭐 해야하지 ? 내가 있는 위치에서 저 버스 정류소까지 가는 방법을 연구해 보아야 겠다.
그럼 오늘도 즐~ 코딩...
댓글
댓글 쓰기