当前位置: 首页 > 知识库问答 >
问题:

无法使用javaFX连接到在线mysql数据库

佘单鹗
2023-03-14

我最近做了一个项目,涉及使用java中的Swing在线连接到mysql数据库。然后我决定将项目转换为javaFX并尝试复制代码以连接到mysql数据库。

这是我的代码:

package virtlib;

import java.net.URL;
import java.util.ResourceBundle;
import javafx.event.ActionEvent;
import javafx.fxml.FXML;
import javafx.fxml.Initializable;
import javafx.scene.control.Button;
import javafx.scene.control.Label;
import javafx.scene.control.PasswordField;
import javafx.scene.control.TextField;
import java.sql.*;
import javafx.fxml.FXMLLoader;
import javafx.scene.Node;
import javafx.scene.Parent;
import javafx.scene.Scene;
import javafx.stage.Stage;


/**
 *
 * @author param
 */
public class FXMLDocumentController implements Initializable {
    private Connection con;
    private Statement st;
    private ResultSet rs;
     private ResultSet rs2;
    private Stage stage;
    @FXML
    private Label label;
    @FXML
    private Button login;
    @FXML
    private PasswordField password;
    @FXML
    private TextField username;
    
    @FXML
    private void handleButtonAction(ActionEvent event) {
     
        try{
            
            Class.forName("com.mysql.cj.jdbc.Driver");
            con=DriverManager.getConnection("jdbc:mysql://db4free.net:3306/parambase","theboss12k","Password");//Password has been changed
            st=con.createStatement();
            label.setText("Connection success !");
            
        }
        catch(Exception ae){
           label.setText("We are unable to connect to our servers. Please check your internet connection and restart the app !");
        }
        
    
    
    }
    @Override
    public void initialize(URL url, ResourceBundle rb) {
        // TODO
    }    
    
}

这是FXML文件的代码

<?xml version="1.0" encoding="UTF-8"?>

<?import javafx.scene.control.Button?>
<?import javafx.scene.control.Label?>
<?import javafx.scene.control.PasswordField?>
<?import javafx.scene.control.TextField?>
<?import javafx.scene.layout.AnchorPane?>
<?import javafx.scene.layout.Pane?>

<AnchorPane id="AnchorPane" prefHeight="494.0" prefWidth="409.0" xmlns:fx="http://javafx.com/fxml/1" xmlns="http://javafx.com/javafx/16" fx:controller="virtlib.FXMLDocumentController">
    <children>
        <Label fx:id="label" layoutX="126" layoutY="120" minHeight="16" minWidth="69" prefHeight="18.0" prefWidth="276.0" />
      <Pane maxHeight="1.7976931348623157E308" maxWidth="1.7976931348623157E308" prefHeight="297.0" prefWidth="410.0" style="-fx-background-color: white;" AnchorPane.bottomAnchor="0.0" AnchorPane.leftAnchor="0.0" AnchorPane.rightAnchor="0.0" AnchorPane.topAnchor="0.0">
         <children>
              <Button fx:id="login" layoutX="129.0" layoutY="331.0" onAction="#handleButtonAction" prefHeight="26.0" prefWidth="70.0" text="Login" />
            <PasswordField fx:id="password" layoutX="129.0" layoutY="276.0" maxHeight="1.7976931348623157E308" maxWidth="1.7976931348623157E308" prefHeight="26.0" prefWidth="222.0" />
            <TextField fx:id="username" layoutX="129.0" layoutY="229.0" maxHeight="1.7976931348623157E308" maxWidth="1.7976931348623157E308" prefHeight="26.0" prefWidth="222.0" />
            <Label layoutX="40.0" layoutY="280.0" text="Password" />
            <Label layoutX="38.0" layoutY="233.0" text="Username" />
            <Label layoutX="129.0" layoutY="400.0" prefHeight="17.0" prefWidth="222.0" textFill="#e70d1b" />
         </children>
      </Pane>
    </children>
</AnchorPane>


然而,当我点击运行时,它就崩溃了,我得到错误“JavaSE二进制平台已经停止工作”。它在我以前使用摆动的应用程序中工作得很好。切换到javafx时,我所做的唯一改变是我使用了jdk 1.8而不是jdk 11,因为我被迫使用netbean 8.2,而netbean 8.2似乎不支持jdk 11(我以前的项目就是使用它开发的)。

共有1个答案

郎宏浚
2023-03-14

我刚刚经历了同样的问题,并重写了我的SQL连接库。也许你可以在你的项目中使用它,它对我在本地和在线都有效。

我的HandleSqlBdSimple类:

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Vector;

public class HandleSqlDbSimple {

    private Connection connection = null;
    private Statement statement;
    private ResultSet resultSet;
    private boolean isConnected = false;

    // Creating objects for connection
    private String aHost;
    private String aPort;
    private String aDatabase;
    private String aUser;
    private String aPassword;
    private String aDriver;
    private String aPrefix;

    public HandleSqlDbSimple(String host, String port, String database, String user, String psw, String driver, String prefix){
        this.aHost = host;
        this.aPort = port;
        this.aDatabase = database;
        this.aUser = user;
        this.aPassword = psw;
        this.aDriver = driver;
        this.aPrefix = prefix;

        //      Connection example:
        //      aHost = "localhost";
        //      aPort = "3306";
        //      aDatabase = "testdb";
        //      aUser = "root";
        //      aPassword = "kungfu";
        //      aDriver = "com.mysql.jdbc.Driver";
        //      aPrefix = "jdbc:mysql:";
    }

    private synchronized void loadConnection(){

        try {
            Class.forName(aDriver);

            connection = DriverManager.getConnection(aPrefix + "//" + aHost + ":" + aPort + "/" + aDatabase +
                    "?user=" + aUser + "&password=" + aPassword);

            isConnected = true;

        } catch (ClassNotFoundException e) {
            isConnected=false;
            e.printStackTrace();
        } catch (SQLException e) {
            isConnected=false;
            e.printStackTrace();
        }

        if(isConnected){
            try {
                connection.setAutoCommit(false);
                statement = connection.createStatement();
                statement.setFetchSize(100000);
                System.out.println("Connection open!");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }else{
            System.out.println("Is not connected!");
        }
    }

    private synchronized void closeConnection(){
        if (isConnected) {
            try {
                if (resultSet != null){
                    resultSet.close();
                };
                statement.close();
                connection.close();
                System.out.println("Connection Closed!");
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
                System.out.println("My Error in connection close: " + e);
            }
        }
    }

    public boolean writeToDB(String stmt){
        boolean aResult = false;

        // Open the connection to the database
        loadConnection();

        try {
            if(isConnected){
                statement.executeUpdate(stmt);
                connection.commit();

                aResult = true;
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }

        // Close the DB again
        closeConnection();

        return aResult;
    }

    public String[][] readFromDB(String stmt) {
        String[][] data = null;
        Vector<String[]> aVectorBuffer = new Vector<String[]>();
        String[] colData = null;

        loadConnection();

        if(isConnected){

            try {
                resultSet = statement.executeQuery(stmt);
                ResultSetMetaData aResultSetMetaData = resultSet.getMetaData();

                // Get number of columns
                int aColCount = aResultSetMetaData.getColumnCount();
                colData = new String[aColCount];

                while (resultSet.next()) {

                    for(int col=0; col<aColCount; col++){

                        colData[col] = resultSet.getString(col+1);

                    }

                    aVectorBuffer.add(colData);
                    colData = new String[aColCount];
                }

                closeConnection();

            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }

        data = new String[aVectorBuffer.size()][colData.length];

        for(int row=0;row<aVectorBuffer.size(); row++){
            for(int col=0;col<colData.length; col++){

                data[row][col] = aVectorBuffer.get(row)[col];

            }
        }

        return data;
    }

}

记住要包括mysql。当然是jar文件。我使用“mysql-connector-java-8.0.26.jar”。但我看到你已经有这个了。

然后你可以用这样的方法。。

@FXML
    private void handleButtonAction(ActionEvent event) {
     
        HandleSqlDbSimple db = new HandleSqlDbSimple("host", "port", "database", "user", "psw", "driver", "prefix");
        
        db.writeToDB("your write statement");
        
        String[][] result = db.readFromDB("your read statement here");
        
    }

希望有帮助;)

 类似资料:
  • 我无法使用客户机SquirrelSQL连接到MySQL。我以前曾设法连接到Oracle和Derby,但这次,我不知道我做错了什么。 我已经在我的Mac上安装了MySQL,以下步骤: > 要确保安装安全,请执行以下操作: 要创建新数据库: 要知道数据库存储在哪里: 创建一个表 在我遵循这些步骤之后: MySQL安装在/usr/local/ceral/MySQL/5.6.17下 在SQuirreL中,

  • 我在Spring是全新的,在Spring Hibernate无法连接到我的MySQL数据库。我得到 请求处理失败;嵌套异常为:org.springframework.transaction.CanNotCreateTransactionException: 无法打开事务的JPA EntityManager;嵌套异常为javax.persistence.persistenceException:or

  • 当我在Postman中点击url(http://localhost:8080/pjt/samples)以获取json数据时,它显示以下错误。 1)pom.xml 2)模型: .________/\/'___()____\\\\(()_'_''/'\\\\\\\/))()))'___.__,////===================================================

  • 我创建了一个简单的类来测试与我的localhost数据库的通信,这是我用Mysql Workbench创建的。Mysql服务器正在运行。JDBC驱动程序被添加到我的项目的类路径中。 当我运行程序时,我得到以下异常: 线程“main”com.mysql.cj.jdbc.Exceptions.CommunicationsException异常:通信链接失败 最后一个成功发送到服务器的数据包是在0毫秒前

  • 我有数据存储在mysql数据库,我想把它拉到我的程序,这是使用javafx,但它不会工作。如果我用一些不使用javafx的基本类提取数据,它工作得很好。但是,使用javafx,我会得到以下错误消息。我该怎么做才能解决这个问题? 很抱歉这个问题太长了。

  • 我无法连接到MySQL数据库。它发生在更新MySQL和JDK之后。我添加了,但没有结果。这是我从eclipse中得到的一个例外: 不建议在没有服务器身份验证的情况下建立SSL连接。根据MySQL 5.5.45、5.6.26和5.7.6的要求,如果未设置explicit选项,默认情况下必须建立SSL连接。为了符合不使用SSL的现有应用程序,verifyServerCertificate属性设置为“f