「java数据库操作」java数据库操作框架有哪些

admin 2023-01-02 18:51:09 652

本篇文章给大家谈谈java数据库操作，以及java数据库操作框架有哪些对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。

本文目录一览：

1、java中使用JDBC完成数据库操作的基本步骤是什么？
2、java的数据库操作
3、在Java中如何对数据库中的数据进行操作？
4、怎么使用JAVA连接数据库?
5、java程序操作MySQL数据库

java中使用JDBC完成数据库操作的基本步骤是什么？

创建一个以JDBC连接数据库的程序，包含7个步骤： \x0d\x0a 1、加载JDBC驱动程序： \x0d\x0a 在连接数据库之前，首先要加载想要连接的数据库的驱动到JVM（Java虚拟机）， \x0d\x0a 这通过java.lang.Class类的静态方法forName(String className)实现。 \x0d\x0a 例如： \x0d\x0a try{ \x0d\x0a //加载MySql的驱动类 \x0d\x0a Class.forName("com.mysql.jdbc.Driver") ; \x0d\x0a }catch(ClassNotFoundException e){ \x0d\x0a System.out.println("找不到驱动程序类，加载驱动失败！"); \x0d\x0a e.printStackTrace() ; \x0d\x0a } \x0d\x0a 成功加载后，会将Driver类的实例注册到DriverManager类中。 \x0d\x0a 2、提供JDBC连接的URL \x0d\x0a •连接URL定义了连接数据库时的协议、子协议、数据源标识。 \x0d\x0a •书写形式：协议：子协议：数据源标识 \x0d\x0a 协议：在JDBC中总是以jdbc开始 \x0d\x0a 子协议：是桥连接的驱动程序或是数据库管理系统名称。 \x0d\x0a 数据源标识：标记找到数据库来源的地址与连接端口。 \x0d\x0a 例如：（MySql的连接URL） \x0d\x0a jdbc:mysql: \x0d\x0a //localhost:3306/test?useUnicode=truecharacterEncoding=gbk ; \x0d\x0a useUnicode=true：表示使用Unicode字符集。如果characterEncoding设置为 \x0d\x0a gb2312或GBK，本参数必须设置为true 。characterEncoding=gbk：字符编码方式。 \x0d\x0a 3、创建数据库的连接 \x0d\x0a •要连接数据库，需要向java.sql.DriverManager请求并获得Connection对象， \x0d\x0a 该对象就代表一个数据库的连接。 \x0d\x0a •使用DriverManager的getConnectin(String url , String username , \x0d\x0a String password )方法传入指定的欲连接的数据库的路径、数据库的用户名和 \x0d\x0a 密码来获得。 \x0d\x0a 例如： \x0d\x0a //连接MySql数据库，用户名和密码都是root \x0d\x0a String url = "jdbc:mysql://localhost:3306/test" ; \x0d\x0a String username = "root" ; \x0d\x0a String password = "root" ; \x0d\x0a try{ \x0d\x0a Connection con = \x0d\x0a DriverManager.getConnection(url , username , password ) ; \x0d\x0a }catch(SQLException se){ \x0d\x0a System.out.println("数据库连接失败！"); \x0d\x0a se.printStackTrace() ; \x0d\x0a } \x0d\x0a 4、创建一个Statement \x0d\x0a •要执行SQL语句，必须获得java.sql.Statement实例，Statement实例分为以下3 \x0d\x0a 种类型： \x0d\x0a 1、执行静态SQL语句。通常通过Statement实例实现。 \x0d\x0a 2、执行动态SQL语句。通常通过PreparedStatement实例实现。 \x0d\x0a 3、执行数据库存储过程。通常通过CallableStatement实例实现。 \x0d\x0a 具体的实现方式： \x0d\x0a Statement stmt = con.createStatement() ; \x0d\x0a PreparedStatement pstmt = con.prepareStatement(sql) ; \x0d\x0a CallableStatement cstmt = \x0d\x0a con.prepareCall("{CALL demoSp(? , ?)}") ; \x0d\x0a 5、执行SQL语句 \x0d\x0a Statement接口提供了三种执行SQL语句的方法：executeQuery 、executeUpdate \x0d\x0a 和execute \x0d\x0a 1、ResultSet executeQuery(String sqlString)：执行查询数据库的SQL语句 \x0d\x0a ，返回一个结果集（ResultSet）对象。 \x0d\x0a 2、int executeUpdate(String sqlString)：用于执行INSERT、UPDATE或 \x0d\x0a DELETE语句以及SQL DDL语句，如：CREATE TABLE和DROP TABLE等 \x0d\x0a 3、execute(sqlString):用于执行返回多个结果集、多个更新计数或二者组合的 \x0d\x0a 语句。 \x0d\x0a 具体实现的代码： \x0d\x0a ResultSet rs = stmt.executeQuery("SELECT * FROM ...") ; \x0d\x0a int rows = stmt.executeUpdate("INSERT INTO ...") ; \x0d\x0a boolean flag = stmt.execute(String sql) ; \x0d\x0a 6、处理结果 \x0d\x0a 两种情况： \x0d\x0a 1、执行更新返回的是本次操作影响到的记录数。 \x0d\x0a 2、执行查询返回的结果是一个ResultSet对象。 \x0d\x0a • ResultSet包含符合SQL语句中条件的所有行，并且它通过一套get方法提供了对这些 \x0d\x0a 行中数据的访问。 \x0d\x0a • 使用结果集（ResultSet）对象的访问方法获取数据： \x0d\x0a while(rs.next()){ \x0d\x0a String name = rs.getString("name") ; \x0d\x0a String pass = rs.getString(1) ; // 此方法比较高效 \x0d\x0a } \x0d\x0a （列是从左到右编号的，并且从列1开始） \x0d\x0a 7、关闭JDBC对象 \x0d\x0a 操作完成以后要把所有使用的JDBC对象全都关闭，以释放JDBC资源，关闭顺序和声 \x0d\x0a 明顺序相反： \x0d\x0a 1、关闭记录集 \x0d\x0a 2、关闭声明 \x0d\x0a 3、关闭连接对象 \x0d\x0a if(rs != null){ // 关闭记录集 \x0d\x0a try{ \x0d\x0a rs.close() ; \x0d\x0a }catch(SQLException e){ \x0d\x0a e.printStackTrace() ; \x0d\x0a } \x0d\x0a } \x0d\x0a if(stmt != null){ // 关闭声明 \x0d\x0a try{ \x0d\x0a stmt.close() ; \x0d\x0a }catch(SQLException e){ \x0d\x0a e.printStackTrace() ; \x0d\x0a } \x0d\x0a } \x0d\x0a if(conn != null){ // 关闭连接对象 \x0d\x0a try{ \x0d\x0a conn.close() ; \x0d\x0a }catch(SQLException e){ \x0d\x0a e.printStackTrace() ; \x0d\x0a } \x0d\x0a }

java的数据库操作

ResultSet 是返回值

比如你要用select * from 表名来查询这张表的数据

那么你查询出来的数据总得返回给你好叫你看见你查询出来的是什么.

那么这个返回会来的数据就在ResultSet里

通过遍历ResultSet 就可以获取你查询出来的数据了

至于怎么遍历ResultSet 还请楼主请教老师或者baidu/google.......

在Java中如何对数据库中的数据进行操作？

package com.dao;import java.sql.*;import javax.naming.Context;

import javax.naming.InitialContext;

import javax.naming.NamingException;

import javax.sql.DataSource;public class BaseDao {

/**

* 创建数据库连接及关闭

// 打开连接

public static Connection getConnection() {

Connection con = null; /*************************** oracl 的连接 ***************************************/

// try { // Class.forName("oracle.jdbc.driver.OracleDriver");

// con = DriverManager.getConnection(

// "jdbc:oracle:thin:@127.0.0.1:1521:orcl", "bbs", "sa");

// } catch (ClassNotFoundException e) {

// e.printStackTrace();

// } catch (SQLException e) {

// e.printStackTrace();

// }

/******************************* sqlerver 的连接 ******************************/

try {

Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");

con = DriverManager.getConnection(

"jdbc:sqlserver://127.0.0.1:1433;databasename=bbs", "sa",

"zhou");

} catch (ClassNotFoundException e) {

e.printStackTrace();

} catch (SQLException e) {

e.printStackTrace();

}

/*********************************************************************/

return con;

} // 关闭

public static void closeAll(Connection connection,

PreparedStatement pStatement, ResultSet res) {

try {

if (connection != null (!connection.isClosed())) {

connection.close();

}

if (res != null) {

res.close();

res = null;

}

if (pStatement != null) {

pStatement.close();

pStatement = null;

}

} catch (Exception e) {

e.printStackTrace();

}

对数据库增删改查package com.dao;import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.List;import com.entity.News;public class NewsDao {

Connection con = null;

PreparedStatement pstmt = null;

ResultSet rs = null;

/**

* 添加新闻

* @param news

* @return

public boolean newsAdd(News news){

boolean result=false;

String sql="insert into news values(?,?)";

con=BaseDao.getConnection();

try {

pstmt=con.prepareStatement(sql);

pstmt.setString(1, news.getContent());

pstmt.setString(2, FormatTime.newTime());

int i = 0;

i = pstmt.executeUpdate();

if (i 0)

result = true;

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return result;

}

/**

* 修改新闻

* @param news

* @return

public boolean updateNews(News news){

boolean result=false;

con=BaseDao.getConnection();

try {

pstmt=con.prepareStatement("update news set content=? ,writedate=? where newsid=?");

pstmt.setString(1, news.getContent());

pstmt.setString(2, FormatTime.newTime());

pstmt.setInt(3, news.getNewsID());

int i = 0;

i = pstmt.executeUpdate();

if (i 0)

result = true;

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return result;

}

/**

* 删除新闻

* @param news

* @return

public boolean deleteNews(News news){

boolean result=false;

String sql=String.format("delete from news where newsid=%d", news.getNewsID());

con=BaseDao.getConnection();

try {

pstmt=con.prepareStatement(sql);

int i = 0;

i = pstmt.executeUpdate();

if (i 0)

result = true;

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return result;

}

/**

* 删除新闻重载

* @param newsId

* @return

public boolean deleteNews(int newsId){

boolean result=false;

String sql=String.format("delete from news where newsid=%d", newsId);

con=BaseDao.getConnection();

try {

pstmt=con.prepareStatement(sql);

int i = 0;

i = pstmt.executeUpdate();

if (i 0)

result = true;

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return result;

}

/**

* 查询所有的新闻

* @return

public ListNews selectAllNews(){

ListNews list=new ArrayListNews();

String sql="select * from Users";

con=BaseDao.getConnection();

try {

pstmt=con.prepareStatement(sql);

rs=pstmt.executeQuery();

while(rs.next()){

News news=new News();

news.setNewsID(rs.getInt(1));

news.setContent(rs.getString(2));

news.setWriteDate(rs.getString(3));

list.add(news);

}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} finally {

BaseDao.closeAll(rs, pstmt, con);

}

return list;

}

/**

* 查询单个

* @return

public News selectOneNews(){

News news=new News();

con=BaseDao.getConnection();

try {

pstmt=con.prepareStatement("select top 1 * from news order by newsid desc");

rs=pstmt.executeQuery();

while(rs.next()){

news.setNewsID(rs.getInt(1));

news.setContent(rs.getString(2));

news.setWriteDate(rs.getString(3));

}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} finally {

BaseDao.closeAll(rs, pstmt, con);

}

return news;

}

实体类package com.entity;import java.io.Serializable;

public class News implements Serializable{

private int newsID;

private String content;

private String writeDate; public News() {

super();

// TODO Auto-generated constructor stub

} public News(String content, String writeDate) {

super();

this.content = content;

this.writeDate = writeDate;

} public News(int newsID, String content, String writeDate) {

super();

this.newsID = newsID;

this.content = content;

this.writeDate = writeDate;

} public int getNewsID() {

return newsID;

} public void setNewsID(int newsID) {

this.newsID = newsID;

} public String getContent() {

return content;

} public void setContent(String content) {

this.content = content;

} public String getWriteDate() {

return writeDate;

} public void setWriteDate(String writeDate) {

this.writeDate = writeDate;

}

怎么使用JAVA连接数据库?

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程序操作MySQL数据库

数据库内容

java源代码（代码实现的是查询成绩为的人员信息至于其他功能的代码中有注释）注意在eclipse里运行程序的时候要工程里插入jar包否则运行异常！ import java sql *; import java io *; class database_manage { public Connection conn = null; public ResultSet rs = null; private String DatabaseDriver = " mysql jdbc Driver"; // DataSource 数据源名称DSN private String DatabaseConnStr = "jdbc:mysql://localhost: /people_manage?useUnicode=truecharacterEncoding=utf " + " root root"; public void setDatabaseDriver(String Driver) { this DatabaseDriver = Driver; } public String getDatabaseDriver() { return (this DatabaseDriver); } public void setDatabaseConnStr(String ConnStr) { this DatabaseConnStr = ConnStr; } public String getDatabaseConnStr() { return (this DatabaseConnStr); } public database_manage() {// 构造函数连接数据库 try { Class forName(DatabaseDriver); } catch (java lang ClassNotFoundException e) { System err println("加载驱动器有错误:" + e getMessage()); System out print("执行插入有错误:" + e getMessage());// 输出到客户端 } } public ResultSet query(String sql) {// 查询数据库 rs = null; try { conn = DriverManager getConnection( "jdbc:mysql://localhost: /people_manage?useUnicode=truecharacterEncoding=utf " "root" "root"); Statement stmt = conn createStatement(); rs = stmt executeQuery(sql); } catch (SQLException ex) { System err println("执行查询有错误:" + ex getMessage()); System out print("执行查询有错误:" + ex getMessage()); // 输出到客户端 }

return rs;

} public int update_database(String sql) {// 更新或插入数据库 int num = ; try { conn = DriverManager getConnection( "jdbc:mysql://localhost: /people_manage?useUnicode=truecharacterEncoding=utf " "root" "root"); Statement stmt = conn createStatement(); num = stmt executeUpdate(sql); } catch (SQLException ex) { System err println("执行插入有错误:" + ex getMessage()); System out print("执行插入有错误:" + ex getMessage());// 输出到客户端 } 　CloseDataBase(); return num; } public void CloseDataBase() {// 关闭数据库 try { conn close(); } catch (Exception end) { System err println("执行关闭Connection对象有错误 " + end getMessage()); System out print("执行执行关闭Connection对象有错误有错误:" + end getMessage()); // 输出到客户端 } } } class people { private String uid; private String name; private String banji; private int score; public people() { } public people(String uid String name String banji) { this uid = uid; this name = name; this banji = banji; } public people(String uid String name String banji int score) { this uid = uid; this name = name; this banji = banji; this score = score; } public String getUid() { return uid; } public void setUid(String uid) { this uid = uid; } public String getName() { return name; } public void setName(String name) { this name = name; } public String getBanji() { return banji; } public void setBanji(String banji) { this banji = banji; } public int getScore() { return score; } public void setScore(int score) { this score = score; } } public class manage { private people[] people_array ;// 对象数组 public void add_people(String uid String name) { 　String sql = "insert people (uid name) values ( " + uid + " " + name + " )";// sql插入语句 // String sql = "insert people (uid name) values ( uid tom )"; 　database_manage db_obj = new database_manage(); db_obj update_database(sql); } public void update_people(String uid String name) { 　String sql = "update people set name= " + name + " where uid= " + uid + " "; database_manage db_obj = new database_manage(); db_obj update_database(sql); } public void delete_people(String uid) { 　String sql = "delete from people where uid= " + uid + " "; 　database_manage db_obj = new database_manage(); 　db_obj update_database(sql); } public people query_people(String uid) { database_manage db_obj = new database_manage(); // String adminid=null; String uid_new name banji; uid_new = null; name = null; banji = null; String sql_query = "select * from people where uid= " + uid + " "; 　try { ResultSet rs = db_obj query(sql_query); if (rs next()) { uid_new = rs getString("uid"); name = rs getString("name"); banji = rs getString("banji"); } } catch (Exception e) { e getMessage(); } people new_people = new people(uid_new name banji); return new_people; } public people[] query_people_byscore(int score) { database_manage db_obj = new database_manage(); String uid_new name banji; uid_new = null; name = null; banji = null; int score_new = ;

String sql_query = "select * from people where score=" + score;// sql查询语句

try {

ResultSet rs = db_obj query(sql_query);// 查询后返回结果集

int num = ;

ResultSet rs_new = rs;

while (rs_new next()) {// 统计结果集中学生个数

num++;

}

// System out println(num);

people_array = new people[num];

int i = ;

rs beforeFirst();// 返回结果集的开始

while (rs next()) {

uid_new = rs getString("uid");

name = rs getString("name");

banji = rs getString("banji");

score_new = rs getInt("score");

people_array [i] = new people(uid_new name banji score_new);

i++;

}

} catch (Exception e) {

e getMessage();

}

return people_array ;

}

public static void main(String args[]) {

* people new_people=new people();

* manage mr=new manage(); //mr add_people(" " "小明");插入一个学生的信息

* new_people=mr query_people(" ");//查询uid= 的学生信息返回对象 System out

* println(""+new_people getName()+"　 "+new_people getBanji());

* mr update_people(" " "小王");更新一个学生的信息

* new_people=mr query_people(" ");//更新后查询

* System out println(""+new_people getName()+"　 "+new_people getBanji(

* ));

manage mr = new manage();

// mr delete_people(" ");删除uid= 的学生信息

people[] people_array;// 声明对象数组

people_array = mr query_people_byscore( );// 返回成绩为一百的学生类数组后输出

int num = ;

num = people_array length;

for (int i = ; i num; i++) {

System out println(people_array[i] getUid() + " "

+ people_array[i] getName() + "　 "

+ people_array[i] getBanji() + "　 "

+ people_array[i] getScore());

}

lishixinzhi/Article/program/Java/JSP/201311/20030

关于java数据库操作和java数据库操作框架有哪些的介绍到此就结束了，不知道你从中找到你需要的信息了吗？如果你还想了解更多这方面的信息，记得收藏关注本站。

标签：java数据库操作