کلاس ارتباط با دیتا بیس در جاوا

کلاس ارتباط با دیتا بیس در جاوا

package db;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

/**
 *
 * @author mpira
 */
public class database {

    public static String message = null;

    public static Connection dboloc() {
        String dbatbas = "dbname";
        String udbatbas = "dbuser";
        String pdbatbas = "dbpass";
        Connection con = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            con = (Connection) DriverManager.getConnection("jdbc:mysql://localhost:3306/" + dbatbas + "?useUnicode=true&characterEncoding=utf-8", udbatbas, pdbatbas);
        } catch (Exception e) {
            System.out.println(e.toString());
        }
        return con;
    }

    public static void update(String table, String id, String dbf[], String dbv[],Connection con) {
        try {

            message += ("driver loaded" + "\n");
            message += ("Connection created" + "\n");
            String dbfild = "";
            for (int i = 0; i < dbf.length; i++) {
                if (i != (dbf.length - 1)) {
                    dbfild += ("`" + dbf[i] + "`='" + dbv[i] + "',");
                } else {
                    dbfild += ("`" + dbf[i] + "`='" + dbv[i] + "'");
                }
            }
            PreparedStatement ps = ((java.sql.Connection) con).prepareStatement("UPDATE `" + table + "` SET " + dbfild + "  WHERE "+id);
            ps.execute();
            System.out.println("UPDATED");
            con = null;
        } catch (Exception e1) {
            message += e1.toString();
        }
    }

    public static String id_ret(String table, String fa, String va, String fb, Connection connection) {
        String q = null;

        try {
            Statement stmt = connection.createStatement();
            String query = "select * from `" + table + "` WHERE `" + fa + "`='" + va + "'";
            //person is the table name
            ResultSet rs = stmt.executeQuery(query);

            while (rs.next()) {
                q = rs.getString(fb);
            }
            return q;
        } catch (SQLException e) {
            e.printStackTrace();
            for (Throwable ex : e) {
                System.err.println("Error occurred " + ex);
            }
            System.out.println("Error in fetching data");
        }

        return q;
    }
    public static void delet(String table, String sh, Connection con) {
        try {
            PreparedStatement ps = ((java.sql.Connection) con).prepareStatement("DELETE FROM `" + table + "` WHERE " + sh);
            ps.execute();
            System.out.println("DELETED");
            con = null;
        } catch (Exception e1) {
            System.out.println(e1.toString());
        }
    }

    public static void insert(String table, String dbf[], String dbv[], Connection con) {
        try {
            String dbfild = "";
            String q = "";
            for (int i = 0; i < dbf.length; i++) {
                if (i != (dbf.length - 1)) {
                    dbfild += ("`" + dbf[i] + "`,");
                    q += "?,";
                } else {
                    dbfild += ("`" + dbf[i] + "`");
                    q += "?";
                }
            }
            PreparedStatement ps = ((java.sql.Connection) con).prepareStatement("INSERT INTO `" + table + "`(" + dbfild + ") VALUES (" + q + ")");
            for (int i = 0; i < dbv.length; i++) {
                ps.setString((i + 1), dbv[i]);
            }
            ps.execute();
            System.out.println("Inserted");
            con = null;
        } catch (Exception e1) {
            System.out.println(e1.toString());
        }
    }

    public static boolean ch_va(String table, String fa, String va, Connection connection) {
        //System.out.println("-------- MySQL JDBC Connection Testing ------------");
        try {
            Statement stmt = connection.createStatement();
            String query = "select * from `" + table + "` WHERE `" + fa + "`='" + va + "'";
            //person is the table name
            ResultSet rs = stmt.executeQuery(query);
            int q = 0;
            while (rs.next()) {
                q++;
            }
            if (q <= 0) {
                return false;
            } else {
                return true;
            }
        } catch (SQLException e) {
            e.printStackTrace();
            for (Throwable ex : e) {
                System.err.println("Error occurred " + ex);
            }
            System.out.println("Error in fetching data");
        }
        return false;
    }
}