Sabtu, 27 Mei 2017

Database pada Java

Database 

CobaDatabase.java

package Pertemuan6;

import javax.swing.plaf.nimbus.State;
import java.sql.*;
import java.util.HashMap;

public class CobaDatabase {
    private static final String DB_NAME = "dbcs_1";
    private static final String DB_USERNAME = "root";
    private static final String DB_PASSWORD = "";

    private Connection connection;

    public CobaDatabase() throws SQLException {
        this.connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/" + DB_NAME, DB_USERNAME, DB_PASSWORD);
    }

    public void select(String tableName, String[] column) {
        try {
            Statement statement = this.connection.createStatement();

            String query = "SELECT ";
            for (int i = 0; i < column.length; i++) {
                query += column[i];
                if (i != column.length - 1)
                    query += ",";
            }

            query += " FROM " + tableName;

            ResultSet result = statement.executeQuery(query);
            this.print(result);

            result.close();
            statement.close();
        } catch(SQLException e) {
            System.out.println("Error : " + e.getMessage());
        }
    }

    public void update(String tableName, String set, String where) {
        try {
            Statement statement = this.connection.createStatement();

            String query = "UPDATE " + tableName + " SET " + set;

            if (where != null)
                query += " WHERE " + where;
//            System.out.println(query);            if (statement.executeUpdate(query) > 0)
                System.out.println("Successfully updated database");
        } catch (SQLException e) {
            System.out.println("Error : " + e.getMessage());
        }
    }
    public void print(ResultSet result) throws SQLException {

        // Ambil daftar kolom dari hasil        String[] resColumn = new String[result.getMetaData().getColumnCount()];
        for (int i = 1; i <= result.getMetaData().getColumnCount(); i++) {
            resColumn[i - 1] = result.getMetaData().getColumnLabel(i);
        }

        while (result.next()) {
            for (int i = 0; i < resColumn.length; i++)
                System.out.println(resColumn[i] + " : " + result.getString(resColumn[i]));
        }
    }

    public static void main(String[] args) {

        try {
            CobaDatabase database = new CobaDatabase();
            database.select("mahasiswa", new String[]{"nim", "nama", "jenis_kelamin as \"Jenis Kelamin\"",
                    "IF(kewarganegaraan = 'I', 'Warga Negara Indonesia', 'Warga Negara Asing') as Kewarganegaraan"});
            database.update("mahasiswa", "namat = \"MAMAK\"", "nim = '140101002'");
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

}

Tidak ada komentar:

Posting Komentar

Thread dan Socket

Thread Thread adalah rangkaian eksekusi dari sebuah aplikasi java dan setiap program java minimal memiliki satu buah thread. Sebuah thre...