导航:首页 > 编程语言 > java文件的写入数据库

java文件的写入数据库

发布时间:2022-04-25 23:50:42

java将txt文档内容写入数据库

首先你要在数据库建表,假设表是 info 字段分别是id , name, age, score ,mail
表 info 对应一个类Info ,属性有 int id; String name; int age; int score ;String mail
构造方法你会写的
下面是写入数据库代码:
Class.forName("org.sqlite.JDBC");//加载数据库驱动
Connection conn = DriverManager.getConnection("jdbc:sqlite:info.s3db");//链接数据库,info.s3db是数据库名字,我用的是sqlite.
PreparedStatement ps = conn.PreparedStatement("insert into info values(?,?,?,?)");//创建语句对象
ps.setInt(1,info.getId());
ps.setString(2,info.getName());
。。。。以此类推
ps.executeUpdate();
这样就插入到数据库了。你可以到表里看看
至于输出成绩的话 你要写方法了。。。

㈡ 怎样用java把文本文档内容写入到数据库里面

大体思路是:用流读取文本中的内容,存到一个字节数组里,然后把这个数组保存到库里,库里对应的字段类型是 blob

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

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

}

}

㈣ java中怎样将String类型的数据写入数据库

需要下载好的东西:MySQL-connector-java-5.0.3-bin.jar

在配置好MyEclipse的JSP基本环境后

开启apmserv后,配置MyEclipse的链接环境:window-open perspection-MyEclipse database exp...新建一个链接,url处:jdbc:MySQL:(MySQL数据库链接),username和password是登录数据库的(不要弄错了).在finish前可以尝试链接,链接成功-finish.链接失败注意看提示,一般是url的错误,多多尝试.我用apmserv的url是jdbc:MySQL:127.0.0.1/(数据库名)

之后在新建的web工程下,在WEB-INF\lib中improt-general-file system-选择MySQL-connector-java-5.0.3-bin.jar所在的文件夹-finish

使用下面的代码,可以测试链接,注意更改使用的数据库名,数据等

JDBCHelloWorld.java
import java.sql.SQLException;
/**
* 第一个 JDBC 的 HelloWorld 程序, 数据库访问 MySQL.
*/
public class JDBCHelloWorld {
/**
* @param args
* @throws SQLException
*/
public static void main(String[] args) throws SQLException {
// 1. 注册驱动
try {
Class.forName("com.MySQL.jdbc.Driver");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}// MySQL 的驱动
// 2. 获取数据库的连接
java.sql.Connection conn = java.sql.DriverManager.getConnection(
"jdbc:MySQL://localhost/test?useUnicode=true&characterEncoding=GBK", "root", null);
// 3. 获取表达式
java.sql.Statement stmt = conn.createStatement();
// 4. 执行 SQL
java.sql.ResultSet rs = stmt.executeQuery("select * from user"); //这里是你要执行的SQL
// 5. 显示结果集里面的数据
while(rs.next()) {
System.out.println(rs.getInt(1));
System.out.println(rs.getString("username"));
System.out.println(rs.getString("password"));
System.out.println();
}
// 6. 释放资源
rs.close();
stmt.close();
conn.close();
}
}

㈤ java文件路径怎么存入数据库

直接读写文件,再把读出来的文件内容格式化成json,再用jdbc、mybatis或者其他框架将json数据存入数据库。

㈥ 如何使用Java解析文件并存入数据库

怎样的文件、哪种数据库、怎样的数据库的格式
~~~~~~~~~~~~~~~~~~~~~~~~~~~~

㈦ 怎样用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);
}

}

㈧ 如何用JAVA把TXT文件导入数据库中

1、java i/o读取txt文本
2、使用实体类封装或使用list、map等封装读取到的数据
3、jdbc

txt文本要保证符合一定的格式,如每个字段间已特定字符分割。

㈨ 怎么用java将一个文件直接写入到sqlserver数据库中

java中使用jdbc连接sql server数据库步骤:
1.JDBC连接SQL Server的驱动安装 ,前两个是属于数据库软件,正常安装即可(注意数据库登陆不要使用windows验证)
<1> 将JDBC解压缩到任意位置,比如解压到C盘program files下面,并在安装目录里找到sqljdbc.jar文件,得到其路径开始配置环境变量
在环境变量classpath 后面追加 C:\Program Files\Microsoft SQL Server2005 JDBC Driver\sqljdbc_1.2\enu\sqljdbc.jar
<2> 设置SQLEXPRESS服务器:
a.打开SQL Server Configuration Manager -> SQLEXPRESS的协议 -> TCP/IP
b.右键单击启动TCP/IP
c.双击进入属性,把IP地址中的IP all中的TCP端口设置为1433
d.重新启动SQL Server 2005服务中的SQLEXPRESS服务器
e.关闭SQL Server Configuration Manager
<3> 打开 SQL Server Management Studio,连接SQLEXPRESS服务器, 新建数据库,起名字为sample
<4> 打开Eclipse
a.新建工程-> Java -> Java project,起名为Test
b.选择eclipse->窗口->首选项->Java->installed JRE 编辑已经安装好的jdk,查找目录添加sqljdbc.jar
c.右键单击目录窗口中的Test, 选择Build Path ->Configure Build Path..., 添加扩展jar文件,即把sqljdbc.jar添加到其中
<5> 编写Java代码来测试JDBC连接SQL Server数据库
import java.sql.*;
public class Test {
public static void main(String[] srg) {
//加载JDBC驱动
String driverName = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
//连接服务器和数据库sample
String dbURL = "jdbc:sqlserver://localhost:1433; DatabaseName=sample";
String userName = "sa"; //默认用户名
String userPwd = "123456"; //密码

Connection dbConn;
try {
Class.forName(driverName);
dbConn = DriverManager.getConnection(dbURL, userName, userPwd);
System.out.println("Connection Successful!"); //如果连接成功 控制台输出
} catch (Exception e) {
e.printStackTrace();
}
}
}

执行以后就可以连接到sample数据库了。

㈩ java如何里将文件存到数据库中

java要实现将文件存到数据库中的话,你可以在数据库中使用blob类型,然后使用IO操作保存为字节类型,这样就可以进行传输和下载

阅读全文

与java文件的写入数据库相关的资料

热点内容
python列表求交集 浏览:872
解压包如何转音频 浏览:447
机明自动编程软件源码 浏览:325
php端口号设置 浏览:540
phperegreplace 浏览:320
androidgridview翻页 浏览:537
ssh协议编程 浏览:634
如何开我的世界电脑服务器地址 浏览:861
玄关pdf 浏览:609
程序员学习论坛 浏览:940
程序员的毒鸡汤怎么做 浏览:548
安卓怎么降级软件到手机 浏览:281
云与服务器入门书籍推荐产品 浏览:636
delphi编程助手 浏览:762
电脑遇到服务器问题怎么办 浏览:515
加工中心编程结束方法 浏览:296
了解什么是web服务器 浏览:140
面向对象的编程的基本特征 浏览:718
php定时执行任务linux 浏览:787
php数组中删除元素 浏览:725