当前位置:首页 » 编程语言 » java写入数据库

java写入数据库

发布时间: 2023-02-05 19:10:11

1. 怎样用java实现从文本文档中读取数据并存入数据库

不知道你要什么样的文本,文本中的内容是否是有格式的:

这里提供下思路,供参考:
1.文本文件,基本上式字符格式的了,可以用Readerio流
2.如果是格式化的文本,可以按数据的长度读取,readIntreadByte...
3.保存到数据库当然用JDBC了,如果你读取出来封装成POJO了,也可以选择OM框架



importjava.io.BufferedReader;
importjava.io.FileInputStream;
importjava.io.IOException;
importjava.io.InputStreamReader;

/**
*文件读取和写入数据库
*@author樊云升
*
*/
publicclassFilesReader{

publicFilesReader(){

}

/**
*读取文件内容
*@paramFILE
*@return
*/
publicStringre_content(StringFILE){
Stringcontent="";
try{
BufferedReaderbufRead=newBufferedReader(newInputStreamReader(newFileInputStream(FILE)));
Stringstr;
while((str=bufRead.readLine())!=null){
content+=str+" ";
}
}catch(IOExceptionioe){
ioe.printStackTrace();
}
returncontent;
}

/**
*将特定字符写入数据库中(原来我写的是重写文件,你这里这里将content写入数据库就OK)
*@parampath
*@return
*/
publicbooleanwriteFile(Stringcontent){
try{
//数据库写入代码
}catch(Exceptione){
out.close();
returnfalse;
}
returntrue;
}

publicstaticvoidmain(String[]args){
Stringcontent=newFilesReader().re_content("D:\AJAX.htm");
newFilesReader().writeFile(content);
}

}

2. java写入数据库

需要拼接字符串, 因为id和student是字符串, 在sql里需要加单引号:

StringBuilderbuilder=newStringBuilder();
builder.append("insertintostudentvalues");
builder.append("('");
builder.append(id);
builder.append("','");
builder.append(password);
builder.append("')");

Stringst=builder.toString();

或者使用setString的方式:

Connectionconn=DriverManager.getConnection(url);
PreparedStatementps=conn.prepareStatement("insertintostudentvalues(?,?)");
pstmt.setString(1,id);//设置第1个参数的值为字符串
pstmt.setString(2,password);//设置第2个参数的值为字符串
pstmt.execute();

3. 用java怎样把数据存到数据库中

只能写个大概的,要写数据到数据库中,先得在数据库中建库,库里建表,表里建字段,然后java里建立数据库连接,用SQL语言写数据到表中的字段x0dx0aClass.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver").newInstance(); x0dx0a//String url="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=数据库名"; //7.0、2000x0dx0aString url="jdbc:sqlserver://localhost:1433;DatabaseName=数据库名"; //2005x0dx0aConnection conn=null;x0dx0aconn= DriverManager.getConnection(url,用户名,密码); x0dx0aPreparedStatement pst=null;x0dx0apst=conn.prepareStatement("Insert Into grade(表名) Values (?)");x0dx0apst.setInt(1,你要写的整弄数据);x0dx0a//pst.setString(2,你要写的字符串数据);x0dx0apst.addBatch();x0dx0apst.executeBatch();

4. java怎样将读取数据写入数据库

就要链接数据库,可以通过JDBC链接。
首先,在连接数据库之前必须保证SQL Server 2012是采用SQL Server身份验证方式而不是windows身份验证方式,开始如下配置:
一、因为SQL Server 2012装好后,默认协议是没有开启的,所以要打开SQL Server配置管理器中开启。
1、安装好SQL Server 2012后,运行 开始 → 所有程序 → Microsoft SQL Server 2012 → 配置工具 →SQL Server配置管理器
2、在左边栏找到 SQL Server网络配置选项,点开它的小箭头,会看到“【你的数据库名】的协议” (图中是ERIC2012的协议),选中它,看右边栏。
(1)如果Named Pipes 未启用,则右键→启用
(2)右键单击 TCP/IP,选择 启用
(3)双击TCP/IP(右键→属性),在弹出的窗口中选择 “IP地址” 选项卡,将IP1和IP10的【IP地址】设为127.0.0.1,并将所有【IPx】的【已启用】设为是。接着,拖动下拉条到最下方,将 IPAll 中的【TCP端口】设成 【1433】,其余不变。
3、重新启动计算机。
4、接下来使用telnet命令测试1433端口是否打开。首先要保证telnet服务开启。
5、完成上一步后。开始菜单 → 运行cmd → 输入:telnet 127.0.0.1 1433,(注意telnet与127之间有空格,1与1433之间有空格)。
6、若提示“不能打开到主机的连接,在端口 1433: 连接失败”,则说明1433端口没有打开,需要重新进行以上配置。

5. java 向数据库插入数据

java向数据库中插入数据,可以使用mysql数据库,使用statement类来操作数据库,示例如下:

Connectionconn=null;
Statementst=null;
try{
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");//加载驱动类
conn=DriverManager.getConnection("jdbc:microsoft:sqlserver://<server_name>:<1433>","name","pwd");
conn.setAutoCommit(false);
st=conn.createStatement();
//模拟一个str[i]=nd.getNodeValue().trim()
String[]str=newString[]{"aaa","bbb","ccc","ddd","eee","fff"};
StringsqlStr=null;
for(inti=0;i<str.length;i++){
sqlStr="INSERTINTO<TABLENAME>(<COLNAME>)VALUES('"+str[i]+"')";//向数据库中插入数据
st.executeUpdate(sqlStr);
}
conn.commit();
}catch(Exceptione){
e.printStackTrace();
}finally{//释放数据库的资源
try{
if(st!=null)
st.close();
if(conn!=null&&!conn.isClosed()){
conn.close();
}
}catch(SQLExceptione){
e.printStackTrace();
}
}

6. 如何把java对象存入数据库

原生java对象存数据库,可以考虑将对象转成字节数组,写入数据库;
一般常用做法是一个属性对应一个字段,不会直接写入java 对象

7. 如何把java对象存入数据库

假设有这么个对象:
import java.io.Serializable;

public class MyObject implements Serializable {

private static final long serialVersionUID = 1L;
private int i;

public int getI() {
return i;
}

public void setI(int i) {
this.i = i;
}
}

//测试 的方法如下
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class test {

public static void main(String[] args) throws IOException,
ClassNotFoundException {

MyObject obj = new MyObject();
obj.setI(4567);
write(Object2Bytes(obj));

// read();
}

public static void write(byte[] b) throws ClassNotFoundException {

System.out.println(b.length);
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
try {
Connection con = DriverManager.getConnection("jdbc:odbc:temp");
String sql = "insert into tab values(?)";

PreparedStatement pstmt = con.prepareStatement(sql);
pstmt.setBytes(1, b);
pstmt.execute();

pstmt.close();
con.close();
} catch (Exception e) {
e.printStackTrace();
}
}

public static void read() throws ClassNotFoundException {
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
try {
Connection con = DriverManager.getConnection("jdbc:odbc:temp");
String sql = "select * from tab";

PreparedStatement pstmt = con.prepareStatement(sql);
ResultSet res = pstmt.executeQuery();

while (res != null && res.next()) {
byte[] b = res.getBytes("key");
System.out.println(b.length);
MyObject obj = (MyObject) Bytes2Object(b);
System.out.println(obj.getI());
}

pstmt.close();
con.close();
} catch (Exception e) {
e.printStackTrace();
}
}

// 将对象转换成字节数组
public static byte[] Object2Bytes(Object obj) throws IOException {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
ObjectOutputStream oos = new ObjectOutputStream(baos);
oos.writeObject(obj);
return baos.toByteArray();
}

// 将字节数组转换成为对象
public static Object Bytes2Object(byte[] b) throws IOException,
ClassNotFoundException {

ByteArrayInputStream s = new ByteArrayInputStream(b);
ObjectInputStream ois = new ObjectInputStream(s);

Object obj = ois.readObject();
return obj;
}

}

8. 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() ;
}
}

(8)java写入数据库扩展阅读

样例

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);

}

}

9. java怎样将读取数据写入数据库

就要链接数据库,可以通过JDBC链接。
首先,在连接数据库之前必须保证SQL Server 2012是采用SQL Server身份验证方式而不是windows身份验证方式,开始如下配置:
一、因为SQL Server 2012装好后,默认协议是没有开启的,所以要打开SQL Server配置管理器中开启。
1、安装好SQL Server 2012后,运行 开始 → 所有程序 → Microsoft SQL Server 2012 → 配置工具 →SQL Server配置管理器
2、在左边栏找到 SQL Server网络配置选项,点开它的小箭头,会看到“【你的数据库名】的协议” (图中是ERIC2012的协议),选中它,看右边栏。
(1)如果Named Pipes 未启用,则右键→启用
(2)右键单击 TCP/IP,选择 启用
(3)双击TCP/IP(右键→属性),在弹出的窗口中选择 “IP地址” 选项卡,将IP1和IP10的【IP地址】设为127.0.0.1,并将所有【IPx】的【已启用】设为是。接着,拖动下拉条到最下方,将 IPAll 中的【TCP端口】设成 【1433】,其余不变。
3、重新启动计算机。
4、接下来使用telnet命令测试1433端口是否打开。首先要保证telnet服务开启。
5、完成上一步后。开始菜单 → 运行cmd → 输入:telnet 127.0.0.1 1433,(注意telnet与127之间有空格,1与1433之间有空格)。
6、若提示“不能打开到主机的连接,在端口 1433: 连接失败”,则说明1433端口没有打开,需要重新进行以上配置。

10. java 写入数据库

1:首先写一个方法是接收数据后保存至数据库的方法,但是添加进去的数据需要进行标识(主要考虑到如果数据量较大,在保存的过程中可能有新的数据进来会产生多条数据,所以需要数据标识);
2:当点击按钮时弹出标识的数据,记录ID号;
3:将修改后的数据根据ID号保存更新至数据库中并取消该数据的标识;

热点内容
网络访问层 发布:2024-11-01 16:18:38 浏览:349
国产系列ftp 发布:2024-11-01 15:49:53 浏览:702
招编程师傅招聘 发布:2024-11-01 15:34:51 浏览:192
kkt编程 发布:2024-11-01 15:31:26 浏览:614
我的世界管理员进服务器提示 发布:2024-11-01 15:21:12 浏览:126
如何删除qq空间访问记录 发布:2024-11-01 15:20:07 浏览:323
微信上传图片失败 发布:2024-11-01 15:19:53 浏览:117
python网站域名服务器搭建 发布:2024-11-01 15:18:36 浏览:693
量产工具加密 发布:2024-11-01 15:14:31 浏览:674
储备存储 发布:2024-11-01 15:14:28 浏览:330