当前位置:首页 » 数据仓库 » jdbc查询mysql数据库
扩展阅读
webinf下怎么引入js 2023-08-31 21:54:13
堡垒机怎么打开web 2023-08-31 21:54:11

jdbc查询mysql数据库

发布时间: 2023-02-03 09:17:40

❶ 怎样使用jdbc访问mysql数据库

JDBC连接MYSQL数据库:

package cn.outofmemory.test;

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

public class Mysql {
public static void main(String arg[]) {
try {
Connection con = null; //定义一个MYSQL链接对象
Class.forName("com.mysql.jdbc.Driver").newInstance(); //MYSQL驱动
con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test", "root", "root"); //链接本地MYSQL
System.out.print("yes");
} catch (Exception e) {
System.out.print("MYSQL ERROR:" + e.getMessage());
}

}
}

Class.forName("com.mysql.jdbc.Driver").newInstance(); 我们链接的是MYSQL数据库,所以需要一个MYSQL的数据库驱动,如果你的环境中没有安装,
可以下载:mysql-connector-java-5.1.17-bin.jar JAR包,然后放进jdk1.6.0_37\jre\lib\ext 重启eclispe 就可以在JRE系统库中看到。

con = DriverManager.getConnection;("jdbc:mysql://127.0.0.1:3306/test", "root", "root"); 是链接数据库的语句,
返回Connection con;对象。参数格式:("jdbc:mysql://ip:端口/数据库名称", 用户名,密码)

写入一条数据

package main;

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

public class Mysql {

/**
* 入口函数
* @param arg
*/
public static void main(String arg[]) {
try {
Connection con = null; //定义一个MYSQL链接对象
Class.forName("com.mysql.jdbc.Driver").newInstance(); //MYSQL驱动
con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test", "root", "root"); //链接本地MYSQL

Statement stmt; //创建声明
stmt = con.createStatement();

//新增一条数据
stmt.executeUpdate("INSERT INTO user (username, password) VALUES ('init', '123456')");
ResultSet res = stmt.executeQuery("select LAST_INSERT_ID()");
int ret_id;
if (res.next()) {
ret_id = res.getInt(1);
System.out.print(ret_id);
}

} catch (Exception e) {
System.out.print("MYSQL ERROR:" + e.getMessage());
}

}
}

stmt.executeUpdate INSERT; DELETE; UPDATE;语句都用executeUpdate函数来操作
stmt.executeQuery SELECT;语句都用stmt.executeQuery函数来操作
ResultSet res = stmt.executeQuery;("select LAST;_INSERT_ID()");
查询最后插入数据的ID号,返回ResultSet res;对象

删除和更新数据
package main;

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

public class Mysql {

/**
* 入口函数
* @param arg
*/
public static void main(String arg[]) {
try {
Connection con = null; //定义一个MYSQL链接对象
Class.forName("com.mysql.jdbc.Driver").newInstance(); //MYSQL驱动
con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test", "root", "root"); //链接本地MYSQL

Statement stmt; //创建声明
stmt = con.createStatement();

//新增一条数据
stmt.executeUpdate("INSERT INTO user (username, password) VALUES ('init', '123456')");
ResultSet res = stmt.executeQuery("select LAST_INSERT_ID()");
int ret_id;
if (res.next()) {
ret_id = res.getInt(1);
System.out.print(ret_id);
}

//删除一条数据
String sql = "DELETE FROM user WHERE id = 1";
long deleteRes = stmt.executeUpdate(sql); //如果为0则没有进行删除操作,如果大于0,则记录删除的条数
System.out.print("DELETE:" + deleteRes);

//更新一条数据
String updateSql = "UPDATE user SET username = 'xxxx' WHERE id = 2";
long updateRes = stmt.executeUpdate(updateSql);
System.out.print("UPDATE:" + updateRes);

} catch (Exception e) {
System.out.print("MYSQL ERROR:" + e.getMessage());
}

}
}

删除和更新数据都使用stmt.executeUpdate函数。
删除和更新数据都会返回一个Long的结果,如果为0,则删除或者更新失败,如果大于0则是操作删除的记录数

查询语句
package main;

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

public class Mysql {

/**
* 入口函数
* @param arg
*/
public static void main(String arg[]) {
try {
Connection con = null; //定义一个MYSQL链接对象
Class.forName("com.mysql.jdbc.Driver").newInstance(); //MYSQL驱动
con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test", "root", "root"); //链接本地MYSQL

Statement stmt; //创建声明
stmt = con.createStatement();

//新增一条数据
stmt.executeUpdate("INSERT INTO user (username, password) VALUES ('init', '123456')");
ResultSet res = stmt.executeQuery("select LAST_INSERT_ID()");
int ret_id;
if (res.next()) {
ret_id = res.getInt(1);
System.out.print(ret_id);
}

//删除一条数据
String sql = "DELETE FROM user WHERE id = 1";
long deleteRes = stmt.executeUpdate(sql); //如果为0则没有进行删除操作,如果大于0,则记录删除的条数
System.out.print("DELETE:" + deleteRes);

//更新一条数据
String updateSql = "UPDATE user SET username = 'xxxx' WHERE id = 2";
long updateRes = stmt.executeUpdate(updateSql);
System.out.print("UPDATE:" + updateRes);

//查询数据并输出
String selectSql = "SELECT * FROM user";
ResultSet selectRes = stmt.executeQuery(selectSql);
while (selectRes.next()) { //循环输出结果集
String username = selectRes.getString("username");
String password = selectRes.getString("password");
System.out.print("\r\n\r\n");
System.out.print("username:" + username + "password:" + password);
}

} catch (Exception e) {
System.out.print("MYSQL ERROR:" + e.getMessage());
}

}
}

查询语句使用stmt.executeQuery函数

rs.absolute() //绝对位置,负数表示从后面数
rs.first()第一条
rs.last()最后一条
rs.previoust()前一条
rs.next()后一条
rs.beforeFirst()第一条之前
rs.afterLast()最后之后
rs.isFirst(),rs.isLast(),rs.isBeforeFirst(),rs.isAfterLast

❷ 如何实现JDBC连接mysql数据库

1.导入mysql数据库的驱动jar包
如我的导的是mysql-connector-java-5.1.40.jar
2.注册驱动
注册驱动代码为:Class.forName("com.mysql.jdbc.Driver")
3.获取连接
Connection con = DriverManager.getConnection(url,username,password)
其中url为 jdbc:mysql://localhost:3306/xun?useSSL=false,后面那个xun为数据库的库名,如果不使用加密的话,?useSSL=false这个其实也可以省略,省略后为jdbc:mysql://localhost:3306/xun,不过最好还是别省略哈。
4.获取PrepareStatement并发送sql查询语句
String sql = "select * from user where username = ?"(这个查询语句为随便举的例子哈)
PreparedStatement pst = con.preparedStatement(sql);

pst.setString(1,"zengjiaxun");
ResultSet rs = pst.executeQuery();
注意,执行查询使用的是executeQuery()方法,此方法返回的是ResultSet,ResultSet为结果集,封装了查询结果。插入,删除,修改用的是executeUpdate()方法。
pst.clearParameters();
执行sql后记得关闭相应的流。。

❸ 怎么通过jdbc连接mysql数据库

•创建一个以JDBC连接数据库的程序,包含7个步骤:
1、加载JDBC驱动程序:
在连接数据库之前,首先要加载想要连接的数据库的驱动到JVM(Java虚拟机),
这通过java.lang.Class类的静态方法forName(String className)实现。
例如:
try{
//加载MySql的驱动类
Class.forName("com.mysql.jdbc.Driver") ;
}catch(ClassNotFoundException e){
System.out.println("找不到驱动程序类 ,加载驱动失败!");
e.printStackTrace() ;
}
成功加载后,会将Driver类的实例注册到DriverManager类中。
2、提供JDBC连接的URL
•连接URL定义了连接数据库时的协议、子协议、数据源标识。
•书写形式:协议:子协议:数据源标识
协议:在JDBC中总是以jdbc开始
子协议:是桥连接的驱动程序或是数据库管理系统名称。
数据源标识:标记找到数据库来源的地址与连接端口。
例如:(MySql的连接URL)
jdbc:mysql:
//localhost:3306/test?useUnicode=true&characterEncoding=gbk ;
useUnicode=true:表示使用Unicode字符集。如果characterEncoding设置为
gb2312或GBK,本参数必须设置为true 。characterEncoding=gbk:字符编码方式。
3、创建数据库的连接
•要连接数据库,需要向java.sql.DriverManager请求并获得Connection对象,
该对象就代表一个数据库的连接。
•使用DriverManager的getConnectin(String url , String username ,
String password )方法传入指定的欲连接的数据库的路径、数据库的用户名

❹ JDBC是什么

JDBC代表Java数据库连接,这对Java编程语言和广泛的数据库之间独立于数据库的连接标准的JavaAPI。

JDBC库包含的API为每个通常与数据库的使用相关联的任务:

使得连接到数据库

创建SQL或MySQL语句

执行SQL或MySQL的查询数据库

查看和修改结果记录从根本上说,JDBC是一种规范,它提供的接口,一套完整的,允许便携式访问底层数据库。可以用Java来写不同类型的可执行文件,如:

Java应用程序

JavaApplets

JavaServlets

JavaServerPages(JSP)

EnterpriseJavaBeans(EJBs)所有这些不同的可执行文件就可以使用JDBC驱动程序来访问数据库,并把存储的数据的优势。

JDBC提供了相同的功能,ODBC,允许Java程序包含与数据库无关的代码。

先决条件:

以前正如期进行本教程,需要具备以下两个主题内容很好的了解:

核心Java编程

SQL或MySQL数据库

JDBC架构:

JDBCAPI支持两层和三层处理模型进行数据库访问,但在一般的JDBC体系结构由两层组成:

JDBCAPI:提供了应用程序对JDBC的管理连接。

JDBCDriverAPI:支持JDBC管理到驱动器连接。JDBCAPI的使用驱动程序管理器和数据库特定的驱动程序提供透明的连接到异构数据库。

JDBC驱动程序管理器可确保正确的驱动程序来访问每个数据源。该驱动程序管理器能够支持连接到多个异构数据库的多个并发的驱动程序。

以下是结构图,它显示了驱动程序管理器方面的JDBC驱动程序和Java应用程序的位置:


常见的JDBC组件:

JDBCAPI提供了以下接口和类:

DriverManager:这个类管理数据库驱动程序的列表。内容是否符合从Java应用程序使用的通信子协议正确的数据库驱动程序的连接请求。识别JDBC在一定子协议的第一个驱动器将被用来建立数据库连接。

Driver:此接口处理与数据库服务器通信。很少直接与驱动程序对象。相反,使用DriverManager中的对象,它管理此类型的对象。它也抽象与驱动程序对象工作相关的详细信息

Connection:此接口与接触数据库的所有方法。连接对象表示通信上下文,即,与数据库中的所有的通信是通过唯一的连接对象。

Statement:可以使用这个接口创建的对象的SQL语句提交到数据库。一些派生的接口接受除执行存储过程的参数。

ResultSet:这些对象保存从数据库后,执行使用Statement对象的SQL查询中检索数据。它作为一个迭代器,让您可以通过移动它的数据。

SQLException:这个类处理发生在一个数据库应用程序的任何错误。

❺ 在使用jdbc将mysql中的数据查询出来更新到sqlserve数据库时,怎么自动转换类型

在使用jdbc将mysql中的数据查询出来更新到sqlserve数据库时,怎么自动转换类型
JDBC操作MySQL数据库的步骤

1、准备MySQL数据库驱动包:mysql-connector-java-5.0.8-bin.jar,一个项目中只能存在一个版本的驱动包
a、复制该驱动包,粘贴到项目中
b、选中项目里的驱动包,右键->Build Path->Add to Build Path
2、在类里写代码加载驱:决定连接哪种数据库
a、Class.forName("com.mysql.jdbc.Driver");
b、必须进行异常处理:ClassNotFoundException
3、连接数据库
a、Connection con=DriverManager.getConnection("连接字符串", "用户名", "密码");
b、连接字符串格式固定,不同数据库,格式不同:jdbc:mysql://要连接的计算机名称:端口号/要连接的数据库名称
c、必须进行异常处理:SQLException
4、拼写要执行的sql语句,必须是可以在数据库中执行的
5、创建执行sql语句的对象
a、Statement stmt=con.createStatement();
b、注意:Statement必须来自于java.sql包中
6、执行sql语句
a、执行insert、update和delete语句:int row=stmt.executeUpdate(sql);返回影响行数
b、执行查询语句:ResultSet rs=stmt.executeQuery(sql);返回查询结果
c、执行任意sql语句(DDL、DCL、DML和DQL等)
7、对执行结果进行处理
a、执行更新语句:判断影响行数是否为0,0表示失败,非0表示成功
b、对查询结果进行处理:
1) 结果集需要先移动、后取值 :rs.next();int id=rs.getInt(1);
String name=rs.getString("loginName");
2) 结果集有多条时,需要循环操作:
while(rs.next()){ System.out.println(rs.getInt(1)+"\t"+rs.getString(2)+"\t"+rs.getString(3)+"\t"+rs.getString(4)+"\t"+rs.getInt(5));
}
3) 不确定是否有查询结果时:if(rs.next()){说明有查询结果}else{没有查询结果}
4) 使用了聚合函数,一定有查询结果,查询结果是一行一列:
rs.next();
int result=rs.getInt(1);
注意:结果集取值时取出的时查询语句中包含的字段,与表中字段无关
9、关闭相关对象(先关闭结果集对象、在关闭执行语句对象,最后关闭连接对象)
例如:执行查询语句
Scanner input=new Scanner(System.in);
System.out.print("请输入登录名: ");
String name=input.next();
System.out.print("请输入密码: ");
String pass=input.next();

try {
Class.forName("com.mysql.jdbc.Driver");
Connection con=DriverManager.getConnection("jdbc:mysql://localhost:3306/userdb", "root", "root");
String sql="select COUNT(*) from UserInfo where loginName='"+name+"' and loginPass='"+pass+"'";
Statement stmt=con.createStatement();
ResultSet rs=stmt.executeQuery(sql);
rs.next();
int result=rs.getInt(1);
if(result!=0){
System.out.println("登录成功!");
}else{
System.out.println("用户名或密码错误,请重新登录!");
}
rs.close();
stmt.close();
con.close();
} catch (ClassNotFoundException e) {
System.out.println("加载驱动错误:"+e.getMessage());
} catch (SQLException e) {
System.out.println("数据库操作错误:"+e.getMessage());
}
执行添加、修改和删除语句
try {
//加载驱动
Class.forName("com.mysql.jdbc.Driver");
//连接数据库
Connection con=DriverManager.getConnection("jdbc:mysql://localhost:3306/userdb", "root", "root");
//拼写要执行的sql语句
String sql="update UserInfo set loginPass='111' where loginName='a'";
//String sql="insert UserInfo values(default,'test','test')";
//String sql="delete from UserInfo where loginName='a'";
//创建执行语句对象
Statement stmt=con.createStatement();
//执行
int row=stmt.executeUpdate(sql);
//处理结果
if(row==0){
System.out.println("修改失败!");
}else{
System.out.println("修改成功!");
}
//关闭
stmt.close();
con.close();
} catch (ClassNotFoundException e) {
System.out.println("驱动加载错误:"+e.getMessage());
} catch (SQLException e) {
System.out.println("数据库操作错误:"+e.getMessage());
}

❻ eclipse用jdbc连接mysql数据库时,url是填什么怎样找出地址

1、首先登陆mysql,查看mysql的数据情况,select * from test_data1 t

❼ java中怎样对mysql数据库查询

importjava.sql.Connection;
importjava.sql.DriverManager;
importjava.sql.ResultSet;
importjava.sql.ResultSetMetaData;
importjava.sql.Statement;
importjava.util.Hashtable;


publicclassGetDBFiled{
publicstaticvoidconn(){
Stringdriver="com.mysql.jdbc.Driver";
Stringurl="jdbc:mysql://localhost:3306/databaseName";
Stringuser="root";
Stringpassword="密码";
try{
Class.forName(driver);
Connectionconn=DriverManager.getConnection(url,user,password);
if(!conn.isClosed()){
Stringsql="select*frompic";
System.out.println("!");
Statementstatement=conn.createStatement();
ResultSetrs=statement.executeQuery(sql);
if(rs.next()){
//得到ResultSetMetaData
ResultSetMetaDatarsmd=rs.getMetaData();
System.out.println(rsmd.getColumnCount());
for(inti=1;i<=rsmd.getColumnCount();i++){
Hashtablehst=newHashtable();
//把字段名放入Name
Stringname=String.valueOf(rsmd.getColumnLabel(i));
hst.put("Name",name);
//把字段类型放入Type
Stringtype=String.valueOf(rsmd.getColumnType(i));
hst.put("Type",type);
System.out.println(hst.get("Name")+""+hst.get("Type"));
}
}
}
}catch(Exceptione){

System.out.println("出现异常");
}

}
}

❽ 用JDBC查询MYSQL元数据的问题,请高手解答!

在建立数据库 连接的 时候

这么写:

DriverManager.getConnection("jdbc:mysql://localhost:3306/student?user=root&password=root&useUnicode=true&characterEncoding=utf-8");

&useUnicode=true&characterEncoding=utf-8" 主要是这句话。