原生JDBC

文章目录

1 未预编译的增删改查

//未预编译的增删改查
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class DML_DQL1test {
	static void add(){
		Connection con = null;//连接对象
		Statement st = null;//语句对象
		try{
			Class.forName("com.mysql.jdbc.Driver");//加载驱动
			//连接数据库               					   jdbc:mysql://<hostname>[<:3306>]/<dbname>
			con = DriverManager.getConnection("jdbc:mysql://192.168.16.241:3306/mytest", "root", "root");
			st = con.createStatement();//创建语句对象
			//增删改(用.executeUpdate)返回的int数据(受影响条数)--操作数据库
			int i = st.executeUpdate("insert into student(sname,gender,classid) values('赵云','女','3')");
			if(i>0){
				System.out.println("成功");
			}else{
				System.out.println("失败");
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			try {
				if (st != null)
					st.close();
				if (con != null)
					con.close();
			} catch (Exception e2) {
				e2.printStackTrace();
			}
		}
	}
	static void select(){//查
		Connection con = null;
		Statement st = null;
		ResultSet rs = null;//结果集对象
		try{
			Class.forName("com.mysql.jdbc.Driver");
			con = DriverManager.getConnection("jdbc:mysql://192.168.16.241:3306/mytest", "root", "root");
			st = con.createStatement();
			//查(用.executeQuery)--操作数据库
			rs = st.executeQuery("select * from student where sid=5");
			if(rs.next()){
				System.out.print("编号:"+rs.getInt("sid")+" ");
				System.out.print("姓名:"+rs.getString("sname")+" ");
				System.out.print("性别:"+rs.getString("gender")+" ");
				System.out.print("班级:"+rs.getInt("classid")+" ");
				System.out.print("分数:"+rs.getInt("score")+" ");
				System.out.println("课程:"+rs.getString("cusion")+" ");
			}
			rs = st.executeQuery("select sname as aa from student where sid=5");
			if(rs.next()){
				System.out.println("姓名:"+rs.getString("aa"));
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			try {
				if (rs != null)
					rs.close();
				if (st != null)
					st.close();
				if (con != null)
					con.close();
			} catch (Exception e2) {
				e2.printStackTrace();
			}
		}
	}
	public static void main(String[] args) {
		add();
		select();
	}
}

2 有预编译的增删改查

//预编译的增删改查
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class DML_DQL2test {
	static void update(){//增删改
		Connection con = null;//连接对象
		PreparedStatement pst = null;//预编译语句对象
		try{
			Class.forName("com.mysql.jdbc.Driver");//加载驱动
			//链接数据库
			con = DriverManager.getConnection("jdbc:mysql://192.168.16.241:3306/mytest", "root", "root");
			//创建预编译语句对象
			pst = con.prepareStatement("insert into student(sname,gender,classid) values(?,?,?)");
			pst.setString(1, "小黄第");//下标从1开始
			pst.setString(2,"男");
			pst.setInt(3,5);
			int i =pst.executeUpdate();//操作数据库 增删改
			System.out.println(i>0?"成功":"失败");
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			try {
				if (pst != null)
					pst.close();
				if (con != null)
					con.close();
			} catch (Exception e2) {
				e2.printStackTrace();
			}
		}
	}
	static void select(){//查
		Connection con = null;//连接对象
		PreparedStatement pst = null;//预编译语句对象
		ResultSet rs = null;
		try{
			Class.forName("com.mysql.jdbc.Driver");//加载驱动
			//链接数据库
			con = DriverManager.getConnection("jdbc:mysql://192.168.16.241:3306/mytest", "root", "root");
			//创建预编译语句对象
			pst = con.prepareStatement("select * from student ");
			rs = pst.executeQuery();//执行查(用.executeQuery)--操作数据库
			while(rs.next()){
				System.out.print("编号:"+rs.getInt("sid")+" ");
				System.out.print("姓名:"+rs.getString("sname")+" ");
				System.out.print("性别:"+rs.getString("gender")+" ");
				System.out.print("班级:"+rs.getInt("classid")+" ");
				System.out.print("分数:"+rs.getInt("score")+" ");
				System.out.println("课程:"+rs.getString("cusion")+" ");
			}
			
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			try {
				if (pst != null)
					pst.close();
				if (con != null)
					con.close();
			} catch (Exception e2) {
				e2.printStackTrace();
			}
		}
	}
	public static void main(String[] args) {
		//update();
		select();
	}
}

3 封装


//增删改查的封装
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
public class myDB{//工具类
	public static final String driver="com.mysql.jdbc.Driver";//
	public static final String url="jdbc:mysql://192.168.9.171:3306/test";
	public static final String user="root";
	public static final String password="root";
	Connection co=null;//连接对象
	PreparedStatement pst=null;//预编译语句对象
	ResultSet rs=null;//结果集对象
	public Connection getco(){//加载驱动和链接数据库的方法   返回的是连接对象co
		try{
			Class.forName(driver);//加载驱动
			co=DriverManager.getConnection(url, user, password);//连接数据库
		}catch(Exception e){
			e.printStackTrace();
		}
		return co;
	}
	public void closeAll(){//关闭
		try{
			if(rs!=null) rs.close();//关闭结果集对象
			if(pst!=null) pst.close();//关闭预编译语句对象
			if(co!=null) co.close();//关闭连接对象
		}catch(Exception e){
			e.printStackTrace();
		}
	} 
	public int update(String sql,Object...obj){//增删改  返回受影响条数、 int型
		int  result=0;
		try{
			co=getco();//调用 加载驱动器和链接数据库的方法
			pst=co.prepareStatement(sql);//预编译语句对象
			if(obj!=null){
				for(int i=0;i<obj.length;i++){
					pst.setObject(i+1, obj[i]);//下标从1开始
				}
			}
			result=pst.executeUpdate();//执行SQL语句 增删改
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			closeAll();//调用关闭的方法
		}
		return result;
	}
	public ResultSet select(String sql,Object...obj){//查 返回 结果集对象 rs
		try{
			co=getco();//调用 加载驱动器和链接数据库的方法
			pst=co.prepareStatement(sql);//预编译语句对象
			if(obj!=null){
				for(int i=0;i<obj.length;i++){
				pst.setObject(i+1, obj[i]);	//下标从1开始
				}
			}
			rs=pst.executeQuery();//执行SQL语句 查
		}catch(Exception e){
			e.printStackTrace();
		}
		return rs;
	}
}
import java.sql.ResultSet;
public class test {
public static void main(String[] args) {
		myDB db = new myDB();
		
		int i1=db.update("insert into student(name,gender,score) value (?,?,?)" , "小黑","女",75);
		System.out.println(i1>0?"成功":"失败");  //增数据
		int i2=db.update("update student set name=? where id=?", "小白",1201232065);
		System.out.println(i2>0?"成功":"失败");  //改数据
		int i3=db.update("delete from student where id=? or id=?", 1,2);
		System.out.println(i3>0?"成功":"失败");//删数据
		
		try {//查询数据
			//调用myDB中的select方法
			ResultSet rs = db.select("select * from student where id=?",1201232064);
			while (rs.next()) {
				System.out.println(rs.getString("name")+" "+rs.getInt("score"));
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			db.closeAll();//查询完 关闭
		}
	}
}


原文地址:https://blog.csdn.net/weixin_38323645/article/details/88842453

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

相关推荐


连接数据库的方式:第一种方式:ODBC:开放数据库连接是微软公司开放服务结构中有关数据库的一个组成部分,是数据库访问接口标准。ODBC是基于C语言实现的。提供了语言和数据库进行交互的一致性的接口,便于语言和数据库通信以及语言对数据库的各种操作。第二种方式:JDBC(本章重点)在Java中,
JDBCRequest 使用VariableNamesmysql:数据库连接池对象variousname:设置的变量名称 如何使用该变量a_#、b_#、c_#、d_#:代表行数a_1:第1行、第1列b_2:第2行、第2列
 1.JDBCDBC(JavaDataBaseConnectivity):Java数据库连接技术:具体讲就是通过Java连接广泛的数据库,并对表中数据执行增、删、改、查等操作的技术。JDBC是数据库与Java代码的桥梁。JDBC中定义了操作数据库的各种接口和类型:增删改基本操作:(1)获取连接:Connectionconnection=
1.需要jar包的支持:java.sqljavax.sqlmysql-conneter-java...连接驱动(必须要导入)<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.46</version></depend
1.简介Activiti是一个业务流程管理(BPM)框架,它是覆盖了业务流程管理,工作流,服务协作等领域的一个开源,灵活的,易扩展的可执行流程语言框架。在Java工作流引擎中可谓是主流,我们的项目也是使用的这个框架进行流程相关的开发。与流程息息相关的就是我们的流程定义BPMN文件,包含有一系列
1.JDBC体系系统一组规范:接口JDBC接口(API)包括两个层次:面向应用的API:JavaAPI,抽象接口,供应用开发人员使用(连接数据库,执行SQL语句,获得结果)面向数据库的API:JavaDriverAPI,供开发商开发数据库驱动程序JDBC是sun公司提供一套用于数据库操作的接口,java程序员只需要面向这套接
原文链接JDBC一般指Java数据库连接(JavaDatabaseConnectivity)api应用程序接口(API):可以调用或者使用类/接口/方法等去完成某个目标。API制定的类/方法可以做什么。API由开发人员调用。spi服务提供接口(SPI):需要继承或实现某些类/接口/方法等去完成某个目标。SPI告诉你
spring.shardingsphere.datasource.names=#省略数据源配置,请参考用法#标准分表配置spring.shardingsphere.rules.sharding.tables.<table-name>.actual-data-nodes=#描述数据源名称和实际表,分隔符为点,多个数据节点用逗号分隔,支持内联表达式。Absent表示仅对数据库进行分片
1问题Cannotloaddriverclass:com.mysql.cj.jdbc.Driver 2解决方案2.1已解决2.1.1首先,去查看项目中MySQL的版本如果找不到,说明可能还没有jdbc驱动,需要配置或者引入       (1)如果是直接引用的jar包,就去lib文件夹中查看,后缀是版
JDBC一、JDBC概述什么是JDBC?JDBC是使用Java语言操作关系型数据库的一套API。这套API是交由不同的数据库厂商实现的。我们利用JDBC编写操作数据库的代码,真正执行的是各个数据库的实现类(驱动)。全称:(JavaDataBaseConnectivity)Java数据库连接。JDBC的好处面向接口编
说明:/*需要引入依赖<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.18</version></dependency>*/代码:objec
1.概要在“配置元件”中添加“JDBCConnectionConfiguration”。配置如下图: 2.重点:配置人大金仓数据库连接下面着重介绍人大金仓数据库连接配置:DatabaseURL输入:jdbc:kingbase8://192.132.180.101:54321/hj_yc   (备注:应输入 jdbc:kingbase8://IP:
JDBC概念:JavaDataBaseconnectivityJava数据库连接,Java语言操作数据库JDBc本质∶其实是官方(sun公司)定义的一套操作所有关系型数据库的规则,即接口。各个数据库商去实现这套接口,提供数据库驱动jar包。我们可以使用这套接口(JDBC)编程,真正执行的代码是驱动jar包中的实现类
Mybatis核心配置文件习惯上命名mybatis-config.xml,整合Spring之后,整个配置文件可以省略核心配置文件主要用于配置连接数据库的环境以及MyBatis的全局配置信息标签顺序顺序出错会报错propertiessettingstypeAliasestypeHandlersobjectFactoryobjectWrapperFa
JDBC1.概念:JavaDataBaseConnectivityJava数据库连接,Java语言操作数据库JDBC本质:其实是官方(sun公司)定义的一套操作所有关系型数据库的规则,即接口。各个数据库厂商去实现这套接口,提供数据库驱动jar包。我们可以使用这套接口(JDBC)编程,真正执行的代码是驱动jar包中的实现类。
  1.出现这个问题的原因 :在安装mysql的时候时区设置的不正确,mysql默认的是美国的时区,而我们中国大陆要比他们迟8小时,采用+8:00格式使用的数据库是MySQL,没有指定MySQL驱动版本的情况下它自动依赖的驱动是8.0.12很高的版本,这是由于数据库和系统时区差异所造成的,在jdbc连
一、环境准备1.数据库创建2个库2个表:xdclass_shop_order_0product_order_0product_order_1ad_configproduct_order_item_0product_order_item_1xdclass_shop_order_1product_order_0product_order_1ad_configproduct_order_item_0product_order_item_1数据
编写配置文件(application.yml)spring:datasource:username:rootpassword:123456url:jdbc:mysql://localhost:3306/mybatis?useUnicode&characterEncoding=utf-8driver-class-name:com.mysql.cj.jdbc.Driver测试连接@SpringBootTestclassSprin
结构图pom.xml<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http:/
MySql链接url参数详解 jdbc:mysql://[host:port],[host:port].../[database][?参数名1][=参数值1][&参数名2][=参数值2]... 常用的几个较为重要的参数: 参数名称参数说明缺省值最低版本要求 user 数据库用户名(用于连接数据库) 所有版本passWord用户密码(用于连接