java增删改查 连接数据库
作者：互联网
java增删改查 连接数据库
import javax.swing.*;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.sql.*;
public class 乘客管理 extends JPanel {
JButton chaxunJButton =new JButton("查询");
JButton xiugaiJButton =new JButton("修改");
JButton zengjiaJButton =new JButton("添加乘客");
JButton liulanJButton =new JButton("浏览");
JButton shanchuJButton =new JButton("注销");
public 乘客管理()
{
add(chaxunJButton);
add(xiugaiJButton);
add(zengjiaJButton);
add(liulanJButton);
add(shanchuJButton);
setVisible(true);
chaxunJButton.addActionListener(new chaxunListen());
zengjiaJButton.addActionListener(new zengjiaListen());
xiugaiJButton.addActionListener(new xiugaiListen());
liulanJButton.addActionListener(new liulanListen());
shanchuJButton.addActionListener(new shanchuListen());
}
//查询乘客按钮实现打开查询乘客页面的功能
class chaxunListen implements ActionListener
{
public void actionPerformed(ActionEvent e){
new 乘客查询();
}
}
//增加乘客按钮实现打开增加乘客页面的功能
class zengjiaListen implements ActionListener
{
public void actionPerformed(ActionEvent e){
new 乘客增加();
}
}
//修改乘客按钮实现打开修改乘客页面的功能
class xiugaiListen implements ActionListener
{
public void actionPerformed(ActionEvent e){
new 乘客修改();
}
}
//浏览所有乘客按钮实现打开浏览所有乘客的功能
class liulanListen implements ActionListener
{
public void actionPerformed(ActionEvent e){
new 乘客浏览();
}
}
class shanchuListen implements ActionListener
{
public void actionPerformed(ActionEvent e){
new 删除乘客();
}
}
public static class 乘客浏览 extends JFrame
{
Object data[][];
Object colname[]={"名字","用户名","密码","身份证号"};
private JTable ckxinxiTable;
JButton ok = new JButton("查询所有乘客");
public 乘客浏览()
{
setLayout(new GridLayout(4, 1, 0, 10));
add(ok);
setTitle("浏览所有乘客");
setLocation(200,200);
setSize(500, 300);
setVisible(true);
ok.addActionListener(new okListen());
setDefaultCloseOperation(JFrame.HIDE_ON_CLOSE);
}
class okListen implements ActionListener
{
public void actionPerformed(ActionEvent e) {
try {
Class.forName("com.mysql.cj.jdbc.Driver");//第一步：加载jdbc驱动
Connection conn = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/mysql", "root", "1234");
Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
//第三步：生成容器
String sql = "select * from chengke";
System.out.println(sql);
ResultSet rs = stmt.executeQuery(sql);
//executeQuery执行查询语句
//*查询结果集的并显示在表格里
rs.last();
int n=rs.getRow();
data = new Object[n][10];
ckxinxiTable = new JTable(data, colname);
add(new JScrollPane(ckxinxiTable));
setVisible(true);
rs.beforeFirst();
int i=0;
while( rs.next()) {
data[i][0] = rs.getString(1);
data[i][1] = rs.getString(2);
data[i][2] = rs.getString(3);
data[i][3] = rs.getString(4);
i++;
}
//关闭数据库
rs.close();
stmt.close();
conn.close();
}
catch( Exception e1) {
System.out.println(e1.getMessage());
}
}
}
public static void main(String[] args)
{
new 乘客浏览();
}
}
public static class 乘客查询 extends JFrame
{
Object data[][];
Object colname[]={"名字","用户名","密码","身份证号"};
private JTable ckTable;
JTextField name = new JTextField(10);
JButton ok = new JButton("确定");
public 乘客查询()
{
setLayout(new GridLayout(4, 1, 0, 10));
add(new JLabel("请输入需要查询的乘客名字"));
add(name);
add(ok);
setTitle("查询乘客");
setLocation(200,200);
setSize(500, 500);
setVisible(true);
ok.addActionListener(new okListen());
setDefaultCloseOperation(JFrame.HIDE_ON_CLOSE);
}
class okListen implements ActionListener
{
public void actionPerformed(ActionEvent e) {
System.out.println(name.getText());
try {
Class.forName("com.mysql.cj.jdbc.Driver");//第一步：加载jdbc驱动
// MySQL的JDBC驱动(8.0版本) 驱动名称改变为：com.mysql.cj.jdbc.Driver
Connection conn = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/mysql", "root", "1234");
Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
//第三步：生成容器
String sql = "select * from chengke where mingzi='"+ name.getText()+"'";
System.out.println(sql);
ResultSet rs = stmt.executeQuery(sql);
//executeQuery执行查询语句
//*查询结果集的并显示在表格里
rs.last();
int n=rs.getRow();
data = new Object[n][10];
ckTable = new JTable(data, colname);
add(new JScrollPane(ckTable));
setVisible(true);
rs.beforeFirst();
int i=0;
while( rs.next()) {
data[i][0] = rs.getString(1);
data[i][1] = rs.getString(2);
data[i][2] = rs.getString(3);
data[i][3] = rs.getString(4);
i++;
}
//关闭数据库
rs.close();
stmt.close();
conn.close();
}
catch( Exception e1) {
System.out.println(e1.getMessage());
}
}
}
public static void main(String[] args)
{
new 乘客查询();
}
}
public static class 乘客增加 extends JFrame {
JTextField mingziJTextField = new JTextField(10);
JTextField nameJTextField = new JTextField(10);
JTextField passwordJTextField = new JTextField(10);
JTextField idJTextField = new JTextField(10);
JButton jieshuJButton = new JButton("结束");
public 乘客增加() {
setLayout(new GridLayout(5, 2, 0, 10));
add(new JLabel("请输入增加乘客的姓名"));
add(mingziJTextField);
add(new JLabel("请输入增加乘客的用户名"));
add(nameJTextField);
add(new JLabel("请输入增加乘客的密码"));
add(passwordJTextField);
add(new JLabel("请输入增加乘客的身份证号"));
add(idJTextField);
add(jieshuJButton);
setTitle("增加信息");
setLocation(200, 200);
setSize(600, 400);
setVisible(true);
jieshuJButton.addActionListener(new jieshuJButtonListen());
setDefaultCloseOperation(JFrame.HIDE_ON_CLOSE);
}
class jieshuJButtonListen implements ActionListener {
public void actionPerformed(ActionEvent e) {
try {
Class.forName("com.mysql.cj.jdbc.Driver");//第一步：加载jdbc驱动
Connection conn = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/mysql", "root", "1234");
Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
//第三步：生成容器
String sql = "insert into chengke(mingzi,name,password,id)" +
"values('"+ mingziJTextField.getText()+"','"+ nameJTextField.getText()+"','"+ passwordJTextField.getText()+"','"+ idJTextField.getText()+"')";
System.out.println(sql);
int rs = stmt.executeUpdate(sql);
//executeQuery执行查询语句；stmt.executeUpdate(sql)执行增删改语句
JOptionPane.showMessageDialog(null, "添加成功");
} catch (Exception e1) {
System.out.println(e1.getMessage());
}
}
}
public static void main(String[] args)
{
new 乘客增加();
}
}
public static class 乘客修改 extends JFrame{
JTextField mingziJTextField = new JTextField(10);
JTextField xiugaixinxiJTextField = new JTextField(10);
JButton genggaimingziJButton = new JButton("更改名字");
JButton genggaiyonghumingJButton = new JButton("更改用户名");
JButton genggaimimaJButton = new JButton("更改密码");
public 乘客修改(){
setLayout(new GridLayout(9, 1, 0, 10));
add(new JLabel("请输入需要修改的乘客名字"));
add(mingziJTextField);
add(new JLabel("请先输入修改后的信息再点击要修改的相应信息按钮"));
add(xiugaixinxiJTextField);
add(genggaimingziJButton);
add(genggaiyonghumingJButton);
add(genggaimimaJButton);
setTitle("修改乘客信息");
setLocation(200, 200);
setSize(500, 500);
setVisible(true);
setDefaultCloseOperation(JFrame.HIDE_ON_CLOSE);
genggaimingziJButton.addActionListener(new xiangxixinxiJButtonListen());
genggaiyonghumingJButton.addActionListener(new nameJButtonListen());
genggaimimaJButton.addActionListener(new chengkeJButtonListen());
}
//更改详细信息按钮触发的修改详细信息事件
class xiangxixinxiJButtonListen implements ActionListener {
public void actionPerformed(ActionEvent e) {
// System.out.println(name.getText());
try {
Class.forName("com.mysql.cj.jdbc.Driver");//第一步：加载jdbc驱动
// MySQL的JDBC驱动(8.0版本) 驱动名称改变为：com.mysql.cj.jdbc.Driver
Connection conn = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/mysql", "root", "1234");
Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
//第三步：生成容器
String sql = "update chengke " +
"set mingzi = '"+ xiugaixinxiJTextField.getText()+"'" +
"where mingzi = '"+ mingziJTextField.getText() +"'";
System.out.println(sql);
int rs = stmt.executeUpdate(sql);
JOptionPane.showMessageDialog(genggaimingziJButton, "更改成功！", "系统提示", JOptionPane.INFORMATION_MESSAGE);
}
catch (Exception e1) {
System.out.println(e1.getMessage());
}
}
}
//修改用户名按钮触发的修改用户名事件
class nameJButtonListen implements ActionListener {
public void actionPerformed(ActionEvent e) {
// System.out.println(name.getText());
try {
Class.forName("com.mysql.cj.jdbc.Driver");//第一步：加载jdbc驱动
// MySQL的JDBC驱动(8.0版本) 驱动名称改变为：com.mysql.cj.jdbc.Driver
Connection conn = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/mysql", "root", "1234");
Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
//第三步：生成容器
String sql = "update chengke " +
"set name = '"+ xiugaixinxiJTextField.getText()+"'" +
"where mingzi = '"+ mingziJTextField.getText() +"'";
System.out.println(sql);
int rs = stmt.executeUpdate(sql);
JOptionPane.showMessageDialog(genggaiyonghumingJButton, "更改成功！", "系统提示", JOptionPane.INFORMATION_MESSAGE);
//stmt.executeUpdate(sql)执行增删改语句
} catch (Exception e1) {
System.out.println(e1.getMessage());
}
}
}
//修改乘客按钮触发的修改乘客事件
class chengkeJButtonListen implements ActionListener {
public void actionPerformed(ActionEvent e) {
// System.out.println(name.getText());
try {
Class.forName("com.mysql.cj.jdbc.Driver");//第一步：加载jdbc驱动
Connection conn = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/mysql", "root", "1234");
Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
//第三步：生成容器
String sql = "update chengke " +
"set password = '"+ xiugaixinxiJTextField.getText()+"'" +
"where mingzi = '"+ mingziJTextField.getText() +"'";
System.out.println(sql);
int rs = stmt.executeUpdate(sql);
JOptionPane.showMessageDialog(genggaimimaJButton, "更改成功！", "系统提示", JOptionPane.INFORMATION_MESSAGE);
//stmt.executeUpdate(sql)执行增删改语句
} catch (Exception e1) {
System.out.println(e1.getMessage());
}
}
}
public static void main(String[] args)
{
new 乘客修改();
}
}
public static class 删除乘客 extends JFrame {
JTextField zhanghuJTextField = new JTextField(10);
JButton quedingJButton = new JButton("确定");
public 删除乘客() {
setLayout(new GridLayout(3, 1, 0, 10));
add(new JLabel("请输入需要删除的乘客名"));
add(zhanghuJTextField);
add(quedingJButton);
setTitle("删除账号");
setLocation(200, 200);
setSize(500, 300);
setVisible(true);
quedingJButton.addActionListener(new quedingJButtonListen());
setDefaultCloseOperation(JFrame.HIDE_ON_CLOSE);
}
class quedingJButtonListen implements ActionListener {
public void actionPerformed(ActionEvent e) {
// System.out.println(name.getText());
try {
Class.forName("com.mysql.cj.jdbc.Driver");//第一步：加载jdbc驱动
// MySQL的JDBC驱动(8.0版本) 驱动名称改变为：com.mysql.cj.jdbc.Driver
Connection conn = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/mysql", "root", "1234");
//第二步，根据情况进行更改：连接数据库school，用户名：root，密码：root
Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
//第三步：生成容器
// String sql = "select * from 患者信息 where 药品名字='"+ name.getText()+"'";
String sql = "delete from chengke " +
"where name = '"+zhanghuJTextField.getText()+"'";
System.out.println(sql);
int rs = stmt.executeUpdate(sql);
//executeQuery执行查询语句；stmt.executeUpdate(sql)执行增删改语句
JOptionPane.showMessageDialog(quedingJButton, "删除成功！", "系统提示", JOptionPane.INFORMATION_MESSAGE);
} catch (Exception e1) {
System.out.println(e1.getMessage());
}
}
}
public static void main(String[] args)
{
new 删除乘客();
}
}
}
标签：java,乘客,mysql,改查,add,sql,增删,new,public 来源： https://blog.csdn.net/qq_51474382/article/details/122222535