discuz 数据库操作方法

C对象，可以有效的利用缓存，数据获得都统一在 class/table 目录下，好处是所有的查询都集中和复用。方便维护和升级。默认的T方法有以下获得数据方式。每个数据表还需要看具体的表数据定义函数。

一、discuz数据操作之查：

1、fetch_all
 DB::fetch_all(sql, $arg = array());//取出符合条件的所有数据
 sql为查询语句，$arg为绑定参数
 例：$result = DB::fetch_all('SELECT * FROM %t',array('table_name'));
 $result为二维数组
2、fetch_first
 DB::fetch_first(sql, $arg = array());//取出符合条件的第一条数据
 例：$result = DB::fetch_first('SELECT * FROM %t ', array('table_name'));
 $result为一维数组

二、discuz数据操作之增：

DB::insert(参数一,参数二,参数三);
 /*
 参数一：table_name
 参数二：以对应数据表中的字段为key，具体数值为value组成的关联数组
 参数三：是否返回该数据的id。true则返回具体id，false则不会返回id
 */
 例：DB::insert('table_name',['name'=>'张三','age'=>'18','sex'=>'男'],true);

三、discuz数据操作之改：

DB::update(参数一,参数二,参数三);
 /*
 参数一：table_name
 参数二：以对应数据表中的字段为key，具体数值为value组成的关联数组
 参数三：修改的where条件
 */
 例：DB::update('table_name',['name'=>'张三','age'=>'19','sex'=>'男'],' id = 1 ');

四、discuz数据操作之删：

 DB::delete(参数一,参数二);
 /*
 参数一：table_name
 参数二：删除的where条件
 */
 例：$sql = 'id = '.$id;
 DB::delete('table_name',$sql);

以上是discuz的基本数据库操作。但实际开发中会对数据操作进行再封装，实际暴露的借口是用C::t()方法来进行数据操作

具体操作在source/class/table文件夹内创建一个文件

文件名为table_表名(注：是去掉表前缀的名字),例如：数据库中表名为pre_forum_post,那么该文件的名字为table_forum_post.php

例：

table_forum_design_list.php<?php/**
 *      [Discuz!] (C)2001-2099 Comsenz Inc.
 *      This is NOT a freeware, use is subject to license terms
 *
 *      $Id: table_forum_access.php 27777 2012-02-14 07:07:26Z zhengqingpeng $ */if(!defined('IN_DISCUZ')) {    exit('Access Denied');
}class table_forum_design_list extends discuz_table
{    public function __construct() {    $this->_table = 'forum_design_list';    $this->_pk    = '';

    parent::__construct();
    }    public function get_all() {    return DB::fetch_all('SELECT * FROM %t WHERE st != 0', array($this->_table));
    }    public function insert($data)
    {        return DB::insert($this->_table,$data,true);
    }    public function delete($id)
    {        $sql = 'id = '.$id;        return DB::delete($this->_table,$sql);
    }
}?>//外部文件调用方式$result = C::t('forum_design_list')->get_all();$result = C::t('forum_design_list')->insert($data);$result = C::t('forum_design_list')->delete(1);

根据上面代码所见，所有的直接操作数据库的操作都会写在表对应的class文件里。

补充一点，如何执行原生sql语句。

DB::query(sql,$arg = array());

1. 1.添加数据DB::insert

2. $uid=empty($_POST['uid']) ? "" : $_POST['uid'];

3. $username=empty($_POST['username']) ? "" : $_POST['username'];

4. $display_type=empty($_POST['display_type']) ? "" : $_POST['display_type'];

5. $filename=empty($_POST['filename']) ? "" : $_POST['filename'];

6. $details=empty($_POST['details']) ? "" : $_POST['details'];

7. $videoname=empty($_POST['videoname']) ? "" : $_POST['videoname'];

8. //$sql="insert into pre_home_video(uid,display_type,filename,default) values('$uid','$display_type','$filename','$default')";

9. //$query = DB::query($sql);

10. if(!empty($_POST['uid']) && !empty($_POST['display_type']) && !empty($_POST['display_type'] ))

11. {

12. $count = DB::result(DB::query("select uid from pre_common_member where uid= $uid"), 0);

13. if($count)

14. {

15. $arr=array();

16. $arr['uid'] = $uid;

17. $arr['username'] = $username;

18. $arr['display_type'] = $display_type;

19. $arr['filename'] = $filename;

20. $arr['details'] = $details;

21. $arr['videoname'] = $videoname;

22. if(!file_exists("data/video/{$uid}")){

23. mkdir("data/video/{$uid}", 0700);

24. }

25. if(!file_exists("data/video/{$uid}/cover")){

26. mkdir("data/video/{$uid}/cover", 0700);

27. }

28. $count1=DB::insert('home_video',$arr);

29. if($count1)

30. {

31. echo("<script type='text/javascript'>alert('添加成功');window.location = \"admin.php?action=video\";</script>");

32. 
    

33. }

34. }

35. else

36. {

37. echo("<script type='text/javascript'>alert('添加失败，该用户不存在');</script>");

38. }

39. 更新

40. $id = $_GET['id'] ? $_GET['id'] : 0;

41. $query = DB::query("select * from ".DB::table('home_hall')." where id=$id");

42. if($query){

43. $data = DB::fetch($query);

44. if($type == 'gold'){

45. if($op == 'add'){

46. $data['isgold'] = 1;

47. }elseif($op = 'cancle'){

48. $data['isgold'] = 0;

49. }

50. DB::update('home_hall', array('isgold'=>$data['isgold']),array('id'=> $id));

51. }elseif($type == 'index'){

52. if($op == 'add'){

53. $data['isindex'] = 1;

54. }elseif($op = 'cancle'){

55. $data['isindex'] = 0;

56. }

57. DB::update('home_hall', array('isindex'=>$data['isindex']),array('id'=> $id));

58. }

59. }else{

60. echo '没有此展厅';

61. }

62. 3.查询，返回结果集

63. $perpage = 25;

64. $start = ($page-1)*$perpage;

65. $mpurl = ADMINSCRIPT.'?action=goldhall';

66. $count = DB::result(DB::query("SELECT COUNT(*) FROM ".DB::table('home_hall')), 0);

67. if($count){

68. $query = DB::query("SELECT * FROM ".DB::table('home_hall')." limit $start, $perpage");

69. while ($value = DB::fetch($query)) {

70. $list[] = $value;

71. }

72. $multipage = multi($count, $perpage, $page, $mpurl);

73. }

74. 
    

75. echo '<table width="100%" border=1>';

76. echo '<tr><td>用户id</td><td>展厅名</td><td>展厅级别</td><td>联系电话</td><td>操作</td><td>操作</td></tr>';

77. foreach ($list as $k => $v){

78. echo "<tr>";

79. echo "<td>{$v['uid']}</td>";

80. echo "<td>{$v['hallname']}</td>";

81. echo $v['isgold'] ? "<td>金牌</td>" : "<td>普通</td>";

82. echo "<td>{$v['telephone']}</td>";

83. if($v['isgold'] == 1){

84. echo "<td><a href='admin.php?action=goldhall&id={$v['id']}&type=gold&op=cancle'>取消金牌展厅</a></td>";

85. }else{

86. echo "<td><a href='admin.php?action=goldhall&id={$v['id']}&type=gold&op=add'>升级</a></td>";

87. }

88. if($v['isindex'] == 1){

89. echo "<td><a href='admin.php?action=goldhall&id={$v['id']}&type=index&op=cancle'>取消首页推荐</a></td>";

90. }else{

91. echo "<td><a href='admin.php?action=goldhall&id={$v['id']}&type=index&op=add'>首页推荐</a></td>";

92. }

93. echo "</tr>";

94. }

95. echo '</table>';

96. if($multipage){

97. echo $multipage;

98. }

99. //删除

100. if($_GET['op'] == 'delete'){

101. if($gid){ //还要删除文件

102. DB::delete('saige_geku', array('id' => $gid));

103. DB::delete('saige_gekufield', array('gid' => $gid));

104. DB::delete('saige_gkcomment', array('gid' => $gid));

105. }

106. 
     

107. }