导航:首页 > 编程大全 > mysql数据库物理写入

mysql数据库物理写入

 发布时间：2024-03-21 15:33:23

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

(1)mysql数据库物理写入扩展阅读

样例

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

}

}

❷ MySQL数据库 写入大量数据如何实现

//最快的方法10000记录23MS
publicstaticvoidinsert(){
//开时时间
Longbegin=newDate().getTime();
//sql前缀
Stringprefix="INSERTINTOtb_big_data(count,create_time,random)VALUES";
try{
//保存sql后缀
StringBuffersuffix=newStringBuffer();
//设置事务为非自动提交
conn.setAutoCommit(false);
//Statementst=conn.createStatement();
//比起st，pst会更好些
PreparedStatementpst=conn.prepareStatement("");
//外层循环，总提交事务次数
for(inti=1;i<=100;i++){
//第次提交步长
for(intj=1;j<=10000;j++){
//构建sql后缀
suffix.append("("+j*i+",SYSDATE(),"+i*j
*Math.random()+"),");
}
//构建完整sql
Stringsql=prefix+suffix.substring(0,suffix.length()-1);
//添加执行sql
pst.addBatch(sql);
//执行操作
pst.executeBatch();
//提交事务
conn.commit();
//清空上一次添加的数据
suffix=newStringBuffer();
}
//头等连接
pst.close();
conn.close();
}catch(SQLExceptione){
e.printStackTrace();
}
//结束时间
Longend=newDate().getTime();
//耗时
System.out.println("cast:"+(end-begin)/1000+"ms");
}

❸ 把很多TXT文件内容写入MYSQL数据库，有一亿条数据，如何提高写入效率求高手赐教修改如下代码

非root用户运行MySQL，当MySQL配置比较高时，MySQL运行中生效的参数值与配置的值不一样,所以具体分析一下MySQL是怎么调整这些参数值的。这篇文章的目的是为了说明在系统资源不够的情况下，MySQL 是怎么调整者三个参数的。说明此文涉及到三个参数open_files_limit、max_connections、table_open_cache。与这三个参数相关的系统资源是打开文件数限制，即文件描述符（fd）限制。系统参数与文件描述符的关系-max_connection&fd: 每一个MySQL connection 都需要一个文件描述符；-table_open_cache&fd打开一张表至少需要一个 文件描述符，如打开MyISAM需要两个fd；- 系统最大打开文件数可以通过ulimit -n查看。MySQL调整参数的方式

❹ MYSQL数据库的物理设计都包括哪些内容，怎么设计

你想设计什么样的数据库啊?..可以简单的说明一下吗?..

设计数据库步骤:概念模型,逻辑模型,物理模型.
概念模型:用户需求和运行需求的一个高级表示.
逻辑模型:用于捕捉结构化数据的软件模型的详细表示.
物理模型:数据库的所有表和列的详细规范.

一,在概念上设计一个数据库(概念模型)
需求:实体,属性,关系.
软件:Microsoft Office Visio for Enterprise Anchitects
步骤:启用软件,创建实体,添加属性,添加关系

二,在逻辑上设计一个数据库来利用关系引擎
需求:表,列,外键.
软件:同上
在概念模型的基础上创建.

三,物理创建数据库.
1,打开SQL Server Management Studio
2,右击数据库-新建数据库.
架构:数据库-安全性(右击)-新建-架构
架构是用于简化数据库对象管理的一种命名空间.
创建表来实现：数据库-(右击)表-新建表;
设置主键:右击想要设置成主键的项-设置主键
CHECK约束:右击想要约束的项-CHECK约束-添加-表达式

数值属性:
1,整数和数量:
bit(0_1) tiyint(0_255) smallint(-32768_32767) int(-2147483648_2147483647) bigint(...)
2,精确数据:
decimal(精度9,小数位数0-5) numeric(19,0-9) dec(28/38 0-13/0-17) money(18,4) smallmoney(9,4)
3,科学与工程数据:
float(存储空间4/8,小数位数1-24/25-53) real(4,24) double(8,53)
4,字符串属性:
长度固定:char nchar
长度可变:varchar nvarchar
5,日期与时间属性:
datetime和smalldatetime

2005提供的约束:
NO NTULL:必需填的属性.
CREATE TABLE EM(
EMNumber INT NOT NULL
)

DEFAULT:插入一行的时候,如果没有为一个列指定值,就会自动使用DEFAULT值.

PRIMARY KEY:定义主键.
CREATE TABLE EM(
EMNumber INT NOT NULL
PRIMARY KEY(EMNumber,..)
)

UNIQUE:约束一个值,使它不在表中重复.
CREATE TABLE EM(
EMNumber INT NOT NULL
UNIQUE(EMNumber,..)
)

CHECK:限制列的取值范围和模式.
CREATE TABLE EM(
EMNumber INT NOT NULL
CHECK(EMNumber>0)
)

FOREIGN KEY:将一个列表中的值限制为可以在另一个列表中发现的值.
CREATE TABLE EM(
EMNumber INT NOT NULL
FOREING KEY(EMNumber,..)
)

注:使用时最好都使用代码来操作,并少用中文.
如果是MySQL里面设计的话..很简单..一句话..
create datebase [数据库名];
创建表:
create table [表名](
[表属性] [属性类型]
);
如:
//创建数据库
create datebase school;
//创建表
create table student(
no int primary key,
name varchar(10) not null
);

至于表属性的类型,你可以在网上找API文档..

❺ 要疯了，怎样用多线程向MYSQL数据库中写入数据

在MySQL 8.0 之前， 我们假设一下有一条烂SQL，

mysqlselect * from t1 order by rand() ;

以多个线程在跑，导致CPU被跑满了，其他的请求只能被阻塞进不来。那这种情况怎么办？


大概有以下几种解决办法：

阅读全文

与mysql数据库物理写入相关的资料

热点内容
旧版追书神器的文件在哪里 浏览：356
附近哪里有卖文件夹的 浏览：285
网络连接项目有哪些 浏览：253
系统备份镜像文件备份放到哪里 浏览：207
intelx58超频教程 浏览：590
在驱动器查找文件在哪里 浏览：15
pdf文件转换word时乱码 浏览：474
红色警戒3没有mod文件夹 浏览：587
企业服务代办平台App有哪些 浏览：103
桌面一个文件夹打不开 浏览：503
js设定日期 浏览：893
qq如何文件 浏览：159
win10游戏模式在那里 浏览：60
乌苏里船歌女声版本 浏览：942
数控铣t型槽怎么编程 浏览：36
我的世界win10合成表 浏览：410
ai怎么导小文件pdf 浏览：345
多益网络怎么通过 浏览：350
编程scratch软件怎么下载 浏览：595
json事件都有那些 浏览：566

友情链接