温馨提示×

java中怎么使用swing连接数据库

小亿
161
2023-08-25 09:24:10
栏目: 编程语言

在Java中使用Swing连接数据库,需要借助JDBC(Java Database Connectivity)技术。以下是一个简单的例子,演示了如何使用Swing和JDBC连接MySQL数据库:

1. 导入必要的包:
```java
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
import java.sql.*;
```

2. 创建Swing界面:
```java
public class DatabaseConnection extends JFrame {
   private JTextField tfName;
   private JTextArea taResult;
   private JButton btnConnect;

   public DatabaseConnection() {
       // 设置窗口标题
       super("Database Connection");
       
       // 创建组件
       tfName = new JTextField(20);
       taResult = new JTextArea();
       btnConnect = new JButton("Connect");
       
       // 添加事件监听器
       btnConnect.addActionListener(new ActionListener() {
           @Override
           public void actionPerformed(ActionEvent e) {
               connectToDatabase();
           }
       });
       
       // 创建面板并添加组件
       JPanel panel = new JPanel();
       panel.add(new JLabel("Name:"));
       panel.add(tfName);
       panel.add(btnConnect);
       
       // 设置文本区域属性
       taResult.setEditable(false);
       taResult.setLineWrap(true);
       
       // 添加组件到窗口
       Container container = getContentPane();
       container.setLayout(new BorderLayout());
       container.add(panel, BorderLayout.NORTH);
       container.add(new JScrollPane(taResult), BorderLayout.CENTER);
       
       // 设置窗口大小和可见性
       setSize(400, 300);
       setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
       setVisible(true);
   }

   private void connectToDatabase() {
       // 获取用户名
       String name = tfName.getText();
       
       // 连接数据库
       try {
           // 加载数据库驱动
           Class.forName("com.mysql.jdbc.Driver");
           
           // 创建连接
           Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydatabase", "username", "password");
           
           // 执行查询
           Statement stmt = con.createStatement();
           ResultSet rs = stmt.executeQuery("SELECT * FROM users WHERE name = '" + name + "'");
           
           // 处理结果集
           while (rs.next()) {
               int id = rs.getInt("id");
               String resultName = rs.getString("name");
               String email = rs.getString("email");
               taResult.append("ID: " + id + ", Name: " + resultName + ", Email: " + email + "\n");
           }
           
           // 关闭连接
           rs.close();
           stmt.close();
           con.close();
       } catch (Exception e) {
           e.printStackTrace();
       }
   }

   public static void main(String[] args) {
       new DatabaseConnection();
   }
}
```

在上述代码中,通过JDBC加载MySQL数据库驱动,使用`DriverManager.getConnection()`方法连接数据库,然后使用查询语句执行查询,并处理结果集。最后关闭连接。

注意:上述代码中的数据库连接字符串(`jdbc:mysql://localhost:3306/mydatabase`)需要根据实际情况进行修改,以及数据库用户名和密码(`"username", "password"`)。

0