示例:

$result = array( 'id'=>null, 'val'=>0 ); $row1 = Yii::app()->db->createCommand()->insert('test1', $result); $id = Yii::app()->db->getLastInsertID(); $row2 = Yii::app()->db->createCommand()->update('test1', array('val'=>$id) , 'id=:id',array(':id'=>$id)); echo $id; exit;

#1. 建立数据库连接 可以使用 try...catch 捕获可能抛出的异常
#$connection=new CDbConnection($dsn,$username,$password);
# DSN格式
# SQLite: sqlite:/path/to/dbfile
# MySQL: mysql:host=localhost;dbname=testdb
# PostgreSQL: pgsql:host=localhost;port=5432;dbname=testdb
# SQL Server: mssql:host=localhost;dbname=testdb
# Oracle: oci:dbname=//localhost:1521/testdb
#在配置文件里面修改别名

array( 'components'=>array( 'db'=>array( 'class'=>'CDbConnection', 'connectionString'=>'mysql:host=localhost;dbname=testdb', 'username'=>'root', 'password'=>'password', 'emulatePrepare'=>true, // needed by some MySQL installations ), ), )

# 然后使用这种方式来建立连接,我们就可以通过

$connection = Yii::app()->db

# 访问数据库连接了。它已经被自动激活了,除非我们特意配置了
# CDbConnection::autoConnect 为 false。
# 通过这种方式,这个单独的DB连接就可以在我们代码中的很多地方共享。
# 如果没有,你可能需要显式建立一个连接:
# $connection=new CDbConnection($dsn,$username,$password);

$connection->active=true; # 建立链接之后active为true;$connection->active=false; # 关闭连接

#运行SQL

$command=$connection->createCommand($sql);

#SQL修改
$command->text = $newSQL;
#########################################################
#execute()方法用来执行 INSERT, UPDATE 和 DELETE 。
如果成功,它将返回此执行所影响的行数。
#query() 方法执行一条会返回若干行数据的 SQL 语句,例如 SELECT。
#如果成功,它将返回一个CDbDataReader 实例,通过此实例可以遍历数据的结果行。
#为简便起见, (Yii)还实现了一系列 queryXXX() 方法以直接返回查询结果
#如果SQL发生错误,将会抛出一个异常。.

$rowCount = $command->execute(); # 执行无查询 SQL $dataReader = $command->query(); # 执行一个 SQL 查询 $rows = $command->queryAll(); # 查询并返回结果中的所有行 $row = $command->queryRow(); # 查询并返回结果中的第一行 $column = $command->queryColumn(); # 查询并返回结果中的第一列 $value = $command->queryScalar(); # 查询并返回结果中第一行的第一个字段

#########################################################
#获取查询结果
#在生成 CDbDataReader后
#重复调用 CDbDataReader::read()
#也可以在 foreach 语言结构中使用 CDbDataReader
####例如####

$dataReader = $command->query();

#方法1 重复调用 read() 直到它返回 false
while( ($row = $dataReader->read()) !== false) { ... }
#方法2 使用 foreach 遍历数据中的每一行
foreach($dataReader as $row) { ... }
#方法3 一次性提取所有行到一个数组
$rows = $dataReader->readAll();
#注意:
#所有的 queryXXX() 方法会直接返回数据
#query()却不会,返回的是一个CDbDataReader 的实例
#使用事务

$transaction= $connection->beginTransaction(); try { $connection->createCommand($sql1)->execute(); $connection->createCommand($sql2)->execute(); #其他 $transaction->commit(); } catch(Exception $e) # 如果有一条查询失败,则会抛出异常 { $transaction->rollBack(); #回滚 }

#########################################################
#预处理(参数绑定) 避免注入 提高重复执行的效率
#占位符可以是命名的 (表现为一个唯一的标记) 或未命名的 (表现为一个问号)。占位符将被替换为实际的参数。
#调用 CDbCommand::bindParam() 或 CDbCommand::bindValue() 以使用实际参数替换这些占位符。
#这些参数不需要使用引号引起来:底层的数据库驱动会为你搞定这个参数绑定必须在 SQL 语句执行之前完成。
#示例
#一条带有两个占位符 ":username" 和 ":email"的 SQL

$sql="INSERT INTO tbl_user (username, email) VALUES(:username,:email)"; $command = $connection->createCommand($sql);

#用实际的用户名替换占位符 ":username"

$command->bindParam(":username", $username, PDO::PARAM_STR);

#用实际的 Email 替换占位符 ":email"

$command->bindParam(":email",$email,PDO::PARAM_STR); $command->execute();

#重复执行同一个逻辑的时候
#使用新的参数集插入另一行

$command->bindParam(":username",$username2,PDO::PARAM_STR); $command->bindParam(":email",$email2,PDO::PARAM_STR); $command->execute();

#bindParam() 和 bindValue() 非常相似。
#唯一的区别就是前者使用一个 PHP 变量绑定参数,
#而后者使用一个值。对于那些内存中的大数据块参数,处于性能的考虑,应优先使用前者。
#########################################################
#绑定列

$sql="SELECT username, email FROM tbl_user"; $dataReader=$connection->createCommand($sql)->query();

#使用 $username 变量绑定第一列 (username)

$dataReader->bindColumn(1,$username);

#使用 $email 变量绑定第二列 (email)

$dataReader->bindColumn(2,$email);