symfony2中mysql和mongodb的增删改查总结
2016-01-13 19:24
701 查看
预定义文中用到的变量:
$em = $this->getDoctrine()->getEntityManager();
$repository = $em->getRepository(‘AcmeStoreBundle:Product’);
1.常用的查询
$repository->find($id); //获取的是一条数据
$repository->findAll(); //获取的是数组
$repository->findOneByName(‘Foo’);//获取的是一条数据
$repository->findBy(array(‘name’ => ‘foo’,‘price’ => 19.99),array(‘price’ => ‘ASC’));//获取的是一个数组
2、DQL
例题1.$query = $em->createQuery(
‘SELECT p FROM AcmeStoreBundle:Product p WHERE p.price > :price ORDER BY p.price ASC’
)->setParameter(‘price’, ’19.99′);
$products = $query->getResult();
注:(1) 获得一个结果可以用:$product = $query->getSingleResult();
(2) setParameter(‘price’, ’19.99′);运用这个外部方法来设置查询语句中的 “占位符”price 的值,而不是直接将数值写入查询语句中,有利于防止SQL注入攻击,你也可以设置多个参数:
->setParameters(array(
‘price’ => ’19.99′,
‘name’ => ‘Foo’,
))
例题2:
$em = $this->getDoctrine()->getEntityManager();
$repository = $em->getRepository(‘AcmeStoreBundle:Product’);
1.常用的查询
$repository->find($id); //获取的是一条数据
$repository->findAll(); //获取的是数组
$repository->findOneByName(‘Foo’);//获取的是一条数据
$repository->findBy(array(‘name’ => ‘foo’,‘price’ => 19.99),array(‘price’ => ‘ASC’));//获取的是一个数组
2、DQL
例题1.$query = $em->createQuery(
‘SELECT p FROM AcmeStoreBundle:Product p WHERE p.price > :price ORDER BY p.price ASC’
)->setParameter(‘price’, ’19.99′);
$products = $query->getResult();
注:(1) 获得一个结果可以用:$product = $query->getSingleResult();
(2) setParameter(‘price’, ’19.99′);运用这个外部方法来设置查询语句中的 “占位符”price 的值,而不是直接将数值写入查询语句中,有利于防止SQL注入攻击,你也可以设置多个参数:
->setParameters(array(
‘price’ => ’19.99′,
‘name’ => ‘Foo’,
))
例题2:
$query = $em->createQuery('SELECT min(bp.price) as minPrice FROM AppBundle:BookPackage bp WHERE bp.bookId=:bookId and bp.status<>2'); $query->setParameter('bookId', $bookId); return $query->getSingleScalarResult();
例题3、
$goodsIdListString = $this->_getGoodsIdList($materialList); $em = $this->getDoctrine()->getManager(); $query = $em->createQuery('SELECT p FROM AppBundle:Photo p WHERE p.subjectId in ('.$goodsIdListString.') and p.type=1 and p.status=0 ORDER BY p.createTime DESC'); $photoList = $query->getResult();
例题4、
if ($status == InventoryOrder::STATUS_SUBMITTED) { $index = 'i.submitTime'; } else if ($status == InventoryOrder::STATUS_UNSUBMITTED) { $index = 'i.createTime'; } else if (empty($status)) { $index = 'i.createTime'; } else { throw new \Exception('时间格式不正确', BaseException::ERROR_CODE_ILLEGAL_PARAMETER); } $sql = 'SELECT i FROM AppBundle:InventoryOrder i WHERE '; if(empty($startDate)) { throw new \Exception('起始时间不为空', BaseException::ERROR_CODE_ILLEGAL_PARAMETER); } if (empty($endDate)) { $endDate = $startDate; } $startTimestamp = strtotime($startDate); $endTimestamp = strtotime($endDate); if ($startTimestamp > $endTimestamp) { throw new \Exception('时间参数错误', BaseException::ERROR_CODE_ILLEGAL_PARAMETER); } $sql .= $index; $sql .= ' BETWEEN :startDate AND :endDate '; $start = date('Y-m-d 00:00:00', $startTimestamp); $end = date('Y-m-d 23:59:59', $endTimestamp); $params['endDate'] = $end; $params['startDate'] = $start; if (!empty($status)) { $sql .= ' AND i.status = :status'; $params['status'] = $status; } $sql .=' ORDER By i.createTime DESC'; $query = $this->entityManager->createQuery($sql); $orderList = $query->setParameters($params)->getResult();
3.Query Builder查询
例题1、
$query = $repository->createQueryBuilder(‘p’) ->where(‘p.price > :price’) ->setParameter(‘price’, ’19.99′) ->orderBy(‘p.price’, ‘ASC’) ->getQuery();$products = $query->getResult();可以在以下链接中获取更多的关于查询生成器的内例题2、
这其实是一个分页的查询
$repository = $this->getDoctrine() ->getRepository('AppBundle:Goods'); $query = $repository->createQueryBuilder('p') ->where('p.name like :name') ->andwhere('p.status = 0') ->setParameter('name', "$fuzzyGoodsInfo") ->orderBy('p.sales', 'DESC') ->setFirstResult($pageSize * $page) ->setMaxResults($pageSize) //相当于limit 取多少条数据 setLimit(100); ->getQuery(); $goodsList = $query->getResult();
例题3.使用queryBuilder方法:查询一个数组结果:materialId等于$materialId,并且action在$actionList数组内的。并且按照时间排序
$queryBuilder = $this->getEntityManager()->createQueryBuilder(); $resultList = $queryBuilder->select('s') ->from('AppBundle:StockHistory', 's') ->Where('s.materialId = :materialId') ->andWhere($queryBuilder->expr()->in('s.action', $actionList)) ->orderBy('s.createTime', 'DESC') ->setParameter('materialId', $materialId) ->getQuery()->getResult();
4.SQL的更新
$query = $em->createQuery("UPDATE AppBundle:ReceiverAddress u SET u.defaultFlag = 0 WHERE u.userId = :userId")->setParameter('userId',$userId); $result = $query->getResult();
二、mongodb的操作
//删除
// 删除掉当前goods下的所有Material $dm = $this->get('doctrine_mongodb')->getManager(); $dm->createQueryBuilder('AppBundle:Material') ->update() ->multiple(true) ->field('status')->set(2) ->field('goodsId')->equals($goodsId) ->getQuery() ->execute(); $dm->flush();
->multiple(true)这句话的意思,可以删除所有goodsId==$goodsId的记录,不加的话,就只删除第一条数据。//查询[/code]
1.根据id直接查询一条记录
$dm = $this->get('doctrine_mongodb')->getManager(); $material = $dm->getRepository('AppBundle:Material')->find(new \MongoId($materialId));2.往mongodb表中插入一条数据
$product = new Product(); $product->setName('A Foo Bar'); $product->setPrice('19.99'); $dm = $this->get('doctrine_mongodb')->getManager(); $dm->persist($product); $dm->flush();
//定义量$repository = $this->get('doctrine_mongodb') ->getManager() ->getRepository('AcmeStoreBundle:Product');[/code]
//查询语句
1.根据$id查询数据$product = $repository->find($id);$product = $repository->findOneById($id);$product = $repository->findOneByName('foo');// find *all* products$products = $repository->findAll();$products = $repository->findByPrice(19.99);
$product = $repository->findOneBy(array('name' => 'foo', 'price' => 19.99));
//多个条件查询 $products = $repository->findBy( array(
'name' => 'foo',
'status' => 0,
), array('price', 'ASC') );
//查询一条语句后,更改某个字段的值
$dm = $this->get('doctrine_mongodb')->getManager(); $product = $dm->getRepository('AcmeStoreBundle:Product')->find($id); if (!$product) { throw $this->createNotFoundException('No product found for id '.$id); } $product->setName('New product name!'); $dm->flush();
二、Query Builder查询
$products = $this->get('doctrine_mongodb') ->getManager() ->createQueryBuilder('AcmeStoreBundle:Product') ->field('name')->equals('foo') ->limit(10) ->sort('price', 'ASC') ->getQuery() ->execute()
相关文章推荐
- MongoDB3.2 集群搭建
- 解决 MongoDB 的 cursor id is not valid at server 问题
- 解决 MongoDB 的 cursor id is not valid at server 问题
- C#开发接口——MongoDB(对用户操作)
- 使用YCSB测试MongoDB的微分片性能
- C#开发接口——MongoDB(对库操作)
- mongodb的简单使用三(结合springdata 使用遇到的坑)
- MongoDB入门
- MongoDB 导入数据(CSV文件)
- MongoDB的安装与设置MongoDB服务
- C#开发接口——MongoDB
- 使用YCSB测试Mongodb性能的方法简介
- 学习mongo系列(十)MongoDB 备份(mongodump)与恢复(mongorerstore) 监控(mongostat mongotop)
- MongoDB数据的安装与启动
- MongoDB usage
- MongoDB使用小结:一些不常见的经验分享
- mongodb初步使用
- MongoDB学习笔记九:分片
- mongoDB 数据库导出与导入
- MongoDB数据库的介绍