導航:首頁 > 編程大全 > 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資料庫物理寫入相關的資料

熱點內容
ps導入ai什麼格式文件 瀏覽：255
手機升級系統的利弊 瀏覽：411
如何判斷兩列是否相同的數據 瀏覽：25
安卓系統微信文件夾 瀏覽：19
xp打開word找不到文件 瀏覽：488
文件名占容量 瀏覽：882
環型槽如何編程 瀏覽：290
excel怎麼分列每一列的第二行數據 瀏覽：240
美味餐廳13安卓版完整 瀏覽：708
請先卸載本地app什麼意思 瀏覽：639
廣東有什麼土建材料網站 瀏覽：613
安卓手機究竟應該給app什麼許可權 瀏覽：137
怎樣給特定文件夾加密碼 瀏覽：168
win10卡在85 瀏覽：421
excel文件怎麼無法打開 瀏覽：970
java文件路徑截取 瀏覽：271
html5公司網站 瀏覽：545
linux內核編譯arm 瀏覽：529
關於如何修改公司章程制度的文件 瀏覽：283
先進企業紅頭文件在哪裡找 瀏覽：546

友情鏈接