Javasource导入数据库(java中导入数据库)
如何用java实现mysql数据库的导入导出
要使用CMD命令窗口首先的将MYSQL环境变量设置到操作系统中,这是第一步,
导出MYSQL数据的命令如下:
mysqldump -u root [-p password] database [table] x.sql
注:root的登录数据库的用户名；database为使用到的数据库；table为表名；x.sql为导出的sql脚本
这样导出为一个SQL脚本文件,里面包括所有的建表语句与数据插入语句,
而数据导入也差不多,给传入一个SQL脚本,语句如下:
source d:/mysql.sql;
java怎么直连数据库，
1.引进所要的JDBC packag：eInmport java.sql.*
2.新建适用的JDBC驱动程序：Class.forName("net.sourceforge.jtds.jdbc.Driver")
3.通过JDBCURL取得数据库连接：Connection con=DriverManager.getConnection("s")
4.建立SQL语句对象 ：Statement stmt=con.createStatement()
5.执行SQL语句及接受返回结果：ResultSet rs=stmt.executeQuery("sqlstr")
6.关闭查询结果集ResultSet：rs.close()
7.关闭SQL语句连接 ：stmt.close()
8.关闭数据库连接：Conn.close()
我给你个完整的连接数据库小程序好了，适用ODBC桥接连接数据库必须要先建立数据源。
首先导入包sql，代码如下：
import java.sql.*;
定义一个类并创建主函数，然后在主函数里建立数据库连接，SQL语句对象，并执行。代码如下：
import java.sql.*;
public class test
{
public static void main(String args[])
{
String url="jdbc:odbc:testdsn";
String sql="insert into temps (姓名,年龄,性别) values('王五',43,'女')";
try
{
Class.forName("net.sourceforge.jtds.jdbc.Driver");
}
catch(ClassNotFoundException e)
{
e.printStackTrace();
}
try
{
Connection con=DriverManager.getConnection(url,"sa","1113");
Statement stmt=con.createStatement();
ResultSet rs=stmt.executeQuery(sql);
con.close();
}
catch(SQLException e)
{
e.printStackTrace();
}
}
}
java语言实现把txt文本文档里面的数据导入到SQL Server数据库的表中
假设sqlserver数据库DatabaseName=master，user = "sa"，password = "root"
数据库中表temperature中group,layer列为int类型，one,two,three,four列为float类型
源文件名为sourcefile.txt
我用正则表达式，帮你把数据导入到SQLServer中了，完整的Java程序如下：
import?java.io.BufferedReader;
import?java.io.FileNotFoundException;
import?java.io.FileReader;
import?java.io.IOException;
import?java.sql.Connection;
import?java.sql.DriverManager;
import?java.sql.PreparedStatement;
import?java.sql.SQLException;
import?java.util.regex.Matcher;
import?java.util.regex.Pattern;
public?class?CCA?{
?//SQLServer
?private?String?driverName?=?"com.microsoft.jdbc.sqlserver.SQLServerDriver";//加载驱动程序??
?private?String?url?=?"jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=master";//设置数据库连接串??master为数据库名
?private?String?user?=?"sa";//数据库登录用户名??
?private?String?password?=?"root";//数据库登录密码??
?public?Connection?getConnection()?{??
??try?{??
???Class.forName(driverName);??
???return?DriverManager.getConnection(url,?user,?password);??
??}?catch?(Exception?e)?{??
???e.printStackTrace();??
???return?null;??
??}??
?}??
?public?static?void?main(String[]?args)?{
??CCA?dcm?=?new?CCA();??
??String?sql?=?"insert?into?temperature(group,layer,one,two,three,four)?values(?,?,?,?,?,?)";
??Connection?conn=null;
??PreparedStatement?ps=null;
??BufferedReader?br=null;
??try?{
???conn?=?dcm.getConnection();?
???br=new?BufferedReader(new?FileReader("sourcefile.txt"));
???String?s="";
???String?regex="(\\d+)\\s+(\\d+)\\s+(\\d+\\.\\d+)\\s+(\\d+\\.\\d+)\\s+(\\d+\\.\\d+)\\s+(\\d+\\.\\d+)";
???while((s=br.readLine())!=null){
????s=s.trim();
????Pattern?p=Pattern.compile(regex);
????Matcher?m=p.matcher(s);
????if(m.matches()){
?????//System.out.println(m.group(1)+"?"+m.group(2)+"?"+m.group(3)+"?"+m.group(4)+"?"+m.group(5)+"?"+m.group(6));
?????ps=conn.prepareStatement(sql);
?????ps.setInt(1,?Integer.parseInt(m.group(1)));?
?????ps.setInt(2,?Integer.parseInt(m.group(2)));?
?????ps.setFloat(3,?Float.parseFloat(m.group(3)));?
?????ps.setFloat(4,?Float.parseFloat(m.group(4)));?
?????ps.setFloat(5,?Float.parseFloat(m.group(5)));?
?????ps.setFloat(6,?Float.parseFloat(m.group(6)));?
?????ps.executeUpdate();
????}
???}
???System.out.println("数据插入完毕！");
??}?catch?(FileNotFoundException?e)?{
???e.printStackTrace();
??}?catch?(IOException?e)?{
???e.printStackTrace();
??}catch?(SQLException?e)?{?
????e.printStackTrace();
???}finally{
???try?{
????ps.close();
????conn.close();
????br.close();
???}?catch?(Exception?e)?{
????e.printStackTrace();
???}
??}
?}
}
运行结果：
数据插入完毕！
Java中如何与数据库建立连接？
导入java.sql包
一、加载要连接数据库的驱动程序
//Jdbc-Odbc桥 和 Microsoft Access 数据库
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
// SQL Server 驱动程序:
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
注：Class.forName()方法将给定的类加载到JVM，如果系统中不存在给定的类，则会引发异常
二、通过驱动程序管理器得到连接实例
Connection conn=null;
//1.
//1.1建立数据源
conn=DriverManager.getConnection("jdbc:odbc:MyDataSource"); //MyDataSource是数据源名称
//1-2、不建立数据源
conn=DriverManager.getConnection("jdbc:odbc:;Driver=Microsoft Access Driver (*.mdb);DBQ=C:\\VBTest.mdb");
//2.SQL Server
conn=DriverManager.getConnection("jdbc:microsoft:sqlserver://127.0.0.1:1433;databasename=mydb","sa","");
注：DriverManager类跟踪已注册的驱动程序，通过getConnection(URL)方法, 找到一个能够连接至URL中指定的数据库驱动程序
它接收三个参数, 分别表示1 数据源的名称、类型 2 用户名（可选） 3 密码（可选）
三、基于连接对象建立处理器对象
Statement stmt=conn.createStatement();
四、准备sql命令
String sql="select * from Student";
五、执行命令返回结果集
ResultSet rs=stmt.executeQuery(sql);
六、显示结果集
while(rs.next())//只要后面有记录
{
//对当前行的所有字段遍历
for(int i=1;i=rs.getMetaData().getColumnCount();i++)
{
System.out.print(rs.getMetaData().getColumnName(i)+": ");//显示字段名
System.out.println(rs.getString(i));//显示字段当前值
}
System.out.println();
}
七、关闭资源
rs.close(); //关闭记录集
stmt.close(); //关闭处理器对象
conn.close(); //关闭连接对象
预处理器的应用：
//3.基于连接对象建立预处理器对象
PreparedStatement pstmt=conn.prepareStatement("insert into student values(?,?,?,?)");
//4.给预处理对象的参数赋值
pstmt.setString(1,"8888");
pstmt.setString(2,"nemo");
pstmt.setString(3,"accp");
pstmt.setString(4,"sanxianglu");
//5.执行预处理命令
int i=pstmt.executeUpdate();
System.out.println(i+"条记录已成功插入！");