java通过JDBC连接数据库及增删改查操作

java通过JDBC连接数据库及增删改查操作1.实战数据库数据的准备  创建数据库(newsmanager),然后创建表news(id,title,content,type)和newstype(id,name),其中news的type和newstype的id为主外键关系,如下图图 2.JDBC的介绍   1)一种执行SQL语言的JavaAPI   2)可以对所以主流数据库进行统一访问(access,

大家好,又见面了,我是你们的朋友全栈君。

1.实战数据库数据的准备

   创建数据库(newsmanager),然后创建表news(id,title,content,type)和newstype(id,name),其中news的type和newstype的id为主外键关系,如下图java通过JDBC连接数据库及增删改查操作

  2.JDBC的介绍

      1)一种执行SQL语言的Java API
      2)可以对所以主流数据库进行统一访问(access,MySQL,sql server,Oracle)
      3)极大地减少了程序操作数据库的复杂性
      4)jdbc使用面向对象的方式操作数据,能更好的和Java语言衔接
      5)jdbc可以直接调用数据库存储过程
      6)jdbc操作数据库的效率很高
      7)学会了jdbc,什么数据库存取数据都会了
      8)但是唯一的缺点就是不安全,因为你会把数据库的用户名和密码写入代码里,别人可以反编译便可以获取你的数据库信息,所以看你怎么衡量吧
3.连接数据库工具类的实现
     1)在IDE(MyEclipse/eclipse)中建立项目
           创建包com jdbc.bean(实体类包),com jdbc.dao(操作数据库的方法),com jdbc.main(实际操作方法),com jdbc.util(工具类包)
     2)导入MySQL连接jar包到项目中(jar包下载地址:http://dev.mysql.com/downloads/file/?id=462850)
     3)利用导入的jar包完成连接数据库的工具类 
           完成上述步骤的图

          java通过JDBC连接数据库及增删改查操作

     4)connection对象的讲解和使用
            在com jdbc.util包下,创建一个类BaseConnection,它的作用是连接数据库 ,写上以下代码

package com.jdbc.util;

import java.sql.Connection;
import java.sql.DriverManager;

public class BaseConnection { 
     public static Connection getConnection(){//用这个方法获取mysql的连接
    	 Connection conn=null;
    	 try{
    		 Class.forName("com.mysql.jdbc.Driver");//加载驱动类
    		 conn=DriverManager.   
    				 getConnection("jdbc:mysql://localhost:3306/newsmanager","root","950107");//(url数据库的IP地址,user数据库用户名,password数据库密码)
    	 }catch(Exception e){
    		 e.printStackTrace();
    	 }
    	 return conn;
     }
     public static void main(String[] args){//测试数据库是否连接成功的方法
        Connection conn=BaseConnection.getConnection();
        System.out.println(conn);
     }
     
}

     若连接成功则显示下图

java通过JDBC连接数据库及增删改查操作

3.查询操作的机制和实现

   1)在com jdbc.bean包下根据数据库的数据属性创建News.java和Newstype.java,代码分别如下
         News.java代码

package com.jdbc.bean;

public class News {
    private int id;
    private String title;
    private String content;
    private int type;
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public String getTitle() {
		return title;
	}
	public void setTitle(String title) {
		this.title = title;
	}
	public String getContent() {
		return content;
	}
	public void setContent(String content) {
		this.content = content;
	}
	public int getType() {
		return type;
	}
	public void setType(int type) {
		this.type = type;
	}
}

         Newstype.java代码

package com.jdbc.bean;

public class NewsType {
	private int id;
	private String name;
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	

}

   2)在com jdbc.dao(操作数据库的方法)下分别创建NewsDAO.java(操作news表的操作)和NewsType.java(操作newstype表的操作),代码如下

        NewsDAO.java

package com.jdbc.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;

import com.jdbc.bean.News;
import com.jdbc.util.BaseConnection;

public class NewsDAO {
	 public ArrayList<News> getList(){//单表查询
		   ArrayList<News> ar=new ArrayList<News>();//存储从数据库中取出来的数据
		   Connection conn=BaseConnection.getConnection();//获取数据库连接
		   //sql执行器对象
		   PreparedStatement ps=null;
		   //结果集对象
		   ResultSet rs=null;//查询出来的数据先放到rs中
		   try{
			     String sql="select * from news";
			     ps=conn.prepareStatement(sql);
			     rs=ps.executeQuery();//执行数据库查询的方法,放到rs中
			     while(rs.next()){//rs对象相当于一个指针,指向数据库的一横行数据
			    	 News ne =new News();//封装数据
			    	 ne.setId(rs.getInt("id"));//rs指针指向id一行获取id一行数据,存储到ne中
			    	 ne.setTitle(rs.getString("title"));//rs指针指向title一行获取id一行数据,存储到ne中
			    	 ne.setContent(rs.getString("content"));//rs指针指向content一行获取id一行数据,存储到ne中
			    	 ne.setType(rs.getInt("type"));//rs指针指向id一行获取type一行数据,存储到ne中
			    	 ar.add(ne);//通过循环,把数据的数据依次存储在ne对象中,再把ne对象添加到ar数组中方便提取
			    	 
			    	 
			     }
		   }catch(Exception e){
			   e.printStackTrace();
		   }finally{//重点下面代码必须写,当数据库使用后必须关闭,如果没有关闭数据库的接口有限,下次就不能连接
			   try{
				   if(rs!=null){
					   rs.close();
				   }if(ps!=null){
					   ps.close();
				   }if(conn!=null){
					   conn.close();
				   }
			   }catch(Exception e2){
				   e2.printStackTrace();
			   }
		   }
		   return ar;//返回ar
	   }
	 
	   public static void main(String[] args){
		  ArrayList<News> ar= new NewsDAO().getList();
		  for(News ne:ar){
			  System.out.println(ne.getId()+" "+ne.getTitle());
		  }
	   }
}

   如果要链表查询只需把NewsDAO.java中String sql=”  select  *  from news, newstype”   “where news.type =newsype.id”和ne.setName(rs.getString(”name”))再把News.java添加private String name;

出现如下图就表示成功

  java通过JDBC连接数据库及增删改查操作

4.添加操作的机制与实现

   只需在NewsDao.java添加方法,代码如下

 //该方法负责将传递过来的news对象中的数据存入到数据库中
	 public void insert(News ne){
		 Connection conn=BaseConnection .getConnection();
		 PreparedStatement ps=null;
		 String sql="insert into news(title,content,type)"+
		 "values(' "+ne.getTitle()+"','"+ne.getContent()+"',"+
				 ne.getType()+")";
		 try{
			 ps= conn.prepareStatement(sql);//把写好的sql语句传递到数据库,让数据库知道我们要干什么
			 int a=ps.executeUpdate();//这个方法用于改变数据库数据,a代表改变数据库的条数
			 if(a>0){
				 System.out.println("添加成功");
			 }else{
				 System.out.println("添加失败");
			 }
		 }catch(Exception e){
			 e.printStackTrace();
		 }try{
			   if(ps!=null){
				   ps.close();
			   }if(conn!=null){
				   conn.close();
			   }
		   }catch(Exception e2){
				 e2.printStackTrace();
			 }
	 }

  再把public static void main(String[] args){

  News ne=new News();
  NewsDAO neda=new NewsDAO();
  ne.setTitle(“成都温江环境好”);
  ne.setContent(“我还是得了肺癌”);
  ne.setType(2);
  neda.insert(ne);
//  ArrayList<News> ar= new NewsDAO().getList();
//  for(News ne:ar){

//  System.out.println(ne.getId()+” “+ne.getTitle());
//  }
   }
}改了

 出现如下图就成功了

  java通过JDBC连接数据库及增删改查操作

数据库也更新了如图

java通过JDBC连接数据库及增删改查操作

上述也可以使用占位符,代码如图

java通过JDBC连接数据库及增删改查操作

5.删除和修改操作的机制和实现

 1)在NewsDAO.java文件下添加deleta方法,代码如下

    public void delete(int id){//删除数据库中的数据
		 Connection conn=BaseConnection.getConnection();
		 PreparedStatement ps=null;
		 String sql="delete from news where id =?";
		 try{
			 ps=conn.prepareStatement(sql);
			 ps.setInt(1, id);
			 int a=ps.executeUpdate();
			 if(a>0){
				 System.out.println("删除成功");
			 }else{
				 System.out.println("删除失败");
			 }
		 }catch(Exception e){
			 e.printStackTrace();
		 }finally{
			 try{
				   if(ps!=null){
					   ps.close();
				   }if(conn!=null){
					   conn.close();
				   }
			   }catch(Exception e2){
				   e2.printStackTrace();
			   }
		 }
	 }

 调用该方法就可以删除操作,成功如下图

java通过JDBC连接数据库及增删改查操作

    2)在NewsDAO.java文件下添加update方法,代码如下
    

//本方法用于将传递过来的news对象中的值,根据id主键,改变数据库中的值
	 public void update(News ne){
		 Connection conn=BaseConnection.getConnection();
		 PreparedStatement ps=null;
		 String sql="update news set title=?,content=?,type=?"+
		             "where id=?";
		 try{
			 ps=conn.prepareStatement(sql);
			 ps.setString(1,ne.getTitle());
			 ps.setString(2,ne.getContent());
			 ps.setInt(3,ne.getType());
			 ps.setInt(4,ne.getId());
			 int a=ps.executeUpdate();
	      if(a>0){
				 System.out.println("修改成功");
			 }else{
				 System.out.println("修改失败");
			 }
		 }catch(Exception e){
			 e.printStackTrace();
		 }finally{
			 try{
				   if(ps!=null){
					   ps.close();
				   }if(conn!=null){
					   conn.close();
				   }
			   }catch(Exception e2){
				   e2.printStackTrace();
			   }
		 }
		     
	 }

  6.把这些方法串起来

在com.jdbc.main包下创建TestMain.java,代码如下

  

package com.jdbc.main;

import java.util.ArrayList;
import java.util.Scanner;

import com.jdbc.bean.News;
import com.jdbc.dao.NewsDAO;

public class TestMain {
    public static void main(String[] args){
    	
    	Scanner sc=new Scanner(System.in);
    	NewsDAO nd=new NewsDAO();
    	while(true){
    		System.out.println("1.查看新闻 2.添加新闻 3.删除新闻 4.退出");
    		int a=sc.nextInt();
    		if(a==1){
    			ArrayList<News> ar =nd.getListAll();
    			System.out.println("编号\t标题\t内容"); 
    			for(News ne:ar){
    				System.out.println(ne.getId()+"\t"+ne.getTitle()+"\t"+ne.getContent());
    			}
    			
    		}else if(a==2){
    			System.out.println("请输入新闻标题内容类别编号");
    			News ne=new News();
    			ne.setTitle(sc.next());
    			ne.setContent(sc.next());
    			ne.setType(sc.nextInt());
    			boolean b=nd.insert1(ne);//调用插入方法
                 System.out.println(b);
    		}else if(a==3){
    			System.out.println("请输入要删除的新闻编号");
    			int id =sc.nextInt();
    			boolean b=nd.delete(id);//调用删除方法
    			System.out.println(b);
    		}else{
    			break;
    		}
    	}
    }
}

 实现成功会出现下图

java通过JDBC连接数据库及增删改查操作

  这就是JDBC连接任何数据库的方法,我会把代码传上来,不用积分就可以下载,希望大家多多支持我!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/158717.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • Objective-C之父Brad J. Cox去世,他推动了今天苹果的软件生态[通俗易懂]

    Objective-C之父Brad J. Cox去世,他推动了今天苹果的软件生态[通俗易懂]本文转载自机器之心近日,讣告网站Legacy.com发布消息:Objective-C之父BradJ.Cox博士于2021年1月2日在自己的家中逝世,享年77岁。如果你是苹果生态的一位开发者,那你对Objective-C一定不会陌生。这门语言成就了苹果强大的软件生态,也因为苹果硬件的畅销而一路高歌猛进,挺进各大编程语言排行榜的前几名。作为一位计算机科学家,BradCox的主要成就是和TomLove一起创建了Objective–C。此外,他还以在软件工

  • ThreadPoolTaskExecutor线程池参数配置

    ThreadPoolTaskExecutor线程池参数配置一、线程池配置1、ThreadPoolConfigimportorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.scheduling.annotation.EnableAsync;importorg.springframework.scheduling.concurrent.Threa

  • 5V升压到12.6V的锂电池充电IC芯片方案FS4062B[通俗易懂]

    5V升压到12.6V的锂电池充电IC芯片方案FS4062B[通俗易懂]三节3.7V的锂电池串联,11.1V和最大12.6V锂电池充电电路的解决方案。在应用中,一般使用低压5V,如USB和TYPE-C口直接输入的给三串锂电池充电,还有是15V或者18V,20V输入降压给锂电池充电的两种情况。  FS4062B是输入5V升压充电管理芯片,FS4008A是输入15V-20V降压充电三节锂电池IC  FS4062B是一款5V输入,最大1.2A充电电流,支持三节锂离子电池的升压充电管理IC。FS4062B外置MOS,自适应充电,采用异步开关架构,使其在应用时仅需极少的外围器

  • 跳过谷歌验证码_如何获取游戏验证码

    跳过谷歌验证码_如何获取游戏验证码本月底,谷歌Google即将停止全球图片验证码服务,这个困扰我们多年的验证码终于要退出历史的舞台了。官方宣告可以看以下截图:想必验证码的发展史已经众所周知了,从2002年到如今,经过了16年的发展,

  • 2020最新Java面试题(常见面试题及答案汇总)「建议收藏」

    2020最新Java面试题(常见面试题及答案汇总)「建议收藏」Java基础篇1.JDK和JRE的区别是什么?JDK:JavaDevelopmentKit的简称,java开发工具包,提供了java的开发环境和运行环境。JRE:JavaRuntimeEnvironment的简称,java运行环境,为java的运行提供了所需环境。总结:JDK包含了JRE,同时还包含了编译java源码的编译器javac,还包含…

  • VLDB论文解读:阿里云超大规模实时分析型数据库AnalyticDB「建议收藏」

    VLDB论文解读:阿里云超大规模实时分析型数据库AnalyticDB「建议收藏」1、背景随着数据量的快速增长,越来越多的企业迎来业务数据化时代,数据成为了最重要的生产资料和业务升级依据。伴随着业务对海量数据实时分析的需求越来越多,数据分析技术这两年也迎来了一些新的挑战和变革:在线化和高可用、离线和在线的边界越来越模糊,一切数据皆服务化、一切分析皆在线化; 高并发低延时,越来越多的数据系统直接服务终端客户,对系统的并发和处理延时提出了新的交互性挑战; 混合负载,一套实时分析系统既要支持数据加工处理,又要支持高并发低延时的交互式查询; 融合分析,随着对数据新的使用方式探索,需

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号