本文目录一览：
- 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)
