如何在Java程序中访问mysql数据库中的数据并进行简单的 *** 作

如何在Java程序中访问mysql数据库中的数据并进行简单的 *** 作,第1张

创建一个javaProject,并输入如下java代码:

package linkimport java.sql.*/*** 使用JDBC连接数据库MySQL的过程* DataBase:fuck, table:person;* 使用myeclipse对mysql数据库进行增删改查的基本 *** 作。*/public class JDBCTest { public static Connection getConnection() throws SQLException, java.lang.ClassNotFoundException { //第一步:加载MySQL的JDBC的驱动 Class.forName("com.mysql.jdbc.Driver") //取得连接的url,能访问MySQL数据库的用户名,密码;jsj:数据库名 String url = "jdbc:mysql://localhost:/fuck" String username = "root" String password = "" //第二步:创建与MySQL数据库的连接类的实例 Connection con = DriverManager.getConnection(url, username, password) return con } public static void main(String args[]) { try { //第三步:获取连接类实例con,用con创建Statement对象类实例 sql_statement Connection con = getConnection() Statement sql_statement = con.createStatement() //如果同名数据库存在,删除 //sql_statement.executeUpdate("drop table if exists student") //执行了一个sql语句生成了一个名为student的表 //sql_statement.executeUpdate("create table student (id int not null auto_increment, name varchar() not null default 'name', math int not null default , primary key (id) )") //向person表中插入数据 sql_statement.executeUpdate("insert person values(, 'liying', )") sql_statement.executeUpdate("insert person values(, 'jiangshan', )") sql_statement.executeUpdate("insert person values(, 'wangjiawu', )") sql_statement.executeUpdate("insert person values(, 'duchangfeng', )") //第四步:执行查询,用ResultSet类的对象,返回查询的结果 String query = "select * from person" ResultSet result = sql_statement.executeQuery(query) //显示数据中person表中的内容: System.out.println("person表中的数据如下:") System.out.println("------------------------") System.out.println("序号" + " " + "姓名" + " " + "分数") System.out.println("------------------------") //对获得的查询结果进行处理,对Result类的对象进行 *** 作 while (result.next()) { int number = result.getInt("number") String name = result.getString("name") String mathsorce = result.getString("mathsorce") //取得数据库中的数据 System.out.println(" " + number + " " + name + " " + mathsorce) } //关闭连接和声明 sql_statement.close() con.close() } catch(java.lang.ClassNotFoundException e) { System.err.print("ClassNotFoundException") System.err.println(e.getMessage()) } catch (SQLException ex) { System.err.println("SQLException: " + ex.getMessage()) } } }

注意有几个地方是你需要修改的。

如下图中的url和账号,密码需要与你自己的相一致。

这些需要访问的数据必须要与数据库中的类型相互匹配,才能打印出正确的结果。

右键单击工程名-->Build Path -->Configure Biuld Path -->Libraries -->Add External JARs -->加入一个jdbc包(具体请查考Mysql的简单使用(一))--->ok

这时,在包下会多了一个Referenced Libraries包文件,则说明配置已经成功。

点击Run as --->运行Java Application --->JDBCTest--link--->显示结果如下:

1、加载驱动程序。

2、创建连接对象。

3、创建sql语句执行对象 。

4、执行sql语句。

5、对执行结果进行处理。

6、关闭相关的连接对象即可(顺序跟声明的顺序相反)。

处理结果两种情况:

1、执行更新返回的是本次 *** 作影响到的记录数。

2、执行查询返回的结果是一个ResultSet对象。

ResultSet包含符合SQL语句中条件的所有行,并且它通过一套get方法提供了对这些 行中数据的访问。

扩展资料:

Statement

要执行SQL语句,必须获得java.sql.Statement实例,Statement实例分为以下3 种类型:

1、执行静态SQL语句。通常通过Statement实例实现。

2、执行动态SQL语句。通常通过PreparedStatement实例实现。

3、执行数据库存储过程。通常通过CallableStatement实例实现。

参考资料:百度百科JAVA

Java可以使用JDBC访问数据库,也可以使用各类ORM框架访问数据库,但这些框架最终还是通过JDBC访问数据库,它们只是封装了数据库 *** 作,而使得开发者可以减少这部分消耗。因此,本文只讲解JDBC访问方式。

JDBC访问一般分为如下流程:

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 )方法传入指定的欲连接的数据库的路径、数据库的用户名和密码来获得。

例如:

//连接MySql数据库,用户名和密码都是root

String url = "jdbc:mysql://localhost:3306/test"

String username = "root"

String password = "root"

try{

Connection con =

DriverManager.getConnection(url , username , password )

}catch(SQLException se){

System.out.println("数据库连接失败!")

se.printStackTrace()

}

4、创建一个Statement

•要执行SQL语句,必须获得java.sql.Statement实例,Statement实例分为以下3种类型:

1、执行静态SQL语句。通常通过Statement实例实现。

2、执行动态SQL语句。通常通过PreparedStatement实例实现。

3、执行数据库存储过程。通常通过CallableStatement实例实现。

具体的实现方式:

Statement stmt = con.createStatement()

PreparedStatement pstmt = con.prepareStatement(sql)

CallableStatement cstmt = con.prepareCall("{CALL demoSp(? , ?)}")

5、执行SQL语句

Statement接口提供了三种执行SQL语句的方法:executeQuery 、executeUpdate和execute

1、ResultSet executeQuery(String sqlString):执行查询数据库的SQL语句,返回一个结果集(ResultSet)对象。

2、int executeUpdate(String sqlString):用于执行INSERT、UPDATE或DELETE语句以及SQL DDL语句,如:CREATE TABLE和DROP TABLE等

3、execute(sqlString):用于执行返回多个结果集、多个更新计数或二者组合的语句。

具体实现的代码:

ResultSet rs = stmt.executeQuery("SELECT * FROM ...")

int rows = stmt.executeUpdate("INSERT INTO ...")

boolean flag = stmt.execute(String sql)

6、处理结果

两种情况:

1、执行更新返回的是本次 *** 作影响到的记录数。

2、执行查询返回的结果是一个ResultSet对象。

•ResultSet包含符合SQL语句中条件的所有行,并且它通过一套get方法提供了对这些行中数据的访问。

•使用结果集(ResultSet)对象的访问方法获取数据:

while(rs.next()){

String name = rs.getString("name")

String pass = rs.getString(1)// 此方法比较高效(列是从左到右编号的,并且从列1开始)

}

7、关闭JDBC对象

*** 作完成以后要把所有使用的JDBC对象全都关闭,以释放JDBC资源,关闭顺序和声明顺序相反:

1、关闭记录集

2、关闭声明

3、关闭连接对象

if(rs != null){ // 关闭记录集

try{

rs.close()

}catch(SQLException e){

e.printStackTrace()

}

}

if(stmt != null){ // 关闭声明

try{

stmt.close()

}catch(SQLException e){

e.printStackTrace()

}

}

if(conn != null){ // 关闭连接对象

try{

conn.close()

}catch(SQLException e){

e.printStackTrace()

}

}


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/sjk/9993834.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-05-04
下一篇 2023-05-04

发表评论

登录后才能评论

评论列表(0条)

保存