您的位置:

java数据库操作,java数据库操作类

本文目录一览:

怎么使用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中使用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 操作 数据库

Java连接数据库是使用具体数据库的JDBC驱动程序来实现的,每一个数据库的驱动程序不同。

以下是一段示例代码:

1.Class.forName("oracle.jdbc.driver.OracleDriver").newInstance(); //加载数据库JDBC驱动,该驱动会自动注册连接所需信息。

2.String url="jdbc:oracle:thin:@localhost:1521:orcl"; //定义连接字符串

String user="test"; //用户名

String password="test"; //密码

3.Connection conn= DriverManager.getConnection(url,user,password);//通过DriverManager获取数据库连接引用

4.Statement sql = conn.createStatement(Resultset.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);//生成一个Statement

5.ResultSet rs = sql.executeQuery("SELECT * FROM 表");//获取记录集引用

6.System.out.println(rs('字段一'));//输出当前一行表头为‘字段一’的数据。

以下再提供给你几个常用数据库的连接方式(驱动通常都是一个jar包,可以去数据库提供商官网下载):

1、Oracle8/8i/9i数据库(thin模式)

Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();

String url="jdbc:oracle:thin:@localhost:1521:orcl";

//orcl为数据库的SID

String user="test";

String password="test";

Connection conn= DriverManager.getConnection(url,user,password);

2、DB2数据库

Class.forName("com.ibm.db2.jdbc.app.DB2Driver ").newInstance();

String url="jdbc:db2://localhost:5000/sample";

//sample为你的数据库名

String user="admin";

String password="";

Connection conn= DriverManager.getConnection(url,user,password);

3、Sql Server7.0/2000数据库

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

String url="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=mydb";

//mydb为数据库

String user="sa";

String password="";

Connection conn= DriverManager.getConnection(url,user,password);

4、Sybase数据库

Class.forName("com.sybase.jdbc.SybDriver").newInstance();

String url =" jdbc:sybase:Tds:localhost:5007/myDB";

//myDB为你的数据库名

Properties sysProps = System.getProperties();

SysProps.put("user","userid");

SysProps.put("password","user_password");

Connection conn= DriverManager.getConnection(url, SysProps);

5、Informix数据库

Class.forName("com.informix.jdbc.IfxDriver").newInstance();

String url =

"jdbc:informix-sqli://123.45.67.89:1533/myDB:INFORMIXSERVER=myserver;

user=testuser;password=testpassword";

//myDB为数据库名

Connection conn= DriverManager.getConnection(url);

6、MySQL数据库

Class.forName("org.gjt.mm.mysql.Driver").newInstance();

String url ="jdbc:mysql://localhost/myDB?user=softpassword=soft1234useUnicode=truecharacterEncoding=8859_1"

//myDB为数据库名

Connection conn= DriverManager.getConnection(url);

7、PostgreSQL数据库

Class.forName("org.postgresql.Driver").newInstance();

String url ="jdbc:postgresql://localhost/myDB"

//myDB为数据库名

String user="myuser";

String password="mypassword";

Connection conn= DriverManager.getConnection(url,user,password);

另外一种方式是针对Windows的,首先建立一个DSN,然后使用Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");和"jdbc:odbc:数据源名称"来获取连接引用,不过这样平台依赖性很大,不推荐这样做。

希望我的回答对你有所帮助!

在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程序中访问mysql数据库中的数据并进行简单的操作

一、使用工具:java语言、Myeclipse。

二、操作步骤:

1、第一步:加载MySQL的JDBC的驱动

2、第二步:创建与MySQL数据库的连接类的实例

3、第三步:获取连接类实例con,用con创建Statement对象类实例 sql_statement

4、第四步:执行查询,用ResultSet类的对象,返回查询的结果

5、得出数据

三、注意事项:有几处是需要根据自身情况修改的

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

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

java怎么操作数据库呢?

jdbc连接数据库,DriverManger等初始化连接,prepareStatement语句执行sql,ResultSet拿到执行结果,while result.hasNext循环拿到数据值等。

如果不用jdbc,可以用框架,hibernate,mybatis都是可以的。

详情可以私聊我,手机打字太累了。

java数据库操作,java数据库操作类

2023-01-08
java与中的数据库操作(java 数据库操作)

2022-11-14
java之数据库操作,java之数据库操作概念

2022-11-21
java数据库操作,java数据库操作框架有哪些

2022-11-28
jsp数据库笔记,jsp写入数据库

本文目录一览: 1、怎么用jsp连接mysql数据库 2、jsp中怎么使用数据库 3、JSP 从数据库中如何取得图片的路径? 怎么用jsp连接mysql数据库 一. 数据库的连接和操作笔记:1.初始化

2023-12-08
jsp操作mysql数据库,jsp访问数据库

2022-11-18
java数据库操作界面(java怎么输出数据库数据到界面?)

2022-11-14
java操作mysql应用实例,java操作mysql数据库

2022-11-22
用java调用mysql数据库,java操作mysql数据库

2022-11-22
java对文件和数据库的操作,java如何调用数据库数据

2022-11-22
学习笔记之mysql数据库操作(mysql数据库怎么操作)

2022-11-16
Java实现MySQL数据库操作

2023-05-10
Java连接MySQL数据库操作步骤

2023-05-11
连接mysql数据库笔记1(如何连接数据库mysql)

2022-11-10
java操作数据库出错,数据库出错怎么解决

2022-11-21
重学java笔记,java笔记总结

2022-11-23
java二级笔试练习(java二级考试操作题)

2022-11-13
java操作mysql后乱码(java写入mysql数据库乱

2022-11-11
运行中操作mysql数据库(运行中操作mysql数据库命令)

2022-11-10
php操作数据库的插件(php操作数据库的插件有哪些)

2022-11-11