问答文章1 问答文章501 问答文章1001 问答文章1501 问答文章2001 问答文章2501 问答文章3001 问答文章3501 问答文章4001 问答文章4501 问答文章5001 问答文章5501 问答文章6001 问答文章6501 问答文章7001 问答文章7501 问答文章8001 问答文章8501 问答文章9001 问答文章9501

如何用java实现对mysql进行增删改查

发布网友 发布时间:2022-04-26 23:32

我来回答

2个回答

懂视网 时间:2022-04-30 00:20

数据库:

create table t1(id int primary key not null auto_increment,name varchar(32),password varchar(32));

insert into t1(name,password) values('admin','123');
insert into t1(name,password) values('zhangsan','123');
insert into t1(name,password) values('lisi','123');

Java代码:

mysqlDao.java:

package com.dao;

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

import org.junit.Test;

public class mysqlDao {
	
	private static String driver="com.mysql.jdbc.Driver"; //驱动
	private String url="jdbc:mysql://localhost:3306/test"; //数据库连接地址
	private String user="root"; //数据库账户
	private String password="11"; //数据库密码
	
	private Connection connection=null; //连接
	private Statement stmt=null; //声明
	private ResultSet rs=null; //结果集
	
	private int i=-1;
	
	/*
	 * 创建驱动
	 * */
	static{
		try {
			Class.forName(driver);
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	/*
	 * 加载驱动
	 * */
	@Test
	public void connect() {
		// TODO Auto-generated method stub
		try {
			
			connection=DriverManager.getConnection(url, user, password);
			
			if(connection!=null){
				System.out.println("数据库连接成功!");
			}else{
				System.out.println("数据库连接失败!");
			}
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	/*
	 * 执行sql语句
	 * */
	public void doSql(String sql) {
		// TODO Auto-generated method stub
		
		System.out.println("This Is mysqlDao.doSql() Method!");
		
		if(sql!=null){
			connect();
			
			try {
				
				stmt=connection.createStatement();
				stmt.execute(sql);
				
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		}
		
	}
	
	/*
	 * 获取影响行数
	 * */
	public int getUpCount() {
		// TODO Auto-generated method stub
		
		try {
			i=stmt.getUpdateCount();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		return i;
	}
	
	/*
	 * 获取结果集
	 * */
	public ResultSet getRs() {
		
		try {
			rs=stmt.getResultSet();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		return rs;
	}
	
	/*
	 * 执行关闭方法
	 * */
	public void close() {
		// TODO Auto-generated method stub
		
			try {
				if(rs!=null){
				rs.close();
				}
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}finally{
				
					try {
						
						if(stmt!=null){
						stmt.close();
						}
					} catch (SQLException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}finally{
						if(connection!=null){
							try {
								connection.close();
							} catch (SQLException e) {
								// TODO Auto-generated catch block
								e.printStackTrace();
							}
						}
					}
				}
				
	}

}

createSql.java

package com.dao;

import java.sql.ResultSet;
import java.sql.SQLException;

import org.junit.Test;

public class createSql {
	
	mysqlDao mysqldao=new mysqlDao();
	
	private String sql;
	private int i=-1;
	
	private ResultSet rs=null;
	
	/*
	 * 插入数据
	 * */
	@Test
	public void insert() {
		// TODO Auto-generated method stub
		
		sql="insert into t1(name,password) values('lisi','1234')"; //创建sql语句
		mysqldao.doSql(sql); //执行sql语句
		i=mysqldao.getUpCount(); //获取影响行数
		if(i!=-1){
			System.out.println("数据插入成功!");
		}else{
			System.out.println("数据插入失败!");
		}
		mysqldao.close(); //关闭连接
		
	}
	
	/*
	 * 删除数据
	 * */
	@Test
	public void delete() {
		// TODO Auto-generated method stub
		sql="delete from t1 where id=6";
		mysqldao.doSql(sql);
		i=mysqldao.getUpCount();
		if(i!=-1){
			System.out.println("数据删除成功!");
		}else{
			System.out.println("数据删除失败!");
		}
		mysqldao.close();
	}
	
	/*
	 * 修改数据
	 * */
	@Test
	public void update() {
		// TODO Auto-generated method stub
		sql="update t1 set name='wangwu' where id=1";
		mysqldao.doSql(sql);
		i=mysqldao.getUpCount();
		if(i!=-1){
			System.out.println("数据更新成功!");
		}else{
			System.out.println("数据更新失败!");
		}
		mysqldao.close();
	}
	
	/*
	 * 遍历数据
	 * */
	@Test
	public void select() throws SQLException {
		// TODO Auto-generated method stub
		
		sql="select * from t1";
		mysqldao.doSql(sql);
		
		rs=mysqldao.getRs();
		
		if(rs!=null){
			rs.last();
			i=rs.getRow();
			
			if(i>0){
				rs.beforeFirst();
				while(rs.next()){
					
					String id=rs.getString("id");
					String name=rs.getString("name");
					String password=rs.getString("password");
					System.out.println("id:"+id+" "+"name:"+name+" password:"+password);
				}
			}else{
				System.out.println("对不起,没有您要查询的信息!");
			}
			
		}else{
			System.out.println("异常...........");
		}
		mysqldao.close();

	}

}


mysql数据库的连接以及增删改查Java代码实现(Statement版)

标签:java   mysql   

热心网友 时间:2022-04-29 21:28

jdbc。。首先你的下载mysql然后下载jdbc驱动,然后在你的代码里与数据库连接,连接成功后就可以在代码里用sql语句对mysql实现增删改查了
声明声明:本网页内容为用户发布,旨在传播知识,不代表本网认同其观点,若有侵权等问题请及时与本网联系,我们将在第一时间删除处理。E-MAIL:11247931@qq.com
怎么取消微信亲情卡 米兰花冬季耐寒多少度 猫为什么喜欢咬人 看看是不是触碰到猫咪禁区了? 幼猫开始咬人是不是要磨牙了的表现 为什么刚到家的猫咪咬人 生气可导致女人8大器官受伤害 如何在windows10中打开任务管理器 windows10资源管理器怎么打开 急问!!下列汉字的构造方式"下、雨、客、武、从、荆、日、绳” 贵州黔运紫金文化传媒有限公司怎么样? 贵州黔之龙文化传媒有限公司怎么样? 对数据库实现增删改查的Java程序 java连接数据库实现增删改查 求一个JAVA应用系统能实现对数据库数据的增删改查就可以!谢谢 只有手机串号能查出公安能查出原机主吗 为什么手机内的照片时间久了会模糊不清? 苹果手机屏幕上出现GPRS标志怎么关掉? iphone5 如何关闭GPRS上网功能 苹果5S总是显示GPRS怎么关掉啊? 苹果手机用的是中国移动号码GPRS不用时怎样关闭网络连接 按摩胸部真的能变大吗 胸会越来越揉越大吗? 严肃解释:胸部真的会越揉越大吗 怎样能找个胸大的女朋友? 我20岁,大学生,看到很*的女生都受不了,怎么办,还会有生理反应,想控制自己控制不住 我女朋友今年23胸挺大的,可是有些下垂了,要怎么办,怎么样可以让他回来呢? 我的女朋友胸很大怎么办? 天猫旗舰店的天气丹为什么后面比免税店多一行字 免税版天气丹有中文标签吗 22岁 改名(100分+1590) 我女儿是2005年阴历11月26日18点生的姓曲 是个女孩 起个什么名好? 用java做界面连接oracle数据库实现增删改查功能,具体步骤怎么做?_百度... 急于求成的歇后语 java怎样用jsp实现对数据库的增删改查操作 "拔苗助长"歇后语的下一句? 在java中怎么对数据库的数据进行操作 用拔苗助长__急于求成写出一句关于心情的歇后语 表示着急的歇后语 怎么用java向数据库中添加和删除数据 形容性急的歇后语~ java io 简单实现对数据的增删改查 java对pl sql数据库查询,增加,修改,删除操作 求北师大版高中英语必修一课本【电子版的】百度云下载地址,谢谢啦^V^ 形容着急的歇后语,求回答! 如何通过java实现对sqlite数据库的增删改查 在JAVA中对数据库进行增删改查 比如这些 String sql = "insert into u... 好了伤疤忘了痛的歌词 创建java的类实现对数据库的增删改查 哪位好心人帮妹妹写一下这首歌的歌词 谢谢 《好了伤疤忘了疼》 人教版高一英语必修1的英语书上第7页的2题,写给小东那个回信,怎么写? java怎样在控制台对数据库字段进行增删改查