并将结果写入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语法如下:

array mysql_fetch_assoc (resource $Result_Set)

范例代码如下：

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

原创文章，作者：ZXGMU，如若转载，请注明出处：https://www.506064.com/n/127547.html