並將結果寫入mysql數據庫（mysql數據文件入庫）

本文目錄一覽：

• 1、如何將這個PHP的結果保存到mysql數據庫。
• 2、如何將hive的結果寫入mysql
• 3、Hadoop MapReduce中把分析數據寫入mysql中
• 4、如何把JS獲得的值存入mysql數據庫
• 5、如何把採集結果存入mysql

如何將這個PHP的結果保存到mysql數據庫。

介紹php查詢mysql數據庫並將結果保存到數組的方法,實例分析了php使用mysql_fetch_assoc查詢數據庫的技巧,

實例講述了php查詢mysql數據庫並將結果保存到數組的方法。具體分析如下：

這裡主要用到了mysql_fetch_assoc函數

mysql_fetch_assoc語法如下:

?

1

array mysql_fetch_assoc (resource $Result_Set)

範例代碼如下：

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

?php

$UserName = ‘abc’;

$Password = ‘1234’;

$DbHandle = mysql_connect (‘localhost’, $UserName, $Password);

if (!$DbHandle) {

die ‘No database connection could be established.’;

}

$DBName = ‘w3db;

if (!mysql_select_db ($DBName, $DbHandle)) {

die ‘Database could not be selected.’;

}

$Query = “SELECT ISBN, Title, Author FROM articles”;

$articles = mysql_query ($Query, $DbHandle));

while ($Row = mysql_fetch_assoc ($articles)) {

echo “ISBN = $Row[‘ISBN’]br /\n”;

echo “Title = $Row[‘Title’]br /\n”;

echo “Author = $Row[‘Author’]br /\n”;

}

?

如何將hive的結果寫入mysql

大部分利用hive做數據分析的步驟是先用hive將統計結果導出到本地文件或者Hive的其他表中，再將本地文件導入到mysql或者利用sqoop將Hive表導入到mysql中。

今天同事給推薦了一個利用udf函數直接將統計結果導入mysql的方法。

步驟為

hiveadd jar /usr/lib/hive/lib/hive-contrib-0.9.0-cdh4.1.2.jar;

Added /usr/lib/hive/lib/hive-contrib-0.9.0-cdh4.1.2.jar to class path

Added resource: /usr/lib/hive/lib/hive-contrib-0.9.0-cdh4.1.2.jar

hiveadd jar /usr/share/java/mysql-connector-java-5.1.17.jar;

Added /usr/share/java/mysql-connector-java-5.1.17.jar to class path

Added resource: /usr/share/java/mysql-connector-java-5.1.17.jar

hiveCREATE TEMPORARY FUNCTION dboutput AS ‘org.apache.hadoop.hive.contrib.genericudf.example.GenericUDFDBOutput’;

hiveselect dboutput(‘jdbc:mysql://localhost/result’,’root’,’123456′,’INSERT INTO dc(code,size) VALUES (?,?)’,code,size) from accesslog limit 10;

註：result為mysql數據庫名，dc為數據庫result中的表名 dc(code,size)括號中的字段為mysql表dc字段，values(?,?)對應hive統計結果的值 後面的code,size為hive表中的字段，accesslog表示hive中的表名稱。

通過以上步驟即可將hive統計結果直接導入到mysql數據庫中。

Hadoop MapReduce中把分析數據寫入mysql中

你的job類並沒有設置outputformat，如需要輸出到數據庫，需要特定的輸出如下：

job.setJarByClass(TextCheckerJob.class);

job.setMapperClass(TextMapper.class);

job.setReducerClass(TextReduce.class);

job.setInputFormatClass(TextInputFormat.class);

job.setOutputFormatClass(MysqlDBOutputFormat.class);

job.setMapOutputKeyClass(Text.class);

job.setMapOutputValueClass(Text.class);

job.setOutputKeyClass(Text.class);

job.setOutputValueClass(Text.class);

job.setNumReduceTasks(1);

MysqlDBOutputFormat.setOutput(job, “data_chck_result”, new String[] { “tblName”, “colName”, “wrongValue”, “count” });

同時，job初始化之前，你需要把連接數據庫的信息寫入conf中，如下

conf.set(“mapreduce.jdbc.driver.class”, clazz);

conf.set(“mapreduce.jdbc.username”, username);

conf.set(“mapreduce.jdbc.password”, password);

conf.set(“mapreduce.jdbc.url”, url);

上面的MysqlDBOutputFormat類是我自己重寫了，你可以直接使用DBOutputFormat這個類

如何把JS獲得的值存入mysql數據庫

JS獲得的值 var name=document.getElenmentById(“username”).value;

用url 提交到後台 腳本 winodw.open(‘addname.php?username=’+name);

後台獲取前台提交的數據後用mysql命令寫入數據庫

?php

$username= $_GET[‘username’];

$link=mysql_connect(‘127.0.0.1′,’root’,’******’) or die(“connection error”.mysql_error());

$flag=mysql_select_db(“testdb”,$link);

mysql_query(“set names “.”utf8”); 

         mysql_query(‘insert into  user ( username) value (‘.$username.’)’);

?

如何把採集結果存入mysql

1. 建立一個數據庫。 打開Access–創建空數據庫Register.mdb【一定要保存成.mdb後綴形式】 創建—表設計—寫入字段名並選擇數據類型—保存為登記表 2.創建數據源DSN(Data Source Names)