创建存储过程,mysql同步的实现方法

MySQL 创建存储过程
“pr_add” 是个简单的 MySQL 存储过程,这个存储过程有两个 int 类型的输入参数

双向加密
    就让我们从最简单的加密开始:双向加密。在这里,一段数据通过一个密钥被加密,只能够由知道这个密钥的人来解密。MySQL有两个函数来支持这种类型的加密,分别叫做ENCODE()和DECODE()。下面是一个简单的实例:
    mysql> INSERT INTO users (username, password)
    VALUES ('joe', ENCODE('guessme', 'abracadabra'));
    Query OK, 1 row affected (0.14 sec)
    其中,Joe的密码是guessme,它通过密钥abracadabra被加密。要注意的是,加密完的结果是一个二进制字符串,如下所示:
    mysql> SELECT * FROM users WHERE username='joe';
    ---------- ----------
    | username | password |
    ---------- ----------
    | joe | ¡?i??!? |
    ---------- ----------
    1 row in set (0.02 sec)
    abracadabra这个密钥对于恢复到原始的字符串至关重要。这个密钥必须被传递给DECODE()函数,以获得原始的、未加密的密码。下面就是它的使用方法:
    mysql> SELECT DECODE(password, 'abracadabra')
    FROM users WHERE username='joe';
    ---------------------------------
    | DECODE(password, 'abracadabra') |
    ---------------------------------
    | guessme |
    ---------------------------------
    1 row in set (0.00 sec)
    应该很容易就看到它在Web应用程序里是如何运行的——在验证用户登录的时候,DECODE()会用网站专用的密钥解开保存在数据库里的密码,并和用户输入的内容进行对比。假设您把PHP用作自己的脚本语言,那么可以像下面这样进行查询:
    undefined undefined
    $query = "SELECT COUNT(*) FROM users WHERE
    username='$inputUser' AND DECODE(password,
    'abracadabra') = '$inputPass'";?>
    注意:虽然ENCODE()和DECODE()这两个函数能够满足大多数的要求,但是有的时候您希望使用强度更高的加密手段。在这种情况下,您可以使用AES_ENCRYPT()和AES_DECRYPT()函数,它们的工作方式是相同的,但是加密强度更高。

<?php
/**
* 输出一个数据库中的表到一个CSV文件中
*
* @param string Mysql数据库的主机
* @param string 数据库名称
* @param string 数据库中的表名
* @param string 数据库的连接用户名
* @param string 数据库的连接密码
* @param string 数据库的表名
* @param string 数据库的
* @param string 错误页面
* @param string SQL语句
*
* @return text 返回CSV格式的内容
*
* @access public
*/
function PMA_exportData(host,db,user,pass,filename,table, crlf, error_url, sql_query) {
what="csv";
csv_terminated=" ";
csv_separator=",";
csv_enclosed=" ";
csv_escaped=" ";
mysql_connect(host, user,pass) or die("不能连接数据库,错误代码如下:" . mysql_error());
mysql_select_db(db);
result = mysql_query(sql_query);
fields_cnt = mysql_num_fields(result);
cc="";
//fp = fopen(filename, 'w');
// 格式化数据
while (row = mysql_fetch_row(result)) {
schema_insert = '';
for (j = 0; j < fields_cnt; j ) {
if (!isset(row[j]) || is_null(row[j])) {
schema_insert .="NULL"; //用什么来替换空值
} elseif (row[j] == '0' || row[j] != '') {
// loic1 :用引号包含字段值
if (csv_enclosed == '') {
schema_insert .= row[j];
} else {
schema_insert .= csv_enclosed
. str_replace(csv_enclosed, csv_escaped . csv_enclosed, row[j])
. csv_enclosed;
}
} else {
schema_insert .= '';
}
if (j < fields_cnt-1) {
schema_insert .= csv_separator;
}
} // end for
// fwrite(fp,schema_insert . csv_terminated);
cc.=schema_insert . csv_terminated;
} // end while
mysql_free_result(result);
// fclose(fp);
return cc;
}
?>

“a”、“b”,返回这两个参数的和。

就让我们从最简单的加密开始:双向加密。在这里,一段数据通过一个密钥被加密,只能够由知道这个密钥的人来解密。MySQL有两...

<?php
/**
* 从一个上传的文件中将数据导入到一个表中
*
* @param string Mysql数据库的主机
* @param string 数据库名称
* @param string 数据库中的表名
* @param string 数据库的连接用户名
* @param string 数据库的连接密码
* @param string 数据库的表名
*
* @return bool 是否执行成功
*
* @access public
*/
function uploadFileOfCsv(host,db,user,pass,table,content){
mysql_connect(host, user,pass) or die("不能连接数据库,错误代码如下:" . mysql_error());
mysql_select_db(db);
result = mysql_query("select * from table");
fields_cnt = mysql_num_fields(result);
test2=array(array());
rownum=0;
log("提取的数据如下:<br>".content);
fd1 = fopen ("C:test.csv",'a');
fwrite(fd1,content);
fclose(fd1);
fp = fopen("C:test.csv", "r");
while (buffer = fgets(fp,4096))
{
i ;
tmp_arr = explode(",",buffer);
if(trim(tmp_arr[0]) == ""){
echo "<script language='javascript'>";
echo "alert('第".i."行的ID空,请检查!');";
echo "location.href=document.referrer;";
echo "</script>";
exit;
}
query = "INSERT INTO db.table";
query .=" values ( ";
for(q=0;q<fields_cnt;q ){
if(q==fields_cnt-1){
tmp=tmp_arr[q];
query.="'tmp');";
}else{
tmp=tmp_arr[q];
query.="'tmp',";
}
}//end for(q=0;
log2(query);
mysql_query(query);
}
fclose(fp);
return "OK";
unlink("C:test.csv");
}
function log2(event = null){
//global db;
// global login;
if(LOG_ENABLED){
now = date("Y-M-d H:i:s");
fd = fopen ("C:log.html",'a');
log = now." "._SERVER["REMOTE_ADDR"] ." - event <br>";
fwrite(fd,log);
fclose(fd);
}
}
?>

drop procedure if exists pr_add;

<?php
require_once("csv.php");
host="localhost";
db="project";
user="root";
pass="";
//导出tb_contact表的数据为csv文件
filename = 'file4.csv';
cc=PMA_exportData( host,db,user,pass, filename,"tb_project_dvp", "", "test.php", "select * from tb_project_dvp") ;
handle = fopen(filename, "rb");
contents = fread(handle, filesize (filename));
fclose(handle);
?>
<form id="form1" name="form1" method="post" action=";
<p>
<textarea name="textarea" cols="180" rows="30"><?php echo cc?></textarea>
<input type="hidden" name="action" value="1"/>
</p>
<p>
<input type="submit" name="Submit" value="提交">
</p>
</form>

-- 计算两个数之和

 

create procedure pr_add
(
   a int,
   b int
)
begin
   declare c int;

/** * 输出一个数据库中的表到一个CSV文件中 * * @param string Mysql数据库的主机 * @param string 数据库名称 * @param string 数据库中的表名 * @pa...

   if a is null then
      set a = 0;
   end if;

   if b is null then
      set b = 0;
   end if;

   set c = a b;

   select c as sum;

   /*
   return c;- 不能在 MySQL 存储过程中使用。return 只能出现在函数中。
  /
end;
二、调用 MySQL 存储过程
call pr_add(10, 20);
执行 MySQL 存储过程,存储过程参数为 MySQL 用户变量。

set @a = 10;
set @b = 20;

call pr_add(@a, @b);
三、MySQL 存储过程特点
创建 MySQL 存储过程的简单语法为:

create procedure 存储过程名字()
(
   [in|out|inout] 参数 datatype
)
begin
   MySQL 语句;
end;
MySQL 存储过程参数如果不显式指定“in”、“out”、“inout”,则默认为“in”。

习惯上,对于是“in” 的参数,我们都不会显式指定。

  1. MySQL 存储过程名字后面的“()”是必须的,即使没有一个参数,也需要“()”

  2. MySQL 存储过程参数,不能在参数名称前加“@”,如:“@a int”。下面的创建存

储过程语法在 MySQL 中是错误的(在 SQL Server 中是正确的)。 MySQL 存储过程中

的变量,不需要在变量名字前加“@”,虽然 MySQL 客户端用户变量要加个“@”。

create procedure pr_add
(
   @a int,- 错误
   b int   - 正确
)

  1. MySQL 存储过程的参数不能指定默认值。

  2. MySQL 存储过程不需要在 procedure body 前面加 “as”。而 SQL Server 存储过

程必须加 “as” 关键字。

create procedure pr_add
(
   a int,
   b int
)
as             - 错误,MySQL 不需要 “as”
begin
   mysql statement ...;
end;

  1. 如果 MySQL 存储过程中包含多条 MySQL 语句,则需要 begin end 关键字。

create procedure pr_add
(
   a int,
   b int
)
begin
   mysql statement 1 ...;
   mysql statement 2 ...;
end;

  1. MySQL 存储过程中的每条语句的末尾,都要加上分号 “;”

   ...

   declare c int;

   if a is null then
      set a = 0;
   end if;

   ...
end;

  1. MySQL 存储过程中的注释。

   /*
     这是个
     多行 MySQL 注释。
  /

   declare c int;    - 这是单行 MySQL 注释 (注意- 后至少要有一个空格)

   if a is null then 这也是个单行 MySQL 注释
      set a = 0;
   end if;

   ...
end;

  1. 不能在 MySQL 存储过程中使用 “return” 关键字。

   set c = a b;

   select c as sum;

   /*
   return c;- 不能在 MySQL 存储过程中使用。return 只能出现在函数中。
  /
end;

  1. 调用 MySQL 存储过程时候,需要在过程名字后面加“()”,即使没有一个参数,也

本文由ca88手机版登录发布于亚洲城ca88手机版官网,转载请注明出处:创建存储过程,mysql同步的实现方法

TAG标签: ca88手机版登录
Ctrl+D 将本页面保存为书签,全面了解最新资讯,方便快捷。