具体的なコードは次のとおりです。 パッケージ epoint.mppdb_01.h3c; java.io.File をインポートします。 java.io.FileInputStream をインポートします。 java.io.FileOutputStream をインポートします。 java.io.InputStream をインポートします。 java.io.OutputStream をインポートします。 java.net.URI をインポートします。 java.sql.Blob をインポートします。 java.sql.Connection をインポートします。 java.sql.DriverManager をインポートします。 java.sql.ResultSet をインポートします。 java.sql.Statement をインポートします。 org.apache.commons.net.ftp.FTPClient をインポートします。 org.apache.commons.net.ftp.FTPReply をインポートします。 org.apache.hadoop.conf.Configuration をインポートします。 org.apache.hadoop.fs.FSDataInputStream をインポートします。 org.apache.hadoop.fs.FileSystem をインポートします。 org.apache.hadoop.fs.Path をインポートします。 org.apache.hadoop.io.IOUtils をインポートします。 パブリッククラスMySQLblobToMPPphoto { //MySQL 接続 public static Connection getMySQLConnection() throws Exception { 文字列 MySQLDRIVER = "com.mysql.jdbc.Driver"; 文字列 MySQLURL = "jdbc:mysql://192.168.186.13:3306/bigdata_scene03_rktj"; 文字列 MySQLUSERNAME = "root"; 文字列 MySQLPASSWORD = "Gepoint"; 接続 MySQLconn = DriverManager.getConnection(MySQLURL、MySQLUSERNAME、MySQLPASSWORD); MySQLconn を返します。 } //MPP接続 public static Connection getMPPConnection() throws Exception { 文字列 MPPDRIVER = "com.MPP.jdbc.Driver"; 文字列 MPPURL = "jdbc:MPP://192.168.186.14:5258/bigdata_scene03_rktj"; 文字列 MPPUSERNAME = "mpp"; 文字列 MPPPASSWORD = "h3c"; 接続 MPPconn = DriverManager.getConnection(MPPURL, MPPUSERNAME, MPPPASSWORD); MPPconn を返します。 } // パブリック静的void getMySQLblobToHDFS()は例外をスローします{ 接続 conn = getMySQLConnection(); 結果セット rs = null; 試す { 文字列 sql = "ROW_ID、photo を t_rk_baseinfo_blob から制限 10 で選択します"; ステートメント prest = conn.prepareStatement(sql); rs = prest.executeQuery(sql); (rs.next()) の間 { 行IDを1にする ブロブ写真 = rs.getBlob(2); System.out.println(row_id + " " + 写真); 入力ストリーム in = photo.getBinaryStream(); 出力ストリーム out = 新しい FileOutputStream("H:/photo/" + row_id + ".jpg"); 長さ = 0; byte[] buffer = 新しいbyte[1024]; ((len = in.read(buffer)) != -1) の間 { out.write(バッファ、0、長さ); } アップロード("H:/photo/" + row_id + ".jpg"); } プレストを閉じる(); rs.close(); } キャッチ (例外 e) { e.printStackTrace(); ついに // 接続を閉じる if (conn != null) { 試す { 接続を閉じる(); 接続 = null; } キャッチ (例外 e) { e.printStackTrace(); } } } } パブリック静的void main(String[] args)は例外をスローします{ MySQL の Blob を HDFS に取得します。 } //HDFS添付ファイルのアップロード public static void upload(String uploadpath) throws Exception { 構成 conf = new Configuration(); URI uri = 新しい URI("hdfs://192.168.186.14:8020"); ファイルシステム fs = FileSystem.get(uri, conf, "HDFS"); パス resP = new Path(uploadpath); パス destP = new Path("/photo"); (!fs.exists(destP))の場合{ fs.mkdirs(destP); } fs.copyFromLocalFile(resP, destP); fs.close(); System.out.println("************************"); System.out.println("アップロードに成功しました!"); } //HDFS添付ファイルのダウンロード public static void download() throws Exception { 構成 conf = new Configuration(); 文字列dest = "hdfs://192.168.186.14:/photo/11.png"; 文字列ローカル = "D://11.png"; ファイルシステム fs = FileSystem.get(URI.create(dest), conf, "hdfs"); FSDataInputStream fsdi = fs.open(新しいパス(dest)); 出力ストリーム output = new FileOutputStream(local); IOUtils.copyBytes(fsdi, 出力, 4096, true); System.out.println("************************"); System.out.println("ダウンロードに成功しました!"); } } 要約する 上記は、私が紹介したMySQLでのBLOBデータ処理方法です。お役に立てれば幸いです。ご質問がある場合は、メッセージを残してください。すぐに返信いたします。また、123WORDPRESS.COM ウェブサイトをサポートしてくださっている皆様にも感謝申し上げます。 以下もご興味があるかもしれません:
|
>>: Ubuntu での Subversion (SVN) の詳細なインストールと設定
目次1. Baidu Map Open Platformにアカウントを登録してログインする2. 必要...
序文以前、ローディングスタイルのコンポーネントを作成しました。コードの再利用性を実現するために、この...
この記事は、JS レッドブックの第 8 章に記載されているオブジェクトに関する 2 番目の記事です。...
目次Vuex とは何ですか? Vuexの5つの特性vuex の State 機能とは何ですか? vu...
1. 仮想環境virtualenvのインストール1. virtualenvをインストールするpip3...
Redis の紹介Redis は完全にオープンソースで無料であり、BSD プロトコルに準拠しており、...
表では、左上の境界線の色を個別に定義したり、セルの右下の境界線の色を定義したりできます。これら 2 ...
まずは適用方法を説明します。nginxモジュールにはjtxyとjtcmdの2つがあります。 http...
実際のプロジェクトでは、緊急事態を防ぐためにデータベースを頻繁にバックアップする必要があります。しば...
1. 概要この記事では、DOCTYPE要素を体系的に説明します。同時に、多くの情報を調べました。イン...
JS でよく使用されるイベントは次の通りです。ページイベント: load;フォーカス イベント: フ...
1. 組み込み関数1. 数学関数ランド()丸め(数値) ceil(数値)階数(数値)ランダム丸め切り...
ウェブサイトのレイアウトの多様化は、当社のフロントエンドの得意分野です。最近、UC ブラウザのデフォ...
この記事の例では、メモ帳機能を実装するためのVueの具体的なコードを参考までに共有しています。具体的...
概要インデックスは、テーブル内の 1 つ以上の列に基づいて DBMS によって特定の順序で作成される...