DB2表格資料遷移 db2指令 db2下載 db2資料庫入門教-php教程-PHP中文網

首頁

後端開發

php教程

DB2表格資料遷移 db2指令 db2下載 db2資料庫入門教

WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB

Jul 29, 2016 am 08:52 AM

db2遷移

系統用到一個遠端資料庫。地點在USA，連接速度特別慢。 DBA又不給導資料庫
只好自己寫一個資料庫表遷移的方法。但是只能一次一張表慢慢的導。使用PHP編寫

<code><span><?php </span><span>//原数据库</span><span>$databaseOri</span> = <span>'原数据库名称'</span>;
    <span>$hostnameOri</span> = <span>'IP地址'</span>;
    <span>$portOri</span> = <span>'端口号'</span>;
    <span>$userOri</span> = <span>'用户名'</span>;
    <span>$passwordOri</span> = <span>'密码'</span>;
    <span>$csOri</span>=<span>"DATABASE=$databaseOri;HOSTNAME=$hostnameOri;PORT=$portOri;PROTOCOL=TCPIP;UID=$userOri;PWD=$passwordOri;"</span>;
    <span>$dbOri</span> = db2_connect (<span>$csOri</span>, <span>$userOri</span>, <span>$passwordOri</span>);
    <span>//目标数据库</span><span>$databaseDes</span> = <span>'要转移到的数据库的名称'</span>;
    <span>$hostnameDes</span> = <span>'IP地址'</span>;
    <span>$portDes</span> = <span>'端口号'</span>;
    <span>$userDes</span> = <span>'用户名'</span>;
    <span>$passwordDes</span> = <span>'密码'</span>;
    <span>$csDes</span>=<span>"DATABASE=$databaseDes;HOSTNAME=$hostnameDes;PORT=$portDes;PROTOCOL=TCPIP;UID=$userDes;PWD=$passwordDes;"</span>;
    <span>$dbDes</span> = db2_connect (<span>$csDes</span>, <span>$userDes</span>, <span>$passwordDes</span>);

    <span>//执行sql的方法</span><span><span>function</span><span>fetcher</span><span>(<span>$db</span>, <span>$query</span>,<span>$par</span> = array<span>()</span>)</span>{</span><span>$stmt</span> = db2_prepare(<span>$db</span>, <span>$query</span>);
        <span>$res</span>=<span>array</span>();
        <span>if</span>(<span>$stmt</span>) {
          <span>//print_r($stmt);</span><span>$ex</span> = db2_execute(<span>$stmt</span>,<span>$par</span>);
          <span>if</span>(<span>$ex</span>) {
            <span>try</span>{
                <span>while</span>(<span>$row</span> = db2_fetch_assoc(<span>$stmt</span>)) {
                    array_push(<span>$res</span>, <span>$row</span>);
                } 
            }<span>catch</span>(<span>Exception</span><span>$e</span>){}
          }<span>else</span>{
            print_r(<span>$query</span>);
          }
        }
        <span>return</span><span>$res</span>;
    }

    <span>//插入数据库的方法</span><span><span>function</span><span>insertIntoDes</span><span>(<span>$db</span>, <span>$query</span>,<span>$par</span> = array<span>()</span>)</span>{</span><span>$stmt</span> = db2_prepare(<span>$db</span>, <span>$query</span>);
        <span>$res</span>=<span>array</span>();
        <span>if</span>(<span>$stmt</span>) {
          <span>$ex</span> = db2_execute(<span>$stmt</span>,<span>$par</span>);
          <span>if</span>(!<span>$ex</span>){
            print_r(<span>$query</span>);
          }
        }
        <span>return</span><span>$res</span>;
    }

    <span><span>function</span><span>transferDB</span><span>(<span>$tableName</span>,<span>$dbOri</span>,<span>$dbDes</span>)</span> {</span><span>//拼出要转移的table的所有字段名</span><span>$tableCloums</span> = fetcher(
            <span>$dbOri</span>,
            <span>"select NAME from sysibm.syscolumns where tbname='"</span>.<span>$tableName</span>.<span>"'"</span>,
            <span>array</span>()
        );
        <span>$tableParams</span> = <span>""</span>;
        <span>$insertParamsLength</span> = count(<span>$tableCloums</span>);
        <span>for</span>(<span>$temp</span>=<span>0</span>;<span>$temp</span>$insertParamsLength</span>;<span>$temp</span>++){
            <span>$tmpName</span> = <span>$tableCloums</span>[<span>$temp</span>][<span>"NAME"</span>];
            <span>$tableParams</span> = <span>$tableParams</span>.<span>$tmpName</span>;
            <span>//print_r($tableCloums[$temp]["NAME"]);</span><span>if</span>(<span>$temp</span> $insertParamsLength - <span>1</span> ){
                <span>$tableParams</span> = <span>$tableParams</span>.<span>","</span>;
            }
        }
        <span>//找出table的主键</span><span>$resultKeyArray</span> = fetcher(
            <span>$dbOri</span>,
            <span>"select NAME from sysibm.syscolumns where tbname='"</span>.<span>$tableName</span>.<span>"' and keyseq = '1'"</span>,
            <span>array</span>()
        );
        <span>if</span>(<span>$resultKeyArray</span>[<span>0</span>][<span>"NAME"</span>]){
            <span>$keyCloum</span> = <span>$resultKeyArray</span>[<span>0</span>][<span>"NAME"</span>];
        }<span>else</span>{
            <span>$keyCloum</span> = <span>"ID"</span>;
        }


        <span>//获取表的所有行数，因为如果表太大有几百万行的话，一下全导入到内存中会照成内存溢出</span><span>$count</span> = fetcher(
            <span>$dbOri</span>,
            <span>"select COUNT(*) from public."</span>.<span>$tableName</span>,
            <span>array</span>()
        );
        <span>$dataCount</span> = <span>$count</span>[<span>0</span>][<span>1</span>];
        <span>//确定要执行几次</span><span>$executeloops</span> = floor(<span>$dataCount</span> / <span>10000</span> + <span>1</span>);
        <span>//$executeloops = 1;</span><span>//循环执行</span><span>for</span>(<span>$i</span>=<span>0</span>;<span>$i</span>$executeloops;<span>$i</span>++){
            <span>$pageIndex</span> = <span>$i</span>;
            <span>$beginIndex</span> = <span>$i</span>*<span>10000</span>;
            <span>$endIndex</span> = (<span>$i</span>+<span>1</span>) * <span>10000</span>;
            <span>//通过分页查询，每次从原表中获取1万条数据</span><span>$getDataFromOriTab</span> = 
            <span>"select "</span>.<span>$tableParams</span>.<span>" from (
                select ROW_NUMBER() OVER(ORDER BY "</span>.<span>$keyCloum</span>.<span>" DESC) AS ROWNUM, "</span>.<span>$tableParams</span>.<span>" from public."</span>.<span>$tableName</span>.<span>"  
            ) a where ROWNUM > "</span>.<span>$beginIndex</span>.<span>" and ROWNUM .<span>$endIndex</span> ;
            <span>//fwrite($myfile, $getDataFromOriTab);</span><span>$tmpData</span> = fetcher(<span>$dbOri</span>,<span>$getDataFromOriTab</span>,<span>array</span>());
            <span>//拼接出insert语句中字段的value的值</span><span>$valueStr</span> = <span>""</span>;
            <span>foreach</span>(<span>$tmpData</span><span>as</span><span>$index</span> => <span>$row</span>){
                <span>$valueStr</span> = <span>""</span>;
                <span>foreach</span> (<span>$row</span><span>as</span><span>$cloumName</span> => <span>$value</span>) {
                    <span>if</span>(<span>empty</span>(<span>$value</span>)){
                        <span>$valueStr</span> = <span>$valueStr</span> . <span>"'',"</span>;
                    }<span>else</span><span>if</span> (is_null(<span>$value</span>)) {
                        <span>$valueStr</span> = <span>$valueStr</span> . <span>"null,"</span>;
                    }<span>else</span>{
                        <span>$valueStr</span> = <span>$valueStr</span> . <span>"$value,"</span>;
                    }
                }
                <span>$valueStr</span> = substr(<span>$valueStr</span>, <span>0</span>, -<span>1</span>);
                <span>$insertSql</span> = <span>"INSERT INTO public."</span>.<span>$tableName</span>.<span>" ("</span>.<span>$tableParams</span>.<span>") VALUES ("</span>.<span>$valueStr</span>.<span>");"</span>;
                insertIntoDes(<span>$dbDes</span>,<span>$insertSql</span>,<span>array</span>()); 
            }
        }

    }
    <span>//参数为要导的表的表名</span>
    transferDB(<span>"表名"</span>,<span>$dbOri</span>,<span>$dbDes</span>);
<span>?></span></span></code>

').addClass('pre-numbering').hide(); $(this).addClass('has-numbering').parent().append($numbering); for (i = 1; i ').text(i)); }; $numbering.fadeIn(1700); }); });

以上就介紹了DB2表格資料遷移，包含了db2,遷移方面的內容，希望對PHP教學有興趣的朋友有幫助。

陳述

本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn

使用數據庫存儲會話的優點是什麼？Apr 24, 2025 am 12:16 AM

使用數據庫存儲會話的主要優勢包括持久性、可擴展性和安全性。 1.持久性：即使服務器重啟，會話數據也能保持不變。 2.可擴展性：適用於分佈式系統，確保會話數據在多服務器間同步。 3.安全性：數據庫提供加密存儲，保護敏感信息。

您如何在PHP中實現自定義會話處理？Apr 24, 2025 am 12:16 AM

在PHP中實現自定義會話處理可以通過實現SessionHandlerInterface接口來完成。具體步驟包括：1)創建實現SessionHandlerInterface的類，如CustomSessionHandler；2)重寫接口中的方法（如open,close,read,write,destroy,gc）來定義會話數據的生命週期和存儲方式；3)在PHP腳本中註冊自定義會話處理器並啟動會話。這樣可以將數據存儲在MySQL、Redis等介質中，提升性能、安全性和可擴展性。

什麼是會話ID？Apr 24, 2025 am 12:13 AM

SessionID是網絡應用程序中用來跟踪用戶會話狀態的機制。 1.它是一個隨機生成的字符串，用於在用戶與服務器之間的多次交互中保持用戶的身份信息。 2.服務器生成並通過cookie或URL參數發送給客戶端，幫助在用戶的多次請求中識別和關聯這些請求。 3.生成通常使用隨機算法保證唯一性和不可預測性。 4.在實際開發中，可以使用內存數據庫如Redis來存儲session數據，提升性能和安全性。

您如何在無狀態環境（例如API）中處理會議？Apr 24, 2025 am 12:12 AM

在無狀態環境如API中管理會話可以通過使用JWT或cookies來實現。 1.JWT適合無狀態和可擴展性，但大數據時體積大。 2.Cookies更傳統且易實現，但需謹慎配置以確保安全性。

您如何防止與會議有關的跨站點腳本（XSS）攻擊？Apr 23, 2025 am 12:16 AM

要保護應用免受與會話相關的XSS攻擊，需採取以下措施：1.設置HttpOnly和Secure標誌保護會話cookie。 2.對所有用戶輸入進行輸出編碼。 3.實施內容安全策略(CSP)限制腳本來源。通過這些策略，可以有效防護會話相關的XSS攻擊，確保用戶數據安全。

您如何優化PHP會話性能？Apr 23, 2025 am 12:13 AM

优化PHP会话性能的方法包括：1.延迟会话启动，2.使用数据库存储会话，3.压缩会话数据，4.管理会话生命周期，5.实现会话共享。这些策略能显著提升应用在高并发环境下的效率。

什麼是session.gc_maxlifetime配置設置？Apr 23, 2025 am 12:10 AM

theSession.gc_maxlifetimesettinginphpdeterminesthelifespanofsessiondata，setInSeconds.1）它'sconfiguredinphp.iniorviaini_set（）.2）abalanceisesneededeededeedeedeededto toavoidperformance andunununununexpectedLogOgouts.3）

您如何在PHP中配置會話名？Apr 23, 2025 am 12:08 AM

在PHP中，可以使用session_name()函數配置會話名稱。具體步驟如下：1.使用session_name()函數設置會話名稱，例如session_name("my_session")。 2.在設置會話名稱後，調用session_start()啟動會話。配置會話名稱可以避免多應用間的會話數據衝突，並增強安全性，但需注意會話名稱的唯一性、安全性、長度和設置時機。

See all articles