"name","sex","adress"
vacher(20),char,vacher(20)
"张山",1,湖南省
"张山",1,湖南省
"张山",1,湖南省
我理解文件是这样的是么那就把文件读进来,前两行特殊处理就行了
1
String[] columnNameLine = readerreadLine()replace("\"")split(",")
那么每一列的标题就是 columnNameLine[i]trim();
2第二行就是类型了,也就是要对接下来每一行转类型,包含建表
String[] types = readerreadLine()split(",")
之后用循环拼装为 建表语句就行
StringBuffer sf = new StringBuffer("create table TTT ");
for(int i=0,len=columnNameLinelength;i<len;i++){
//具体的就是 sql语句了,省略。。。
}
3 执行sql 建表语句
4 读接下来的每一行,文件很短的话,直接拼成sql并执行
insert into TTT () values ()
文件很大的话,采用prepareStatement, 批量执行。
这个首先要看你安装的数据库,需要导入到项目中相应的数据库驱动,一下以mysql为例
//增加sql
Stringsql="INSERTINTODEMO_ORDER(ORDER_ID,ORDER_NAME)VALUES(,)";
//注册驱动
ClassforName("commysqljdbcDriver");
//获取连接3306指数据库端口,demo指数据库database名,两个root分别是数据库用户名和密码
Connectioncon=("jdbc:mysql://localhost:3306/demo","root","root"");
//预编译sql语句
pst=con(sql);
需要导入mysql-connector-javajar包
用java连接数据库啊。下面给点例子可以参考,不大好,凑合看
import javasqlConnection;import javasqlDriverManager;
import javasqlPreparedStatement;
import javasqlResultSet;
import javasqlSQLException;
public class JdbcConnection
{
private String driver;
private String dbname;
private String username;
private String password;
private String url;
private Connection con;
private PreparedStatement pstmt;
private ResultSet rs;
public JdbcConnection(){
thisdriver="commicrosoftsqlserverjdbcSQLServerDriver";
thisdbname=数据库名";
thisusername="数据库账号";
thispassword="数据库密码";
thisurl="地址加数据库名";
}
//创建连接方法
public Connection getconnection()
{
try
{
ClassforName(driver);
con=DriverManagergetConnection(url,username,password);
} catch (ClassNotFoundException e)
{
// TODO Auto-generated catch block
eprintStackTrace();
} catch (SQLException e)
{
// TODO Auto-generated catch block
eprintStackTrace();
}
return con;
}
//关闭连接方法
public void coloseConnection(Connection con,ResultSet rs,PreparedStatement pstmt)
{
if(rs!=null)
{
try
{
rsclose();
} catch (SQLException e)
{
eprintStackTrace();
}
}
if(pstmt!=null)
{
try
{
pstmtclose();
} catch (SQLException e)
{
// TODO Auto-generated catch block
eprintStackTrace();
}
}
if(con!=null)
{
try
{
conclose();
} catch (SQLException e)
{
// TODO Auto-generated catch block
eprintStackTrace();
}
}
}
public Connection getCon()
{
return con;
}
public void setCon(Connection con)
{
thiscon = con;
}
public PreparedStatement getPstmt()
{
return pstmt;
}
public void setPstmt(PreparedStatement pstmt)
{
thispstmt = pstmt;
}
public ResultSet getRs()
{
return rs;
}
public void setRs(ResultSet rs)
{
thisrs = rs;
}
public String getDriver()
{
return driver;
}
public void setDriver(String driver)
{
thisdriver = driver;
}
public String getDbname()
{
return dbname;
}
public void setDbname(String dbname)
{
thisdbname = dbname;
}
public String getUsername()
{
return username;
}
public void setUsername(String username)
{
thisusername = username;
}
public String getPassword()
{
return password;
}
public void setPassword(String password)
{
thispassword = password;
}
public String getUrl()
{
return url;
}
public void setUrl(String url)
{
thisurl = url;
}
}
java中使用jdbc连接sql server数据库步骤:
1JDBC连接SQL Server的驱动安装 ,前两个是属于数据库软件,正常安装即可(注意数据库登陆不要使用windows验证)
<1> 将JDBC解压缩到任意位置,比如解压到C盘program files下面,并在安装目录里找到sqljdbcjar文件,得到其路径开始配置环境变量
在环境变量classpath 后面追加 C:\Program Files\Microsoft SQL Server2005 JDBC Driver\sqljdbc_12\enu\sqljdbcjar
<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,查找目录添加sqljdbcjar
c右键单击目录窗口中的Test, 选择Build Path ->Configure Build Path, 添加扩展jar文件,即把sqljdbcjar添加到其中
<5> 编写Java代码来测试JDBC连接SQL Server数据库
import javasql;
public class Test {
public static void main(String[] srg) {
//加载JDBC驱动
String driverName = "commicrosoftsqlserverjdbcSQLServerDriver";
//连接服务器和数据库sample
String dbURL = "jdbc:sqlserver://localhost:1433; DatabaseName=sample";
String userName = "sa"; //默认用户名
String userPwd = "123456"; //密码
Connection dbConn;
try {
ClassforName(driverName);
dbConn = DriverManagergetConnection(dbURL, userName, userPwd);
Systemoutprintln("Connection Successful!"); //如果连接成功 控制台输出
} catch (Exception e) {
eprintStackTrace();
}
}
}
执行以后就可以连接到sample数据库了。
String sql = "insert into shuangseqiu ("+tem[0]+","+tem[1]","+tem[2]","+tem[3]","+tem[4]","+tem[5]","+tem[6]","+tem[7]",)";
或者
StringBuffer sb = new StringBuffer();
sbappend("insert into shuangseqiu (");
for(int i = 0; i < temlength; i++){
if(temlength -1 == i){
sbappend(tem[i]+")");
}else{
sbappend(tem[i]+",");
}
}
以上就是关于java 如何把文本里面的数据读取出来放入数据库里面全部的内容,包括:java 如何把文本里面的数据读取出来放入数据库里面、Java数据库连接怎么做(java代码连接数据库的步骤)、java怎样存数据到mysql数据库等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)