Source code DBDataSource di SQLIte Database dengan Android

package com.example.contohentridatabase;

//Author :midasoft.blogspot.com

import java.util.ArrayList;

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;

public class DBDataSourceMob {

      //inisialiasi SQLite Database    

      private SQLiteDatabase database;

       

    //inisialisasi kelas DBHelper   

      private DBHelperMob dbHelper;

 

    //ambil semua nama kolom    

      private String[] allColumns = { DBHelperMob.COLUMN_ID,

     DBHelperMob.COLUMN_NAME, DBHelperMob.COLUMN_MERK,DBHelperMob.COLUMN_HARGA};

 

   

      //DBHelper diinstantiasi pada constructor   

      public  DBDataSourceMob(Context context)

    {

        dbHelper = new DBHelperMob(context);

    }

 

    //membuka/membuat sambungan baru ke database    

      public void open() throws SQLException {

        database = dbHelper.getWritableDatabase();

    }

 

    //menutup sambungan ke database    

      public void close() {

        dbHelper.close();

    }

 

    //method untuk create/insert barang ke database   

      public Barang createBarang(String nama, String merk, String harga) {

    // membuat sebuah ContentValues, yang berfungsi       

    

            ContentValues values = new ContentValues();

        values.put(DBHelperMob.COLUMN_NAME, nama);

        values.put(DBHelperMob.COLUMN_MERK, merk);

        values.put(DBHelperMob.COLUMN_HARGA, harga);

 

        // mengeksekusi perintah SQL insert data       

        // yang akan mengembalikan sebuah

          long insertId = database.insert(DBHelperMob.TABLE_NAME, null,

            values);

 

        // setelah data dimasukkan, memanggil       

        // perintah SQL Select menggunakan Cursor untuk       

                

          Cursor cursor = database.query(DBHelperMob.TABLE_NAME,

            allColumns, DBHelperMob.COLUMN_ID + " = " + insertId, null,

            null, null, null);

           

        // pindah ke data paling pertama      

            cursor.moveToFirst();

 

        // mengubah objek pada kursor pertama tadi      

            

            Barang newBarang = cursorToBarang(cursor);

 

        // close cursor       

            cursor.close();

 

        // mengembalikan barang baru        

            return newBarang;

      }

 

    private Barang cursorToBarang(Cursor cursor) 

    {

        // buat objek barang baru      

      Barang barang = new Barang();

        // debug LOGCAT       

      Log.v("info", "The getLONG "+cursor.getLong(0));

        Log.v("info", "The setLatLng "+cursor.getString(1)+","+cursor.getString(2));

 

       // * data kursor yang diambil dari database*/

        barang.setId(cursor.getLong(0));

        barang.setNama_barang(cursor.getString(1));

        barang.setMerk_barang(cursor.getString(2));

        barang.setHarga_barang(cursor.getString(3));

       

      //kembalikan sebagai objek barang       

        return barang;

    }

 

    //mengambil semua data barang   

    public ArrayList<Barang> getAllBarang() {

    ArrayList<Barang> daftarBarang = new ArrayList<Barang>();

 

        // select all SQL query        

        Cursor cursor = database.query(DBHelperMob.TABLE_NAME,

            allColumns, null, null, null, null, null);

 

        // pindah ke data paling pertama        

        cursor.moveToFirst();

        // jika masih ada data, masukkan data barang ke     

        // daftar barang     

        while (!cursor.isAfterLast()) {

          Barang barang = cursorToBarang(cursor);

          daftarBarang.add(barang);

          cursor.moveToNext();

       

        // Make sure to close the cursor        

                   cursor.close();

                   return daftarBarang;    

             }

            return daftarBarang;

    }

}