【java】用javaSE来实现对mysql数据库的增删改查

主程序:

import Bean.StudentBean;
import Impl.StudentImpl;

public class T7 {
    public static void main(String[] args) {
        StudentImpl stdimp = new StudentImpl();
//        StudentBean student = new StudentBean("halala", "woman", "china");
//         stdimp.add(student);
         stdimp.select("libin");
//         stdimp.delete("halala");
//         stdimp.add("halazi", "woman", "computer");
//        stdimp.update("halazi", "libin");
    }
}

DAO层:

package Bean;

public class StudentBean {

private int number;
    private String name;
    private String sex;
    private String major;

public String getName() {
        return name;
    }

public void setName(String name) {
        this.name = name;
    }

public int getNumber() {
        return number;
    }

public void setNumber(int number) {
        this.number = number;
    }

public String getSex() {
        return sex;
    }

public void setSex(String sex) {
        this.sex = sex;
    }

public String getMajor() {
        return major;
    }

public void setMajor(String major) {
        this.major = major;
    }

@Override
    public String toString() {
        return "StudentBean [number=" + number + ", name=" + name + ", sex="
                + sex + ", major=" + major + "]";
    }

public StudentBean() {
        super();
        // TODO Auto-generated constructor stub
    }

public StudentBean(String name, String sex, String major) {
        super();
        this.name = name;
        this.sex = sex;
        this.major = major;
    }

}

实现层:

package Impl;

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

import Bean.StudentBean;
import Conn.BD;

public class StudentImpl {
    BD bd = new BD();

public int add(StudentBean std) {
        int row = 0;
        Statement stmt = null;
        Connection conn = null;
        // String sql = "insert into info (name,sex,major)values("
        // + "‘std.getName()‘" +","+ "‘std.getSex()‘" +","+ "‘std.getMajor()‘"
        // + ");";
        String sql = "insert into info (name,sex,major)values( ‘"
                + std.getName() + "‘,‘" + std.getSex() + "‘,‘" + std.getMajor()
                + "‘);";
        System.out.println(sql);
        try {
            stmt = bd.conn(conn).createStatement();
            row = stmt.executeUpdate(sql);
            stmt.close();

return row;
        } catch (SQLException e) {

e.printStackTrace();
            try {
                stmt.close();
                conn.close();
            } catch (SQLException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
            }

return -1;
        }

}

public int add(String name, String sex, String major) {
        int row = 0;
        Connection conn = null;
        Statement stmt = null;

StudentBean std = new StudentBean();
        std.setName(name);
        std.setSex(sex);
        std.setMajor(major);

// String sql = "insert into info (name,sex,major)values("
        // + "‘std.getName()‘" +","+ "‘std.getSex()‘" +","+ "‘std.getMajor()‘"
        // + ");";
        String sql = "insert into info (name,sex,major)values( ‘"
                + std.getName() + "‘,‘" + std.getSex() + "‘,‘" + std.getMajor()
                + "‘);";
        System.out.println(sql);
        try {
            stmt = bd.conn(conn).createStatement();
            row = stmt.executeUpdate(sql);
            stmt.close();
            return row;
        } catch (SQLException e) {

e.printStackTrace();
            try {
                stmt.close();
                conn.close();
            } catch (SQLException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
            }

return -1;
        }

}

public int delete(String name) {
        StudentBean std = new StudentBean();
        Statement stmt = null;
        Connection conn = null;
        int dem = 0;
        std.setName(name);
        String sql = "delete from info where name=‘" + std.getName() + "‘;";
        System.out.println(sql);
        try {
            stmt = bd.conn(conn).createStatement();
            dem = stmt.executeUpdate(sql);
            System.out.println("删除成功!");
            return dem;
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            return -1;
        }
    }
    public void select(String name) {
        StudentBean std = new StudentBean();
        Statement stmt = null;
        Connection conn = null;
        ResultSet rs = null;
        std.setName(name);
        String sql = "select * from info where name=‘" + std.getName() + "‘;";
        System.out.println(sql);
        try {
            stmt = bd.conn(conn).createStatement();
            rs = stmt.executeQuery(sql);
            System.out.println("查询成功!");
            while (rs.next()) {
                System.out.println();
                System.out.println(+rs.getInt("number") + "\t"
                        + rs.getString("name") + "\t" + rs.getString("sex")
                        + "\t" + rs.getString("major") + "\t");
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            System.out.println("查询失败!");
        }
    }

//
    public int update(String name,String upinfo) {
        
        Statement stmt = null;
        Connection conn = null;
        StudentBean std=new StudentBean();
        std.setName(name);
        int upd = 0;

String sql = "update info set name= ‘"+upinfo+"‘ where name=‘"+std.getName()+"‘ ;";
        System.out.println(sql);
        try {
            stmt = bd.conn(conn).createStatement();
            
            upd = stmt.executeUpdate(sql);
            stmt.close();
            return upd;
        } catch (SQLException e) {

e.printStackTrace();
            
            
            return -1;
        }
        
    }
}

和数据库连接层:

package Conn;

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

public class BD {

public Connection conn(Connection conn) {
        // 驱动程序名
        String driver = "com.mysql.jdbc.Driver";
        // URL指向所访问的数据库的驱动名
        String url = "jdbc:mysql://127.0.0.1:3306/student";
        // 配置mysql用的用户名
        String username = "root";
        // java连接mysql用的密码
        String password = "root123";
        try {
            Class.forName(driver);
            conn = DriverManager.getConnection(url, username, password);

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

return conn;
    }

}

它们之间的关系是:

BD连接数据库,DAO层是数据库的元素映射,实现层调用DAO层实现数据的增删改查,主函数调用实现层进行具体操作。

新手纯手打,还请各位多多指教!!

时间: 2024-08-02 02:40:39

【java】用javaSE来实现对mysql数据库的增删改查的相关文章

shell实现对mysql数据库的增、删、改、查操作

shell实现对mysql数据库的增.删.改.查操作 #!/bin/bash #数据库信息 HOSTNAME="192.168.111.84" PORT="3306" USERNAME="root" PASSWORD="" DBNAME="test_db_test" TABLENAME="test_table_test" #也可以写 HOSTNAME="localhost&qu

【Hibernate】Hibernate的在Eclipse+Mysql的配置、安装,纯Java,利用Annotation与HQL完成数据库的增删改查

这篇文章有很多槽点,在Hibernate4.x上面用着Hibernate3.x的写法去写.而且程序中放到Eclipse中会有一大堆警告,但是这好歹也在一定程度上完成了Hibernate的入门.毕竟现在很多介绍Hibernate的书籍都是用Hibernate3.x的写法去写.上次那篇<[Hibernate]最简单的Hibernate工程--账号注册系统>(点击打开链接)杂糅Struts的技术其实是不对的.因为Hibernate完成的是,从Java到数据库,从数据库到Java的任务.之后Java与

java jdbc 连接mysql数据库 实现增删改查

好久没有写博文了,写个简单的东西热热身,分享给大家. jdbc相信大家都不陌生,只要是个搞java的,最初接触j2ee的时候都是要学习这么个东西的,谁叫程序得和数据库打交道呢!而jdbc就是和数据库打交道非常基础的一个知识,也是比较接近底层的,在实际的工作中大家用得更多的其实还是比较成熟的框架,例如Hibernate.Mybatis. 但是作为这些成熟框架的底层的jdbc却也是我们应该去掌握的,只有了解了jdbc的增删改查,这样在以后如果有兴趣去研究Hibernate或者Mybatis的源代码的

【Mysql】Java中对Mysql数据库的增删改查、Java的System类

这部分也是所谓JDBC.网站数据源的内容,把名字弄得很高深似得,实际上只是Java中对Mysql数据库的增删改查的内容.非常简单,之前写了这么多Mysql的内容,没好好总结一下,实在是不应该.今天就实现一个Java中对Mysql数据库的增删改查,随便带点Java取出当前系统的系统名与系统时间的知识,完成一个还算有点意思的小例子. 一.基本目标 首先,在Mysql数据库中有一张名为testtable的空表,id为自增列,username,class都是文本列,但是class里面都存放数字,也就是整

Windows下安装MySQLdb, Python操作MySQL数据库的增删改查

这里的前提是windows上已经安装了MySQL数据库,且配置完毕,能正常建表能操作.在此基础上只需安装MySQL-python-1.2.4b4.win32-py2.7.exe就ok了,只有1M多.这个有点类似jdbc里的那个jar包. 下载链接:http://sourceforge.net/projects/mysql-python/ , 百度云盘 :http://pan.baidu.com/s/1dDgnfpR 密码:7bna 接着import MySQLdb就能使用了,下面给出测试代码:

mysql数据库的增删改查语句

连接命令:mysql -h[主机地址] -u[用户名] -p[用户密码] 创建数据库:create database [库名] 显示所有数据库: show databases; 打开数据库:use [库名] 当前选择的库状态:SELECT DATABASE(); 创建数据表:CREATE TABLE [表名]([字段名] [字段类型]([字段要求]) [字段参数], ......); 显示数据表字段:describe 表名; 当前库数据表结构:show tables; =============

Java数据库连接——JDBC基础知识(操作数据库:增删改查)

一.JDBC简介 JDBC是连接java应用程序和数据库之间的桥梁. 什么是JDBC? Java语言访问数据库的一种规范,是一套API. JDBC (Java Database Connectivity) API,即Java数据库编程接口,是一组标准的Java语言中的接口和类,使用这些接口和类,Java客户端程序可以访问各种不同类型的数据库.比如建立数据库连接.执行SQL语句进行数据的存取操作. JDBC代表Java数据库连接. JDBC库中所包含的API任务通常与数据库使用: 连接到数据库 创

php连接MySQL数据库及增删改查

  1.连接MySQL数据库$conn = new mysqli($host,$user,$password); $conn -> query('set names utf8'); //设置字符编码,避免存入中文数据乱码$conn -> select_db('db'); //选择自己建立的数据库(db) 1.1 判断连接状态if (!$conn) { die("数据库连接异常");} //数据库的创建$db = "create database db";

使用JDBC连接MySQL数据库操作增删改查

目录 1.首先这个Myeclipse的包名以及一些实现的类(这样子写是我的习惯) 2.接下来我们创建数据库(MySQL) 3.在数据库里面添加数据 4.首先是BaseDao,这个是重中之重,注意那个数据库的名字,强调所在的包名 5.这个是实体类,我相信大家都会写,注意所在的包名 6.接下来我们写BookingDao 7.下面我们写Servlet 1.查询的Servlet 2.添加的Servlet 3.修改的Servlet 4.删除的Servlet 8.配置web.xml 9.再次写JSP页面 1