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

时间：2023-03-08 16:57:47

一、JDBC简介

　　JDBC是连接java应用程序和数据库之间的桥梁。

　　什么是JDBC?

　　Java语言访问数据库的一种规范,是一套API。

　　JDBC (Java Database Connectivity) API，即Java数据库编程接口，是一组标准的Java语言中的接口和类，使用这些接口和类，Java客户端程序可以访问各种不同类型的数据库。比如建立数据库连接、执行SQL语句进行数据的存取操作。

　　JDBC全称是java数据库连接，可以为多种数据库提供统一的访问。体现了Java“一次编写，处处运行”的高大上精神。

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

　　JDBC库中所包含的API任务通常与数据库使用：

　　　　连接到数据库。

　　　　创建SQL或MYSQL语句

　　　　在数据库中执行SQL或MYSQL语句。

　　　　查看或修改记录

　　比如：

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

二、JDBC使用详解

1、打通数据库

　　<1>工欲善其事必先利其器

　　　　明确目的：需求(做什么)

　　　　　　　　　　实现屌丝逆袭

　　　　　　　　　　拥有女神禁区，享有查看，添加，修改，删除等功能。

　　　　指导思想：概述详设(怎么做)

　　　　工具准备：Mysql、Eclipse、Navicat(数据库管理工具)

　　<2>JDBC编程步骤

　　　　加载驱动程序：Class.forName(driverClass);

　　　　加载mysql驱动：Class.forName("com.mysql.jdbc.Driver");

　　　　加载Oracle驱动：Class.forName("oracle.jdbc.driver.OracleDriver");

　　　　获得数据库连接：DriverManager.getConnection("jdbc:mysql:localhost:3306/mydb","root","mysql123");

　　　　创建Statement对象：conn.createStatement();

　　<3>简单测试:DBUtil.java

  public class DBUtil {

      private static final String URL="jdbc:mysql://localhost:3306/mydb";

      private static final String NAME="root";

      private static final String PASSWORD="mysql";

      public static void main(String[] args) throws Exception{

          //1.加载驱动程序

          Class.forName("com.mysql.jdbc.Driver");

          //2.获得数据库的连接

          Connection conn = DriverManager.getConnection(URL, NAME, PASSWORD);

          //3.通过数据库的连接操作数据库，实现增删改查

          Statement stmt = conn.createStatement();

          ResultSet rs = stmt.executeQuery("select user_name,age from imooc_goddess");//选择import java.sql.ResultSet;

          while(rs.next()){//如果对象中有数据，就会循环打印出来

             System.out.println(rs.getString("user_name")+","+rs.getInt("age"));

          }

      }

  }

DBUtil.java

　　<4>运行结果

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

2、搭建模型层

　　详设：

　　　　采用MVC三层结构

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

　　采用MVC三层架构：建议从下往上开发(DB->view，需求读懂以后，设计数据库，然后根据数据库映射模型，再写控制层，再写视图层)

　　　　--View视图层  ：展示数据，反馈用户行为

　　　　--Control控制层  ：控制数据流通过程，协调视图层和数据层

　　　　--Model模型层  ：与数据库建立映射，与数据进行交互

　　　　--DB数据库

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

　　先新增对应的model层，按照数据库表对应的字段编写实体类。

 package sql.model;

 import java.util.Date;

 public class Goddess {

     private Integer id;

     private String userName;

     private String sex;

     private Integer age;

     private Date birthday;

     private String email;

     private String mobile;

     private String createUser;

     private Date createDate;

     private String updateUser;

     private Date updateDate;

     private Integer isDel;

     public Integer getId(){

         return id;

     }

     public void setId(Integer id){

         this.id=id;

     }

     public String getUserName(){

         return userName;

     }

     public void setUserName(String userName){

         this.userName=userName;

     }

     public String getSex(){

         return sex;

     }

     public void setSex(String sex){

         this.sex=sex;

     }

     public Integer getAge(){

         return age;

     }

     public void setAge(Integer age){

         this.age=age;

     }

     public Date getBirthday(){

         return birthday;

     }

     public void setBirthday(Date birthday){

         this.birthday=birthday;

     }

     public String getEmail(){

         return email;

     }

     public void setEmail(String email){

         this.email=email;

     }

     public String getMobile(){

         return mobile;

     }

     public void setMobile(String mobile){

         this.mobile=mobile;

     }

     public String getCreateUser(){

         return createUser;

     }

     public void setCreateUser(String createUser){

         this.createUser=createUser;

     }

     public Date getCreateDate(){

         return createDate;

     }

     public void setCreateDate(Date createDate){

         this.createDate=createDate;

     }

     public String getUpdateUser(){

         return updateUser;

     }

     public void setUpdateUser(String updateUser){

         this.updateUser=updateUser;

     }

     public Date getUpdateDate(){

         return updateDate;

     }

     public void setUpdateDate(Date updateDate){

         this.updateDate=updateDate;

     }

     public Integer getIsDel(){

         return isDel;

     }

     public void setIsDel(Integer isDel){

         this.isDel=isDel;

     }

     public String toString(){

         return "Goddess:[ user_name="+userName+",sex="+sex+",age="+age+",birthday="+birthday+",email="+email

                 +",mobile="+mobile+",create_user="+createUser+",create_date="+createDate+",update_user="+

                 updateUser+",update_date="+updateDate+",isdel="+isDel+" ]";

     }

 }

Goddess.java

　　然后开始新增Dao层，并修改DBUtil.java

 package sql.Dao;

 import java.sql.DriverManager;

 import java.sql.ResultSet;

 import java.sql.Connection;

 import java.sql.SQLException;

 import java.sql.Statement;

 import test.staticTest;

 public class DBUtil {

     private static final String URL="jdbc:mysql://localhost:3306/mydb";

     private static final String NAME="root";

     private static final String PASSWORD="mysql123";

     private static Connection conn=null;

     //静态代码块(将加载驱动、连接数据库放入静态快中)

     static{

         try {

             //1.加载驱动程序

             Class.forName("com.mysql.jdbc.Driver");

             //2.获得数据库的连接

             conn=DriverManager.getConnection(URL,NAME,PASSWORD);

         } catch (SQLException e) {

             // TODO: handle exception

             e.printStackTrace();

         }catch(ClassNotFoundException e){

             e.printStackTrace();

         }

     }

     //对外提供一个方法来获取数据库；连接

     public static Connection getConnection(){

         return conn;

     }

     public static void main(String []args) throws Exception{

         //3.通过数据库的连接操作数据库，实现增删改查

         Statement stmt =conn.createStatement();

         ResultSet rs=stmt.executeQuery("select user_name,age from imooc_goddess");

         while(rs.next()){

             System.out.println(rs.getString("user_name")+","+rs.getInt("age"));

         }

     }

 }

DBUtil.java

 package sql.Dao;

 import java.sql.Connection;

 import java.sql.Date;

 import java.sql.PreparedStatement;

 import java.sql.ResultSet;

 import java.sql.SQLException;

 import java.sql.Statement;

 import java.util.ArrayList;

 import java.util.List;

 import java.util.Map;

 import sql.model.Goddess;

 import db.DBCPUtil;

         public class GoddessDao {

         }

     //更新女神

     public void updateGoddess(Goddess gs) throws Exception{

     }

     public void delGoddess(Integer id) throws SQLException{

     }

     public List<Goddess> query() throws Exception{

         Connection con=DBUtil.getConnection();

         Statement stmt=con.createStatement();

         ResultSet rs=stmt.executeQuery("select id,user_name,age from imooc_goddess");

         List<Goddess> gs=new ArrayList<Goddess>();

         Goddess g=null;

         while(rs.next()){

             g=new Goddess();

             g.setId(rs.getInt("id"));

             g.setUserName(rs.getString("user_name"));

             g.setAge(rs.getInt("age"));

             gs.add(g);

         }

         return gs;

     }

     //查询单个女神

     public Goddess get(Integer id) throws SQLException{

         return null;

     }

 }

GoddessDao.java

　　新增Controller层：GoddessAction.java　

 package controller;

 import java.util.ArrayList;

 import java.util.Date;

 import java.util.HashMap;

 import java.util.List;

 import java.util.Map;

 import sql.Dao.GoddessDao;

 import sql.model.Goddess;

 public class GoddessAction {

     public static void main(String []args) throws Exception {

         GoddessDao gdDao=new GoddessDao();

         List<Goddess> gs=gdDao.query();

         for(Goddess goddess:gs){

             System.out.println(goddess.getUserName()+","+goddess.getAge());

         }

 }

GoddessAction.java

　运行结果：

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

　　PS:CRUD:增加Create、读取Retrieve(重新得到数据-->高级应用：报表，分页)、更新Update和删除Delete

3、搭建模型层--CRUD操作

　　新增create操作

 public void addGoddess(Goddess gs) throws Exception{

         Connection connection=DBUtil.getConnection();//首先拿到数据库的连接

         String sql=""+

                     "insert into imooc_goddess"+

                     "(user_name,sex,age,birthday,email,mobile, "+

                     "create_user,create_date,update_user,update_date,isdel) "+

                     "values("+

                     "?,?,?,?,?,?,?,current_date(),?,current_date(),?)";//?表示占位符；用mysql的日期函数current_date()

         //来获取当前日期。

         //预编译SQL语句

         PreparedStatement psmt=connection.prepareStatement(sql);

         //先对应SQL语句，给SQL语句传递参数

         psmt.setString(1, gs.getUserName());

         psmt.setString(2, gs.getSex());

         psmt.setInt(3, gs.getAge());

         //注意：setDate()函数第二个参数需要的是java.sql.Date类型，我们传进来是java.util.Date类型，需要做一下转换。

         psmt.setDate(4, new Date(gs.getBirthday().getTime()));

         psmt.setString(5, gs.getEmail());

         psmt.setString(6, gs.getMobile());

         psmt.setString(7, gs.getCreateUser());

         psmt.setString(8, gs.getUpdateUser());

         psmt.setInt(9, gs.getIsDel());

         //执行sql语句

         psmt.execute();

         /**

          * prepareStatement这个方法会将SQL语句加载到驱动程序conn集成程序中，但是不直接执行

          * 而是当它调用execute()方法的时候才真正执行

          *

          * 上面的sql中的参数用？表示，相当于占位符，然后再对参数进行赋值

          * 当真正执行时，这些参数会加载在SQL语句中，把SQL语句拼接完整采取执行。

          * 这样就会减少对数据库的操作。

          * */

     }

addGoddess(Goddess g)添加女神方法

　　测试：

 package controller;

 import java.util.ArrayList;

 import java.util.Date;

 import java.util.HashMap;

 import java.util.List;

 import java.util.Map;

 import sql.Dao.GoddessDao;

 import sql.model.Goddess;

 public class GoddessAction {

     public static void main(String []args) throws Exception {

         GoddessDao gdDao=new GoddessDao();

         Goddess g1=new Goddess();

         g1.setUserName("陈好");

         g1.setAge(29);

         g1.setSex("女");

         g1.setBirthday(new Date());

         g1.setEmail("wangmeili@qq.com");

         g1.setMobile("123");

         g1.setCreateUser("admin");

         g1.setUpdateUser("admin");

         g1.setIsDel(1);

         gdDao.addGoddess(g1);//增加女神

         }

 }

GoddessAction.java

　　运行结果：

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

　　修改、删除、查询(根据ID)操作：

     //更新女神

     public void updateGoddess(Goddess gs) throws Exception{

         Connection connection=DBUtil.getConnection();//首先拿到数据库的连接

         String sql=""+

                     "update imooc_goddess"+

                     "(set user_name=?,sex=?,age=?,birthday?,email=?,mobile=?, "+

                     "update_user=?,update_date=current_date(),isdel=?) "+

                     "where id=?";//?表示占位符；用mysql的日期函数current_date()

         //来获取当前日期。

         //预编译SQL语句

         PreparedStatement psmt=connection.prepareStatement(sql);

         //先对应SQL语句，给SQL语句传递参数

         psmt.setString(1, gs.getUserName());

         psmt.setString(2, gs.getSex());

         psmt.setInt(3, gs.getAge());

         //注意：setDate()函数第二个参数需要的是java.sql.Date类型，我们传进来是java.util.Date类型，需要做一下转换。

         psmt.setDate(4, new Date(gs.getBirthday().getTime()));

         psmt.setString(5, gs.getEmail());

         psmt.setString(6, gs.getMobile());

         psmt.setString(7, gs.getUpdateUser());

         psmt.setInt(8, gs.getIsDel());

         psmt.setInt(9, gs.getId());

         //执行sql语句

         psmt.execute();

     }

     public void delGoddess(Integer id) throws SQLException{

         Connection connection=DBUtil.getConnection();

         String sql=""+

                     "delete from imooc_goddess "+

                     "where id=?";

         PreparedStatement psmt=connection.prepareStatement(sql);

         psmt.setInt(1, id);

         psmt.execute();

     }

     public List<Goddess> query() throws Exception{

         Connection con=DBUtil.getConnection();

         Statement stmt=con.createStatement();

         ResultSet rs=stmt.executeQuery("select id,user_name,age from imooc_goddess");

         List<Goddess> gs=new ArrayList<Goddess>();

         Goddess g=null;

         while(rs.next()){

             g=new Goddess();

             g.setId(rs.getInt("id"));

             g.setUserName(rs.getString("user_name"));

             g.setAge(rs.getInt("age"));

             gs.add(g);

         }

         return gs;

     }

     //查询单个女神

     public Goddess get(Integer id) throws SQLException{

         Goddess goddess=null;

         Connection connection=DBUtil.getConnection();

         String sql=""+

                 "select * from imooc_goddess "+

                 "where id=?";

         PreparedStatement psmt=connection.prepareStatement(sql);

         psmt.setInt(1, id);

         //psmt.execute();execute()是执行更改数据库操作(包括新增、修改、删除)；executeQuery()是执行查询操作

         ResultSet rsResultSet=psmt.executeQuery();

         while(rsResultSet.next()){

             goddess=new Goddess();

             goddess.setId(rsResultSet.getInt("id"));

             goddess.setUserName(rsResultSet.getString("user_name"));

             goddess.setSex(rsResultSet.getString("sex"));

             goddess.setAge(rsResultSet.getInt("age"));

             goddess.setBirthday(rsResultSet.getDate("birthday"));

             goddess.setEmail(rsResultSet.getString("email"));

             goddess.setMobile(rsResultSet.getString("mobile"));

             goddess.setCreateUser(rsResultSet.getString("create_user"));

             goddess.setCreateDate(rsResultSet.getDate("create_date"));

             goddess.setUpdateUser(rsResultSet.getString("update_user"));

             goddess.setUpdateDate(rsResultSet.getDate("update_date"));

             goddess.setIsDel(rsResultSet.getInt("isdel"));

         }

         return goddess;

     }

updateGoddess()、delGoddess()、get()

　　查询(根据name/mobile等)操作：

 //查询单个女神，(根据姓名等信息去查询)

     public List<Goddess> get(String name,String mobile) throws SQLException{

         List<Goddess> result=new ArrayList<>();

         Connection conn =DBUtil.getConnection();

         StringBuffer sb =new StringBuffer();

         System.out.print("sql: ");

         sb.append("select * from imooc_goddess ");

         sb.append("where user_name like ? and mobile like ?");

         //预编译sql语句

         PreparedStatement psmt=conn.prepareStatement(sb.toString());

         //先对应sql语句，给sql语句传递参数

         psmt.setString(1, "%"+name+"%");

         psmt.setString(2, "%"+mobile+"%");

         System.out.println(sb.toString());

         //执行sql语句

         ResultSet rsResultSet=psmt.executeQuery();

         Goddess goddess=null;

         while(rsResultSet.next()){

             goddess=new Goddess();

             goddess.setId(rsResultSet.getInt("id"));

             goddess.setUserName(rsResultSet.getString("user_name"));

             goddess.setSex(rsResultSet.getString("sex"));

             goddess.setAge(rsResultSet.getInt("age"));

             goddess.setBirthday(rsResultSet.getDate("birthday"));

             goddess.setEmail(rsResultSet.getString("email"));

             goddess.setMobile(rsResultSet.getString("mobile"));

             goddess.setCreateUser(rsResultSet.getString("create_user"));

             goddess.setCreateDate(rsResultSet.getDate("create_date"));

             goddess.setUpdateUser(rsResultSet.getString("update_user"));

             goddess.setUpdateDate(rsResultSet.getDate("update_date"));

             goddess.setIsDel(rsResultSet.getInt("isdel"));

             result.add(goddess);//将结果封装到对象中

         }

         return result;

     }

get(String name,String mobile)

　　测试：

 package controller;

 import java.util.ArrayList;

 import java.util.Date;

 import java.util.HashMap;

 import java.util.List;

 import java.util.Map;

 import sql.Dao.GoddessDao;

 import sql.model.Goddess;

 public class GoddessAction {

     public static void main(String []args) throws Exception {

         GoddessDao gdDao=new GoddessDao();

         //查询单个女神(根据姓名等信息)

         List<Goddess> list=gdDao.get("蔡妍", "123456");

         //遍历结果集

         for(int i=0;i<list.size();i++){

             System.out.println(list.get(i).toString());

         }

         }

 }

GoddessAction.java

　　运行结果：

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

　　查询操作的进一步完善：

 //查询单个女神，(根据姓名等信息去查询----->使用Map存储条件信息，防止条件为空可加一条where 1=1,目的是为了保证语法不会出错)

     public List<Goddess> get(List<Map<String, Object>> params) throws SQLException{

         List<Goddess> result=new ArrayList<>();

         Connection conn =DBUtil.getConnection();

         StringBuffer sb =new StringBuffer();

         System.out.print("sql: ");

         sb.append("select * from imooc_goddess where 1=1");//注意where 1=1的小技巧

         if(params!=null&&params.size()>0){

             //遍历集合

             for(int i=0; i<params.size();i++){

                 Map<String, Object> map=params.get(i);

                 sb.append(" and "+map.get("name")+" "+map.get("rela")+" "+map.get("value")+" ");

                 //查询什么？关系是什么？以及值是什么，我们都可以通过参数传进来

             }

         }

         //预编译sql语句

         PreparedStatement psmt=conn.prepareStatement(sb.toString());

         //先对应sql语句，给sql语句传递参数

         System.out.println(sb.toString());

         //执行sql语句

         ResultSet rsResultSet=psmt.executeQuery();

         Goddess goddess=null;

         while(rsResultSet.next()){

             goddess=new Goddess();

             goddess.setId(rsResultSet.getInt("id"));

             goddess.setUserName(rsResultSet.getString("user_name"));

             goddess.setSex(rsResultSet.getString("sex"));

             goddess.setAge(rsResultSet.getInt("age"));

             goddess.setBirthday(rsResultSet.getDate("birthday"));

             goddess.setEmail(rsResultSet.getString("email"));

             goddess.setMobile(rsResultSet.getString("mobile"));

             goddess.setCreateUser(rsResultSet.getString("create_user"));

             goddess.setCreateDate(rsResultSet.getDate("create_date"));

             goddess.setUpdateUser(rsResultSet.getString("update_user"));

             goddess.setUpdateDate(rsResultSet.getDate("update_date"));

             goddess.setIsDel(rsResultSet.getInt("isdel"));

             result.add(goddess);//将结果封装到对象中

         }

         return result;

     }

get(List<Map<String,Object>>)

　　测试：

 package controller;

 import java.util.ArrayList;

 import java.util.Date;

 import java.util.HashMap;

 import java.util.List;

 import java.util.Map;

 import sql.Dao.GoddessDao;

 import sql.model.Goddess;

 public class GoddessAction {

     public static void main(String []args) throws Exception {

         GoddessDao gdDao=new GoddessDao();

         //查询单个女神，(根据姓名等信息去查询----->使用Map存储条件信息，防止条件为空可加一条where 1=1,目的是为了保证语法不会出错)

         List<Map<String, Object>> params=new ArrayList<Map<String,Object>>();

         Map<String, Object> param=new HashMap<>();

         param.put("name", "user_name");

         param.put("rela", "like");

         param.put("value", "'%蔡素%'");

         params.add(param);

         param=new HashMap<>();

         param.put("name", "mobile");

         param.put("rela", "like");

         param.put("value", "'%123456789%'");

         params.add(param);

         List<Goddess> list1=gdDao.get(params);

         //遍历结果集

         for(int i=0;i<list1.size();i++){

             System.out.println(list1.get(i).toString());

         }

         }

 }

GoddessAction.java

　　运行结果：

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

　　这个查询的亮点在于：使用get(List<Map<String,Object>> params) 和 where 1=1；

　　jdbc传参数过多的时候：用List<Map<String,Object>> params双泛型作为参数.　　

　　我们查询的每一个条件都是一个键值对。键值对的数据结构就是Map。然后是因为查询的条件可能是多个，数量不确定，所以用List 比较好，所以就会是List<Map<key,value>>这样的数据结构了。上面使用where 1=1的原因主要是下面的语句直接就跟着一个and。SQL语句后面需要跟着where，但不确定where后面是否有语句，就要加上1=1，保证语法不会出错。一般用于构造动态SQL语句，"SELECT ... FROM ... WHERE 1=1 "+动态构造条件子句。

4、搭建控制层

　　控制层起到一个桥梁的作用，连接模型层和视图层。

 package controller;

 import java.util.List;

 import java.util.Map;

 import sql.Dao.GoddessDao;

 import sql.model.Goddess;

 /*

  * 控制层起到一个桥梁的作用，连接模型层和视图层*/

 public class GoddessAction1 {

     //添加女神

     public void add(Goddess goddess) throws Exception{

         GoddessDao dao=new GoddessDao();

         goddess.setSex("女");

         goddess.setIsDel(0);

         dao.addGoddess(goddess);

     }

     //修改女神

     public void edit(Goddess goddess) throws Exception{

         GoddessDao dao=new GoddessDao();

         dao.updateGoddess(goddess);

     }

     //删除女神

     public void del(Integer id) throws Exception{

         GoddessDao dao=new GoddessDao();

         dao.delGoddess(id);

     }

     //查询所有女神

     public List<Goddess> query() throws Exception{

         GoddessDao dao=new GoddessDao();

         return dao.query();

     }

     //查询单个女神信息(根据id)

     public Goddess get(Integer id) throws Exception{

         GoddessDao dao=new GoddessDao();

         return dao.get(id);

     }

     //查询单个女神(根据姓名等信息)

     public List<Goddess> get(List<Map<String, Object>> params) throws Exception{

         GoddessDao dao=new GoddessDao();

         return dao.get(params);

     }

 }

GoddessAction1.java

5、搭建视图层

　　<1>流程

　　　　程序启动后，一直保持在运行状态

　　　循环接收控制台的输入参数

　　　调用Action(控制层)响应，并将返回结果展示在控制台中。

　　　知道输入特定的输入标记(如EXIT)后，程序退出。

　　<2>问题点

　　　　循环接收参数

　　　某个功能的保持

　　<3>代码示例

 package view;

 import java.util.Date;

 import java.text.ParseException;

 import java.text.SimpleDateFormat;

 import java.util.List;

 import java.util.Scanner;

 import sql.model.Goddess;

 import controller.GoddessAction1;

 public class View {

     //提示语

     private static final String CONTEXT="欢迎来到女神禁区：\n" +

             "下面是女神禁区的功能列表：\n" +

             "[MAIN/M]:主菜单\n" +

             "[QUERY/Q]:查看全部女神的信息\n" +

             "[GET/G]:查看某位女神的详细信息\n" +

             "[ADD/A]:添加女神信息\n" +

             "[UPDATE/U]:更新女神信息\n" +

             "[DELETE/D]:删除女神信息\n" +

             "[SEARCH/S]:查询女神信息(根据姓名、手机号来查询)\n" +

            "[EXIT/E]:退出女神禁区\n" +

            "[BREAK/B]:退出当前功能，返回主菜单";

     //操作标记

     private static final String OPERATION_MAIN="MAIN";

     private static final String OPERATION_QUERY="QUERY";

     private static final String OPERATION_GET="GET";

     private static final String OPERATION_ADD="ADD";

     private static final String OPERATION_UPDATE="UPDATE";

     private static final String OPERATION_DELETE="DELETE";

     private static final String OPERATION_SEACHR="SEARCH";

     private static final String OPERATION_EXIT="EXIT";

     private static final String OPERATION_BREAK="BREAK";

     public static void main(String []args){

         //输出提示

         System.out.println(CONTEXT);

         //怎么保持程序的一直运行：while(true)

         Scanner inScanner=new Scanner(System.in);//受程序台的控制

         Goddess go=new Goddess();

         GoddessAction1 action=new GoddessAction1();

         String prenious=null;//标记，记住上一次的请求

         Integer step=1;//步骤标记

         while(inScanner.hasNext()){

             //有数值时，才进行循环，没有就不进行。

             String string=inScanner.next().toString();

             if (OPERATION_EXIT.equals(string.toUpperCase())

                     || OPERATION_EXIT.substring(0, 1).equals(string.toUpperCase())) {

                 System.out.println("您已成功退出女神禁区！");

                 break;//退出当前while循环

             }else if(OPERATION_QUERY.equals(string.toUpperCase())

                     || OPERATION_QUERY.substring(0,1).equals(string.toUpperCase())){

                 try {

                     List<Goddess> list=action.query();

                     for(Goddess g : list){

                         System.out.println(g.getId()+", 姓名："+g.getUserName());

                     }

                 } catch (Exception e) {

                     // TODO: handle exception

                     e.printStackTrace();

                 }

             }else if (OPERATION_ADD.equals(string.toUpperCase())

                     || OPERATION_ADD.substring(0,1).equals(string.toUpperCase())

                     || OPERATION_ADD.equals(prenious)) {

                 prenious=OPERATION_ADD;

                 //新增女神

                 if (step==1) {

                     System.out.println("请输入女神 [姓名] ");

                 }else if (step==2) {

                     go.setUserName(string);

                     System.out.println("请输入女神 [年龄] ");

                 }else if (step==3) {

                     go.setAge(Integer.valueOf(string));//string转换为int型

                     System.out.println("请输入女神 [生日] ");

                 }else if (step==4) {

                     SimpleDateFormat sf=new SimpleDateFormat("yyyy-MM-dd");

                     Date birthday=null;

                     try {

                         birthday=sf.parse(string);

                         go.setBirthday(birthday);

                         System.out.println("请输入女神 [邮箱]");

                     } catch (Exception e) {

                         // TODO: handle exception

                         e.printStackTrace();

                         System.out.println("您的输入有误，请重新输入");

                         step=3;

                     }

                 }else if (step==5) {

                     go.setEmail(string);

                     System.out.println("请输入女神 [手机号] ");

                 }else if (step==6) {

                     go.setMobile(string);

                     try {

                         action.add(go);

                         System.out.println("新增女神成功");

                     } catch (Exception e) {

                         // TODO: handle exception

                         e.printStackTrace();

                         System.out.println("新增女神失败");

                     }

                 }if(OPERATION_ADD.equals(prenious)){

                     step++;

                 }

             }else {

                 System.out.println("您的输入值为："+inScanner);

             }

         }

     }

 }

View.java

　　<4>运行结果

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

三、JDBC总结

　　 1、JDBC的基本概念：JDBC是连接数据库的桥梁；

是由Java语言编写的类和接口组成，可以为多种数据库提供统一的访问。

　　2、采用MVC三层结构:

DB（数据库）、Model（模型层）、Control（控制层）、View（视图层）

模型层（DB + DAO）：封装了实现类
控制层：负责调用模型层
视图层调用控制层

　　3、JDBC各种连接方式的对比：

  • 1、JDBC + ODBC桥的方式。特点：需要数据库的ODBC驱动，仅适用于微软的系统

这种方式，JDBC将调用传递给ODBC，然后ODBC再调用本地的数据库驱动代码。

  • 2、JDBC + 厂商API的形式。特点：厂商API一般使用C编写

这种方式，JDBC将调用直接传递给厂商API的服务，然后在调用本地的数据库驱动。

  • 3、JDBC + 厂商Database Connection Server + DataBase的形式。

特点：在JAVA与DATABASE之间架起了一台专门用于数据库连接的服务器（一般有数据库厂商提供）
这种方式，JDBC将调用传递给中间服务器，中间服务器再将调用转换成数据库能够被调用的形式，在调用数据库服务器。中间增设数据库服务器能够提升效率，但不如直接操作数据库便捷。

  • 4、JDBC + DATABASE的连接方式。

特点：这使得Application与数据库分开，开发者只需关心内部逻辑的实现而不需注重数据库连接的具体实现。（没有中间环节，是推荐方式！

转载：Java数据库连接

相关文章