jdbc写入数据库_JDBC连接数据库的步骤都有哪些

加载(注册)数据库驱动(到JVM)。建立(获取)数据库连接。创建(获取)数据库操作对象。定义操作的sql语句。执行数据库操作。获取并操作结果集。

在数据库的发展历史上，数据库先后经历了层次数据库、网状数据库和关系数据库等各个阶段的发展，数据库技术在各个方面的快速的发展。特别是关系型数据库已经成为目前数据库产品中最重要的一员。

80年代以来，几乎所有的数据库厂商新出的数据库产品都支持关系型数据库，即使一些非关系数据库产品也几乎都有支持关系数据库的接口。这主要是传统的关系型数据库可以比较好的解决管理和存储关系型数据的问题。

数据库管理系统是为管理数据库而设计的电脑软件系统，一般具有存储、截取、安全保障、备份等基础功能。数据库管理系统可以依据它所支持的数据库模型来作分类，例如关系式、XML；或依据所支持的计算机类型来作分类，例如服务器群集、移动电话。

或依据所用查询语言来作分类，例如SQL、XQuery；或依据性能冲量重点来作分类，例如最大规模、最高运行速度；亦或其他的分类方式。不论使用哪种分类方式，一些DBMS能够跨类别，例如，同时支持多种查询语言。

Ⅱ jdbc连接数据库的几个步骤

创建一个以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 )方法传入指定的欲连接的数据库的路径、数据库的用户名和
密码来获得。
例如：
//连接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() ;
}
}

Ⅲ 怎样用JDBC把文本数据导入到Oracle数据库中

1.读取文本文件，每次读取一行，用BufferedReader
2.因为每一行中都是固定的格式，因此解析每一行中的数据。
3.将解析的数据保存到数据库。

BufferedReader br = new BufferedReader(new FileReader(new File("aa.txt")));
String temp = null;
// 假定这是你写的将数据插入数据库的接口和实现类。
Dao = new DaoImpl();

while ((temp = br.readLine()) != null) {
String[] strs = temp.split("|");
String s1 = strs[0];//如上面的2300
String s2 = strs[1]; // 如上面的62220202222
String s3 = strs[2];//如上面的2000
String s4 = strs[3]; // 如上面的村镇银行3
//还需要写一个方法将数据插入数据库。
.insert(s1,s2,s3,s4);
}
br.close();

请自行导入所需要的包，并处理异常。

Ⅳ java怎样将读取数据写入数据库

Java可以使用JDBC对数据库进行读写。JDBC访问一般分为如下流程：

一、加载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类中。

二、提供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：字符编码方式。

三、创建数据库的连接

要连接数据库，需要向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() ;
}

四、创建一个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(? , ?)}") ;

五、执行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) ;

六、处理结果两种情况：
1、执行更新返回的是本次操作影响到的记录数。

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

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

使用结果集（ResultSet）对象的访问方法获取数据：

while(rs.next()){

String name = rs.getString("name") ;

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

七、关闭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() ;
}
}

(4)jdbc写入数据库扩展阅读

样例

package first;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.concurrent.Executors;

import java.util.concurrent.ScheledExecutorService;

import java.util.concurrent.TimeUnit;

public class lianjie {

public static void main(String[] args) {

Runnable runnable = new Runnable() {

public void run() {

//声明Connection对象

Connection con;

//驱动程序名

String driver1 = "com.microsoft.sqlserver.jdbc.SQLServerDriver";

//URL指向要访问的数据库名

String url1 = "jdbc:sqlserver://IP地址和端口号;DateBaseName=数据库名";

//MySQL配置时的用户名

String user1 = "user";

//MySQL配置时的密码

String password1 = "user";

//声明Connection对象

Connection con1;

//驱动程序名

String driver2 = "com.microsoft.sqlserver.jdbc.SQLServerDriver";

//URL指向要访问的数据库名

String url2 = "jdbc:sqlserver://IP地址和端口号;DateBaseName=数据库名";

//MySQL配置时的用户名

String user2 = "user";

//MySQL配置时的密码

String password2 = "user";

//遍历查询结果集

try {

//加载驱动程序

Class.forName(driver1);

//1.getConnection()方法，连接MySQL数据库！！

con = DriverManager.getConnection(url1,user1,password1);

if(!con.isClosed())

System.out.println("成功连接到数据库!");

try {

//加载驱动程序

Class.forName(driver2);

//1.getConnection()方法，连接MySQL数据库！！

con1 = DriverManager.getConnection(url2,user2,password2);

if(!con1.isClosed())

System.out.println("成功连接到数据库!");

//2.创建statement类对象，用来执行SQL语句！！

Statement statement = con.createStatement();

//要执行的SQL语句

String sql = "use 数据库名 select * from 表名";

//3.ResultSet类，用来存放获取的结果集！！

ResultSet rs = statement.executeQuery(sql);

//要执行的SQL语句

String sql1 = "use tiantiana insert into Table_1(tiantian,qiqi,yuyu)VALUES(?,?,?)";

//3.ResultSet类，用来存放获取的结果集！！

PreparedStatement pst = con1.prepareStatement(sql1);

System.out.println ("tiantian"+"/t"+"qiqi"+"/t"+"yuyu");

while(rs.next()){

System.out.print(rs.getString(1));

System.out.print(rs.getString(2));

System.out.print(rs.getString(3));

pst.setString(1,rs.getString(1));

pst.setString(2,rs.getString(2));

pst.setString(3,rs.getString(3));

pst.executeUpdate();

}

pst.close();

rs.close();

//2.创建statement类对象，用来执行SQL语句！！

Statement statement1 = con.createStatement();

//要执行的SQL语句

String sql2 = "use 数据库名 select * from 表名";

//3.ResultSet类，用来存放获取的结果集！！

ResultSet rs1 = statement1.executeQuery(sql2);

//要执行的SQL语句

String sql3 = "use tiantiana insert into Table_2(tiantian1,qiqi1,yuyu1)VALUES(?,?,?)";

//3.ResultSet类，用来存放获取的结果集！！

PreparedStatement pst1 = con1.prepareStatement(sql3);

System.out.println ("tiantian1"+"/t"+"qiqi1"+"/t"+"yuyu1");

while(rs1.next()){

System.out.print(rs1.getString(1));

System.out.print(rs1.getString(2));

System.out.print(rs1.getString(3));

pst1.setString(1,rs1.getString(1));

pst1.setString(2,rs1.getString(2));

pst1.setString(3,rs1.getString(3));

pst1.executeUpdate();

}

//关闭链接

rs1.close();

pst.close();

con1.close();

con.close();

} catch(ClassNotFoundException e) {

//数据库驱动类异常处理

System.out.println("对不起,找不到驱动程序!");

e.printStackTrace();

} catch(SQLException e) {

//数据库连接失败异常处理

e.printStackTrace();

}catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

}finally{

System.out.println("数据库数据成功获取！！");

}

} catch(ClassNotFoundException e) {

//数据库驱动类异常处理

System.out.println("对不起,找不到驱动程序!");

e.printStackTrace();

} catch(SQLException e) {

//数据库连接失败异常处理

e.printStackTrace();

}catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

}finally{

System.out.println("数据库数据成功获取！！");

}

};

ScheledExecutorService service = Executors

.();

// 第二个参数为首次执行的延时时间，第三个参数为定时执行的间隔时间

service.scheleAtFixedRate(runnable, 10, 60*2, TimeUnit.SECONDS);

}

Ⅳ JDBC操作数据库如何快速学会

JDBC操作数据库其实只要掌握了六大步骤就基本差不多啦：
1.加载驱动
Class.forName(String);
String(驱动器的名称，分oracle,sql
server等数据库驱动)
2.创建连接
DriverManager.getConnection(url,userName,passwd);
url是数据库的地址,后面分别是用户名和密码
3.创建会话statement(三种statement)
stmt(Statement):所有stmt的父类从connection对象获得，主要用于解析执行sql语句，返回响应结果，多执行异构的sql语句
pstmt(preparedStatement):主要用于执行同构的sql语句，stmt的子类。
cstmt:主要用于执行plsql的编程对象
4.执行sql语句
executeQuery();
5.处理结果集(有结果集返回，无则可省去，比如插入和删除)
ResultSet
rs
=
步骤4的结果
6.释放资源即连接，一般些在finally语句块中，目的是减轻服务器的压力

Ⅵ jsp jdbc向数据库写入值

这是表单页面代码！

<%@ page contentType="text/html; charset=gb2312" language="java" import="java.sql.*,bean.*" errorPage="" %>
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=gb2312">
<title>图书管理</title>
<script language="JavaScript" type="text/JavaScript">

</script>
<script language="javascript" src="tupian.js"></script>
<link href="css.css" rel="stylesheet" type="text/css">
<style type="text/css">

</style>
</head>

<body topmargin="0">

<%
if(session.getAttribute("admin")==null){
response.sendRedirect("adminlogin.jsp");
}
else{
%>
<div align="center">
<table width="800" height="530" border="0">
<tr>
<td height="48" colspan="3" align="left" valign="top"><jsp:include page="top.jsp" flush="true"></jsp:include></td>
</tr>
<tr>
<td width="196" height="220" align="left" valign="top"><div align="center" class="style1"><jsp:include page="adminleft.htm"></jsp:include>

</div></td>
<td width="363" align="left" valign="top"><div align="left" class="style1">图书添加</div>
<form action="aabook.jsp" method="post" enctype="multipart/form-data" name="form2" onSubmit="return jjian()">
<p>书名:
<input name="book_name" type="text" id="book_name">
</p>
<p>作者:
<input name="author" type="text" id="author">
</p>
<p>出版社:
<input name="publisher" type="text" id="publisher">
</p>
<p>类型:
<input name="type" type="text" id="type">
</p>
<p>Ifnew: <span class="style1"> </span>
<input type="radio" name="ifNew" value="yes">
<input name="ifNew" type="radio" value="top" checked>
</p>
<p>价格:
<input name="price" type="text" id="price">
</p>
<p>图片:
<input name="img" type="file" id="img" onChange="tupian(this)">
</p>
<p>简介:
<textarea name="jiejian" cols="50" rows="4" id="jiejian"></textarea>
</p>
<p>
<input type="submit" name="Submit" value="修改">

<input type="reset" name="Submit" value="重置">
</p>
</form>
<br> </td>
<td width="251" align="left" valign="top"><p></p>
<p></p>
<p></p>
<p><img name="rr" width="137" height="141" alt="图片预览"></p></td>
</tr>

<tr>
<td height="53" colspan="3" align="left" valign="top"><jsp:include page="end.jsp" flush="true"></jsp:include></td>
</tr>
</table>
<%}%>
</div>
</body>
</html>

这是接受页面代码

<%@ page contentType="text/html; charset=gb2312" language="java" import="java.sql.*,bean.*" errorPage="" %>
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=gb2312">
<title>无标题文档</title>
</head>

<body>
<%
//String bookid=request.getParameter("book_id");
//int book_id=Integer.parseInt(bookid);
String book_name=request.getAttribute("book_name").toString();
//book_name=new String(book_name.getBytes("ISO-8859-1"),"GB2312");
String author=request.getAttribute("author").toString();
//author=new String(author.getBytes("ISO-8859-1"),"GB2312");
String publisher=request.getAttribute("publisher").toString();
//publisher=new String(publisher.getBytes("ISO-8859-1"),"GB2312");
String type=request.getAttribute("type").toString();
//type=new String(type.getBytes("ISO-8859-1"),"GB2312");
String ifNew=request.getAttribute("ifNew").toString();
String price=request.getAttribute("price").toString();
String img=request.getAttribute("fname").toString();
String jiejian=request.getAttribute("jiejian").toString();
//jiejian=new String(jiejian.getBytes("ISO-8859-1"),"GB2312");
String str[]={book_name,author,publisher,type,ifNew,price,img,jiejian};
String sql="insert into book values(?,?,?,?,?,?,?,?,getDate())";
DBMain.pexeUpdate(sql,str);
out.print("<a href=\"admin.jsp\">添加成功返回首页</a>");
%>

</body>
</html>

这是数据库处理类

package bean;
import java.sql.*;

public class DBMain {

//连接数据库
public static Connection getcon(){
Connection con=null;
try {
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
} catch (ClassNotFoundException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
try {
con=DriverManager.getConnection("jdbc:microsoft:sqlserver://localhost:1433;databaseName=bookshop","sa","2601350");
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
return con;
}

//用Statement查询数据库
public static ResultSet exeQuery(String sql){
ResultSet rs=null;
Connection con=getcon(); //Connection的对象
try {
Statement stm=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
rs=stm.executeQuery(sql);
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
return rs;

}

//用Statement类，执行添加，删除，更新数据库操作
public static void exeUpdate(String sql){
Connection con=getcon();
try {
Statement stm=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
stm.executeUpdate(sql);
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
}

//用PreparedStatement类查询数据库
public static ResultSet pexeQuery(String sql,String[] str){
ResultSet rs=null;
Connection con=getcon();
try {
PreparedStatement pstm=con.prepareStatement(sql);
for(int i=0;i<str.length;i++){
pstm.setString(i+1,str[i]);
}
rs=pstm.executeQuery();
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
return rs;
}

//用PreparedStatement类实现添加,删除,更新数据库
public static void pexeUpdate(String sql,String[] str){
try {
Connection con=getcon();
PreparedStatement pstm=con.prepareStatement(sql);
for(int i=0;i<str.length;i++){
pstm.setString(i + 1,str[i]);
}
pstm.executeUpdate();
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
}

}

这是我第一次连接数据库写的代码，现在不适用，不过你可以感觉下，

Ⅶ jdbc添加记录到数据库

数组下表越界
stmt.setInt(1, num);
stmt.setString(2, name);
stmt.setInt(3, age);
stmt.setString(4, sex);
stmt.setString(5, college);
，没有5个，结果你set了5个，肯定报数组下标越界

Ⅷ Java jdbc写入数据库报错

FileReader fr1=new FileReader(filePath);
BufferedReader br1=new BufferedReader(fr1);
String line2=null;
try {
while(true){
//读取txt里面的每一行数据
line2=br1.readLine();
System.out.println(line2);

if(line2!=null)
{
//分割提取每一列数据
StringTokenizer dt=new StringTokenizer(line2,",");
Date=dt.nextToken();
OPrice=dt.nextToken();
HPrice=dt.nextToken();
LPrice=dt.nextToken();
CPrice=dt.nextToken();
Voume=dt.nextToken();
CRate=dt.nextToken();
System.out.println(Date);
System.out.println(OPrice);

//向数据库的StockData表写入数据
String sql;
sql="insert into StockData values ('"+line0+"','"+str[1]+"','"+Date+"','"+OPrice+"','"+HPrice+"','"+LPrice+"','"+CPrice+"','"+Voume+"','"+CRate+"')";
stmt.executeUpdate(sql);
}
else break;
}

} catch(Exception e) {
} finally {
if (con != null) {
con.close();
}
}

另外，对于字符串的多次拼接，尽量使用StringBuffer（这儿没有给你修改出来）

Ⅸ JDBC连接数据库的步骤都有哪些

1、首先我们通过数据库可视化工具navicate for mysql，新建一个数据库，名字叫test新建一张表。

jdbc写入数据库

与jdbc写入数据库相关的内容