Mysql
 sql >> Teknologi Basis Data >  >> RDS >> Mysql

Bagaimana cara memperbaiki com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException:Tidak ada operasi yang diizinkan setelah koneksi ditutup. pengecualian?

Apakah Anda menyadari fakta bahwa Anda sebenarnya mengakses backend dari dalam GUI Anda? Anda meneruskan parameter dari bidang teks langsung ke database Anda. Ini adalah sumber untuk fuckups besar. Setidaknya validasi masukan Anda, atau Meja Bobby Kecil akan mengakhiri kontrak kerja Anda sebelum waktunya.

Mengenai kesalahan Anda:Maaf, tetapi kode ini membutuhkan refactoring besar. Sendirian, hitungan baris kode ini terlalu banyak. Aturan emas pertama:Jaga agar metode Anda tetap singkat. Aturan emas kedua:Buat lebih pendek.

Fakta bahwa Anda sendiri tidak mengerti apa yang sedang terjadi adalah lampu merah besar bagi Anda dan menunjukkan bahwa Anda perlu mempertimbangkan kembali desain Anda.

  • Buat metode yang menulis sesuatu dengan JDBC.putData() mandiri.
  • Lakukan hal yang sama dengan JDBC.getData().
  • Lihat pola yang muncul.

Saya kira ini adalah panggilan prematur ke connection.close() di JDBC. Dengan mengelompokkan operasi Anda ke operasi yang lebih atomik, Anda dapat menalar tentang kode Anda dengan lebih baik, sehingga memahami kesalahan yang ada.

Maaf karena tidak memberikan solusi, tetapi dalam jangka panjang Anda lebih baik dengan mengikuti beberapa prinsip kode. Pelajari mereka! Lebih cepat lebih baik dan karena saya membutuhkan lebih banyak karma:Baca "Clean-Code" oleh Robert C. Martin.http://www.amazon.de/Clean-Code-Handbook-Software-Craftsmanship/dp/0132350882

Anda kemudian akan berada di jalan pencerahan dan dengan demikian menggunakan DAOFactory (petunjuk) dan pola desain DAO (juga petunjuk) dan menjadi dewa pembuat kode. Selamat!

Nah, inilah sedikit panduan tentang bagaimana refactoring bisa terlihat. Belum selesai dan belum diuji, dan saya kira saya mengacaukan urutan penyisipan SQL (tidak tahu transactionId mana yang digunakan di mana). Tapi saya harap Anda akan mendapatkan ide. Semoga hari Anda menyenangkan dan selamat datang di Jamaika!

package mysqlfix;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Date;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.JTextField;

public class JDBC {

    static Connection con = null;
    static boolean b;
    static PreparedStatement state;

    public static void setCon() {
        try {
            Class.forName("com.mysql.jdbc.Driver");
            con = DriverManager.getConnection("jdbc:mysql://localhost:3306/lottery", "root", "123");
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    public static Connection getCon() throws Exception {
        if (con == null) {
            setCon();
        }
        return con;
    }

    public static boolean putData(String sql) {
        try {
            getCon().setAutoCommit(false);
            state = getCon().prepareStatement(sql);
            state.executeUpdate();
            getCon().commit();
            b = true;
        } catch (Exception e) {
            e.printStackTrace();
            b = false;
        }
        return b;
    }

// connection commit
    public static void commit() {
        try {
            con.commit();
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

    // rollback data
    public static void rollback() {
        if (con != null) {
            try {
                con.rollback();
            } catch (SQLException ex) {
                Logger.getLogger(JDBC.class.getName()).log(Level.SEVERE, null, ex);
            }
        }
    }

// close statement
    public static void putClose() {
        try {
            state.close();
        } catch (SQLException ex) {
            Logger.getLogger(JDBC.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
    // close connection

    public static void conClose() {
        try {
            con.setAutoCommit(true);
            con.close();
        } catch (SQLException ex) {
            Logger.getLogger(JDBC.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

// clear prepared statement
    public static void putClear() {
        try {
            if (state != null && !state.isClosed()) {
                state.close();
            }
        } catch (SQLException ex) {
            Logger.getLogger(JDBC.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

// clear the connection
    public static void conClear() {
        try {
            if (con != null && !con.isClosed()) {
                con.setAutoCommit(true);
                con.close();
            }
        } catch (SQLException ex) {
            Logger.getLogger(JDBC.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    public static ResultSet getData(String sql) throws Exception {
        Statement state = getCon().createStatement();
        ResultSet rs = state.executeQuery(sql);
        return rs;
    }

    public void saveTotal(JTextField txtGtotal, JTextField txtPTotal) {
        SuperDAO superDAO = new SuperDAO();

        if (superDAO.getMaxIdFromOrder() > 0) {
            Date date1;
            date1 = new Date();
            String txtGTotalFromTextField = txtGtotal.getText();
            String txtPTotalFromTextField = txtPTotal.getText();
            boolean b1 = false;
                    //regarding the transaction id...
            //this changes whilst updating the table transaction.

            int transactionId = -1;
            if (txtGTotalFromTextField.matches("[a-zA-Z]")) {
                transactionId = superDAO.insertOrderIntoTransaction(date1, txtGTotalFromTextField);
                //b1 = JDBC.putData("insert into transaction(tr_date, amount, tr_type) values ('" + date1 + "' , '" + txtGTotalFromTextField + "' , 'order')");
            }
            if (transactionId > 0) {
                try {
                } catch (Exception ex) {
                    Logger.getLogger(JDBC.class.getName()).log(Level.SEVERE, null, ex);
                }
                if (txtPTotalFromTextField.matches("[a-zA-Z]")) {
                    transactionId = superDAO.insertProfitIntoTransaction(date1, txtGTotalFromTextField);
                }
                JDBC.putData("insert into o_de(or_id, tr_id, oday, gtotal) values ('" + superDAO.getMaxIdFromOrder() + "' , '" + transactionId + "','" + date1 + "','" + txtGtotal.getText() + "' )");
                JDBC.putData("insert into order_profit(or_id, tr_id, ptotal) values ('" + superDAO.getMaxIdFromOrder() + "' , '" + transactionId + "','" + txtPTotal.getText() + "' )");

                                                        //JDBC.commit();
                //JOptionPane.showMessageDialog(null, "Order Saved Sucessfully..");
                JDBC.putClose();
                JDBC.conClose();

            }

        }

    }

}



package mysqlfix;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Date;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author edm
 */
public class SuperDAO {

    Connection conn;

    public SuperDAO() {
        try {
            this.conn = JDBC.getCon();
        } catch (Exception ex) {
            Logger.getLogger(SuperDAO.class.getName()).log(Level.SEVERE, null, ex);
        }
    }

    public int getMaxIdFromOrder() {

        try {
            ResultSet rs = JDBC.getData("select MAX(or_id) as or_id from `order`");
            if (rs.first()) {

                return rs.getInt("or_id");
            }
        } catch (SQLException ex) {
            Logger.getLogger(SuperDAO.class.getName()).log(Level.SEVERE, null, ex);
        } catch (Exception ex) {
            Logger.getLogger(SuperDAO.class.getName()).log(Level.SEVERE, null, ex);
        }
        return -1;
    }

    public int getMaxIdFromTransaction() {
        ResultSet rs;
        try {
            rs = JDBC.getData("select MAX(tr_id) as tr_id from transaction");
            if (rs.first()) {
            return rs.getInt("tr_id");
        }
        } catch (Exception ex) {
            Logger.getLogger(SuperDAO.class.getName()).log(Level.SEVERE, null, ex);
        }
        return -1;
    }


    public int insertOrderIntoTransaction(Date date, String text) {
        JDBC.putData("insert into transaction(tr_date, amount, tr_type) values ('" + date + "' , '" + text + "' , 'order')");
        return getMaxIdFromTransaction();
    }

     public int insertProfitIntoTransaction(Date date, String text) {
        JDBC.putData("insert into transaction(tr_date, amount, tr_type) values ('" + date + "' , '" + text + "' , 'profit')"); 

        return getMaxIdFromTransaction();
    }



}

Tentu perjalanan tidak berhenti sampai di situ. Saya tidak menyelesaikan JDBC saveTotal(). Saya baru saja memulainya, Anda yang membuat sisanya.

Harap dicatat bahwa saya tidak menguji kode ini terhadap database (file sql ddl tertentu tidak ada). Juga, saya tidak menggunakan mekanisme rollback. Selanjutnya, saveTotal() tinggal di JDBC, di tempat yang bukan miliknya. Gunakan saveTotal di GUI Anda (jika perlu) dan biarkan semua akses database mengalir melalui SuperDAO. Ini bukan desain terbaik tetapi tidak terlalu abstrak dan Anda dapat dengan mudah melihat bagaimana pemisahan perhatian membuat kode Anda sedikit lebih mudah dibaca dan dipelihara.




  1. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. Pemula Java membutuhkan bantuan dalam koneksi database

  2. Bagaimana cara menghasilkan tampilan pohon dari kumpulan hasil ini berdasarkan Algoritma Traversal Pohon?

  3. Ambil fungsi array menggandakan nilai di setiap posisi array?

  4. Kapan saya harus menggunakan indeks komposit?

  5. cara menghitung total komentar