tripal_chado.cv.api.inc 50 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526
  1. <?php
  2. /**
  3. * @file
  4. * This module provides a set of functions to simplify working with
  5. * controlled vocabularies.
  6. */
  7. /**
  8. * @defgroup tripal_chado_api Controlled Vocabulary API
  9. * @ingroup tripal_api
  10. * This module provides a set of functions to simplify working with
  11. * controlled vocabularies. Most of the API functions deal with retrieving
  12. * terms or their parent vocabularies.
  13. *
  14. * However, the API also supports
  15. * generation of trees for browsing a vocabulary as well as generation of
  16. * pie graphs for display of hierarchical counts of terms. Version 0.3b of
  17. * Tripal provides a feature browser and a feature summary chart uses
  18. * the API functions provided here. But in general charts and trees can be
  19. * created for any controlled vocabulary.
  20. *
  21. */
  22. /**
  23. * Retrieves a chado controlled vocabulary variable
  24. *
  25. * @param $identifier
  26. * An array with the key stating what the identifier is. Supported keys (only on of the
  27. * following unique keys is required):
  28. * - cv_id: the chado cv.cv_id primary key
  29. * - name: the chado cv.name field (assume unique)
  30. * @param $options
  31. * An array of options. Supported keys include:
  32. * - Any keys supported by chado_generate_var(). See that function definition for
  33. * additional details.
  34. *
  35. * NOTE: the $identifier parameter can really be any array similar to $values passed into
  36. * chado_select_record(). It should fully specify the cv record to be returned.
  37. *
  38. * @return
  39. * If unique values were passed in as an identifier then an object describing the cv
  40. * will be returned (will be a chado variable from chado_generate_var()). Otherwise,
  41. * FALSE will be returned.
  42. *
  43. * @ingroup tripal_chado_api
  44. */
  45. function tripal_get_cv($identifiers, $options = array()) {
  46. // Set Defaults
  47. if (!isset($options['include_fk'])) {
  48. // Tells chado_generate_var not to follow any foreign keys
  49. $options['include_fk'] = array();
  50. }
  51. // Error Checking of parameters
  52. if (!is_array($identifiers)) {
  53. tripal_report_error(
  54. 'tripal_chado_api',
  55. TRIPAL_ERROR,
  56. "tripal_get_cv: The identifier passed in is expected to be an array with the key
  57. matching a column name in the cv table (ie: cv_id or name). You passed in %identifier.",
  58. array(
  59. '%identifier'=> print_r($identifiers, TRUE)
  60. )
  61. );
  62. }
  63. elseif (empty($identifiers)) {
  64. tripal_report_error(
  65. 'tripal_chado_api',
  66. TRIPAL_ERROR,
  67. "tripal_get_cv: You did not pass in anything to identify the cv you want. The identifier
  68. is expected to be an array with the key matching a column name in the cv table
  69. (ie: cv_id or name). You passed in %identifier.",
  70. array(
  71. '%identifier'=> print_r($identifiers, TRUE)
  72. )
  73. );
  74. }
  75. // Try to get the cv
  76. $cv = chado_generate_var(
  77. 'cv',
  78. $identifiers,
  79. $options
  80. );
  81. // Ensure the cv is singular. If it's an array then it is not singular
  82. if (is_array($cv)) {
  83. tripal_report_error(
  84. 'tripal_chado_api',
  85. TRIPAL_ERROR,
  86. "tripal_get_cv: The identifiers you passed in were not unique. You passed in %identifier.",
  87. array(
  88. '%identifier'=> print_r($identifiers, TRUE)
  89. )
  90. );
  91. }
  92. // Report an error if $cv is FALSE since then chado_generate_var has failed
  93. elseif ($cv === FALSE) {
  94. tripal_report_error(
  95. 'tripal_chado_api',
  96. TRIPAL_ERROR,
  97. "tripal_get_cv: chado_generate_var() failed to return a cv based on the identifiers
  98. you passed in. You should check that your identifiers are correct, as well as, look
  99. for a chado_generate_var error for additional clues. You passed in %identifier.",
  100. array(
  101. '%identifier'=> print_r($identifiers, TRUE)
  102. )
  103. );
  104. }
  105. // Else, as far we know, everything is fine so give them their cv :)
  106. else {
  107. return $cv;
  108. }
  109. }
  110. /**
  111. * Create an options array to be used in a form element which provides a
  112. * list of all chado cvs
  113. *
  114. * @return
  115. * An array(cv_id => name) for each cv in the chado cv table
  116. *
  117. * @ingroup tripal_chado_api
  118. */
  119. function tripal_get_cv_select_options() {
  120. $results = chado_select_record('cv', array('cv_id', 'name'), array(), array('order_by' => array('name' => 'ASC')));
  121. $options = array();
  122. $options[] = 'Select a Vocabulary';
  123. foreach ($results as $r) {
  124. $options[$r->cv_id] = $r->name;
  125. }
  126. return $options;
  127. }
  128. /**
  129. * Retrieves a chado controlled vocabulary term variable
  130. *
  131. * @param $identifier
  132. * An array apropriate for use with the chado_generate_var for uniquely
  133. * identifying a cvterm record. Alternativley, there are also some specially
  134. * handled keys. They are:
  135. * - id: an ID for the term of the for [dbname]:[accession], where [dbname]
  136. * is the short name of the vocabulary and accession is the unique ID.
  137. * - cv_id: an integer indicating the cv_id or an array with 'name' => the
  138. * name of the cv.
  139. * - synonym: an array with 'name' => the name of the synonym of the cvterm
  140. * you want returned; 'cv_id' => the cv_id of the synonym; 'cv_name' =>
  141. * the name of the cv of the synonym
  142. * - property: An array/object describing the property to select records
  143. * for. It should at least have either a type_name (if unique across cvs)
  144. * or type_id. Other supported keys include: cv_id/cv_name (of the type),
  145. * value and rank
  146. * @param $options
  147. * An array of options. Supported keys include:
  148. * - Any keys supported by chado_generate_var(). See that function
  149. * definition for additional details.
  150. *
  151. * NOTE: the $identifier parameter can really be any array similar to $values
  152. * passed into chado_select_record(). It should fully specify the cvterm
  153. * record to be returned.
  154. *
  155. * @return
  156. * If unique values were passed in as an identifier then an object describing
  157. * the cvterm will be returned (will be a chado variable from
  158. * chado_generate_var()). Otherwise, FALSE will be returned.
  159. *
  160. * @ingroup tripal_cv_api
  161. */
  162. function tripal_get_cvterm($identifiers, $options = array()) {
  163. // Set Defaults
  164. if (!isset($options['include_fk'])) {
  165. // Tells chado_generate_var to only get the cv
  166. $options['include_fk'] = array('cv_id' => TRUE);
  167. }
  168. // Error Checking of parameters
  169. if (!is_array($identifiers)) {
  170. tripal_report_error('tripal_cv_api', TRIPAL_ERROR,
  171. "tripal_get_cvterm: The identifier passed in is expected to be an array with the key
  172. matching a column name in the cvterm table (ie: cvterm_id or name). You passed in %identifier.",
  173. array('%identifier'=> print_r($identifiers, TRUE))
  174. );
  175. }
  176. elseif (empty($identifiers)) {
  177. tripal_report_error('tripal_cv_api', TRIPAL_ERROR,
  178. "tripal_get_cvterm: You did not pass in anything to identify the cvterm you want. The identifier
  179. is expected to be an array with the key matching a column name in the cvterm table
  180. (ie: cvterm_id or name). You passed in %identifier.",
  181. array('%identifier'=> print_r($identifiers, TRUE))
  182. );
  183. }
  184. // If synonym was passed in, then process this first before calling chado_generate_var()
  185. if (isset($identifiers['synonym'])) {
  186. $synonym = $identifiers['synonym']['name'];
  187. $values = array('synonym' => $synonym);
  188. if (isset($identifiers['synonym']['cv_id'])) {
  189. $values['cvterm_id'] = array('cv_id' => $identifiers['synonym']['cv_id']);
  190. }
  191. if (isset($identifiers['synonym']['cv_name'])) {
  192. $values['cvterm_id'] = array('cv_id' => array('name' => $identifiers['synonym']['cv_name']));
  193. }
  194. $options = array(
  195. 'case_insensitive_columns' => array('name')
  196. );
  197. $result = chado_select_record('cvtermsynonym', array('cvterm_id'), $values, $options);
  198. // if the synonym doens't exist or more than one record is returned then return false
  199. if (count($result) == 0) {
  200. return FALSE;
  201. }
  202. if (count($result) > 1) {
  203. return FALSE;
  204. }
  205. $identifiers = array('cvterm_id' => $result[0]->cvterm_id);
  206. }
  207. // If one of the identifiers is property then use chado_get_record_with_property()
  208. if (isset($identifiers['property'])) {
  209. $property = $identifiers['property'];
  210. unset($identifiers['property']);
  211. $cvterm = chado_get_record_with_property(
  212. array('table' => 'cvterm', 'base_records' => $identifiers),
  213. array('type_name' => $property),
  214. $options
  215. );
  216. }
  217. if (isset($identifiers['id'])) {
  218. list($db_name, $accession) = preg_split('/:/', $identifiers['id']);
  219. $cvterm = chado_generate_var('cvterm',array(
  220. 'dbxref_id' => array(
  221. 'db_id' => array(
  222. 'name' => $db_name,
  223. ),
  224. 'accession' => $accession,
  225. )
  226. ));
  227. }
  228. // Else we have a simple case and we can just use chado_generate_var to get the cvterm
  229. else {
  230. // Try to get the cvterm
  231. $cvterm = chado_generate_var('cvterm', $identifiers, $options);
  232. }
  233. // Ensure the cvterm is singular. If it's an array then it is not singular
  234. if (is_array($cvterm)) {
  235. tripal_report_error(
  236. 'tripal_cv_api',
  237. TRIPAL_ERROR,
  238. "tripal_get_cvterm: The identifiers you passed in were not unique. You passed in %identifier.",
  239. array(
  240. '%identifier'=> print_r($identifiers, TRUE)
  241. )
  242. );
  243. }
  244. // Report an error if $cvterm is FALSE since then chado_generate_var has failed
  245. elseif ($cvterm === FALSE) {
  246. tripal_report_error(
  247. 'tripal_cv_api',
  248. TRIPAL_ERROR,
  249. "tripal_get_cvterm: chado_generate_var() failed to return a cvterm based on the identifiers
  250. you passed in. You should check that your identifiers are correct, as well as, look
  251. for a chado_generate_var error for additional clues. You passed in %identifier.",
  252. array(
  253. '%identifier'=> print_r($identifiers, TRUE)
  254. )
  255. );
  256. }
  257. // Else, as far we know, everything is fine so give them their cvterm :)
  258. else {
  259. return $cvterm;
  260. }
  261. }
  262. /**
  263. * Create an options array to be used in a form element
  264. * which provides a list of all chado cvterms
  265. *
  266. * @param $cv_id
  267. * The chado cv_id; only cvterms with the supplied cv_id will be returned
  268. * @param $rel_type
  269. * Set to TRUE if the terms returned should only be relationship types in
  270. * the vocabulary. This is useful for creating drop-downs of terms
  271. * used for relationship linker tables.
  272. *
  273. * @return
  274. * An associative array with the cvterm_id's as keys. The first
  275. * element in the array has a key of '0' and a value of 'Select a Type'
  276. *
  277. * @ingroup tripal_chado_api
  278. */
  279. function tripal_get_cvterm_select_options($cv_id, $rel_type = FALSE) {
  280. $columns = array('cvterm_id', 'name');
  281. $values = array('cv_id' => $cv_id);
  282. if ($rel_type) {
  283. $values['is_relationshiptype'] = 1;
  284. }
  285. $s_options = array('order_by' => array('name' => 'ASC'));
  286. $cvterms = chado_select_record('cvterm', $columns, $values, $s_options);
  287. $options = array();
  288. $options[0] = 'Select a Type';
  289. foreach ($cvterms as $cvterm) {
  290. $options[$cvterm->cvterm_id] = $cvterm->name;
  291. }
  292. return $options;
  293. }
  294. /**
  295. * Updates the cvtermpath table of Chado for the specified CV.
  296. *
  297. * @param $cv_id
  298. * The chado cv_id;
  299. * @param $job_id
  300. * This function is intended to be used with the Tripal Jobs API.
  301. * When this function is called as a job the $job_id is automatically
  302. * passed to this function.
  303. * @return
  304. * TRUE on success FALSE on failure
  305. *
  306. * @ingroup tripal_chado_api
  307. */
  308. function tripal_update_cvtermpath($cv_id, $job_id = NULL) {
  309. // TODO: need better error checking in this function
  310. // first get the controlled vocabulary name:
  311. $sql = "SELECT * FROM {cv} WHERE cv_id = :cv_id";
  312. $cv = chado_query($sql, array(':cv_id' => $cv_id))->fetchObject();
  313. print "\nUpdating cvtermpath for $cv->name...\n";
  314. // We need to set the chado schema as active because some of the
  315. // functions call other functions which would not be in scope.
  316. $previous = chado_set_active('chado');
  317. try {
  318. $sql = "SELECT * FROM fill_cvtermpath(:name)";
  319. db_query($sql, array(':name' => $cv->name));
  320. chado_set_active($previous);
  321. }
  322. catch (Exception $e) {
  323. chado_set_active($previous);
  324. $error = $e->getMessage();
  325. tripal_report_error('tripal_chado', TRIPAL_ERROR, "Could not fill cvtermpath table: @error", array('@error' => $error));
  326. return FALSE;
  327. }
  328. return TRUE;
  329. }
  330. /**
  331. *
  332. * @param unknown $cv_id
  333. * @param string $job_id
  334. */
  335. function tripal_update_cvtermpath_bak($cv_id, $job_id = NULL){
  336. chado_set_active('chado');
  337. $result = db_query('
  338. SELECT DISTINCT t.*
  339. FROM cvterm t
  340. LEFT JOIN cvterm_relationship r ON (t.cvterm_id = r.subject_id)
  341. INNER JOIN cvterm_relationship r2 ON (t.cvterm_id = r2.object_id)
  342. WHERE t.cv_id = :cvid AND r.subject_id is null',
  343. array(':cvid' => $cv_id)
  344. );
  345. $record = $result->fetchObject();
  346. tripal_update_cvtermpath_root_loop($record->cvterm_id, $record->cv_id);
  347. }
  348. /**
  349. *
  350. * @param unknown $rootid
  351. * @param unknown $cvid
  352. */
  353. function tripal_update_cvtermpath_root_loop($rootid, $cvid){
  354. chado_set_active('chado');
  355. $ttype = db_select('cvterm', 'cv')
  356. ->fields('cv', array('cvterm_id'));
  357. $db_or = db_or();
  358. $db_or->condition('cv.name', "isa", '=' );
  359. $db_or->condition('cv.name', "is_a", '=' );
  360. $ttype->condition($db_or);
  361. $result = $ttype->execute()->fetchObject();
  362. tripal_update_cvtermpath_loop($rootid, $rootid, $cvid, $result->cvterm_id, 0, 0, array());
  363. $cterm = db_query(
  364. 'SELECT *
  365. FROM cvterm_relationship
  366. WHERE object_id = :rootid
  367. ',
  368. array(':rootid' => $rootid)
  369. );
  370. while($cterm_result = $cterm->fetchAssoc()) {
  371. tripal_update_cvtermpath_root_loop($cterm_result['subject_id'], $cvid);
  372. };
  373. }
  374. /**
  375. *
  376. * @param $origin
  377. * @param $subject_id
  378. * @param $cv_id
  379. * @param $type_id
  380. * @param $depth
  381. * @return multitype:
  382. */
  383. function tripal_update_cvtermpath_loop($origin, $child_id, $cv_id, $type_id, $depth, $increment_of_depth, $array_of_children){
  384. // Check to see if a row with these values already exists.
  385. chado_set_active('chado');
  386. $count = db_query(
  387. 'SELECT *
  388. FROM cvtermpath
  389. WHERE cv_id = :cvid
  390. AND object_id = :origin
  391. AND subject_id = :child_id
  392. AND pathdistance = :depth
  393. ',
  394. array(':cvid' => $cv_id, ':origin' => $origin, ':child_id' => $child_id, ':depth' => $depth)
  395. );
  396. $count_total = $count->rowCount();
  397. try{
  398. if($count_total == 0) {
  399. // If row with values does not already exist write to table.
  400. chado_set_active('chado');
  401. $query = db_insert('cvtermpath')
  402. ->fields(array(
  403. 'object_id' => $origin,
  404. 'subject_id' => $child_id,
  405. 'cv_id' => $cv_id,
  406. 'type_id' => $type_id,
  407. 'pathdistance' => $depth,
  408. ));
  409. $rows = $query->execute();
  410. }
  411. // Build the ID.
  412. $children_id = $origin.$child_id.$cv_id.$type_id;
  413. // Then add that new entry to the $array_of_children.
  414. $array_of_children[$increment_of_depth] = array('build_id'=>$children_id, 'depth' => $depth);
  415. // Now check if the most recent entry already exists in the array.
  416. if($increment_of_depth != 0){
  417. // Search the $array_of_children for the new $child_id in the build_id column.
  418. $possible_loop_starts = array_keys(array_column($array_of_children, 'build_id'), $children_id);
  419. // If the search returns something check for a possible loop.
  420. if(!empty($possible_loop_starts)){
  421. foreach($possible_loop_starts as $possible_loop_start){
  422. // Call the loop checker function.
  423. $result_of_loop_checker = tripal_update_cvtermpath_loop_checker($origin, $child_id, $cv_id, $type_id, $depth, $increment_of_depth, 0, $possible_loop_start, array());
  424. if($result_of_loop_checker == TRUE){
  425. continue;
  426. }
  427. }
  428. }
  429. }
  430. if ($count_total == 0) {
  431. chado_set_active('chado');
  432. $query = db_select('cvterm_relationship', 'cvtr')
  433. ->fields('cvtr')
  434. ->condition('cvtr.object_id', $child_id, '=')
  435. ->execute();
  436. $cterm = $query->fetchAll();
  437. foreach ($cterm as $item) {
  438. //watchdog('debug', '<pre>tripal_ds_preprocess_TripalEntity $item ' . print_r($item, TRUE) . '</pre>');
  439. $increment_of_depth++;
  440. tripal_update_cvtermpath_loop($origin, $item->subject_id, $cv_id, $item->type_id, $depth + 1, $increment_of_depth, $array_of_children);
  441. };
  442. //}
  443. }
  444. }
  445. catch(Exception $e){
  446. watchdog_exception('tripal_ds', $e);
  447. return FALSE;
  448. }
  449. return 1;
  450. }
  451. /**
  452. *
  453. * @param $origin
  454. * @param $subject_id
  455. * @param $cv_id
  456. * @param $type_id
  457. * @param $depth
  458. * @return bool
  459. */
  460. function tripal_update_cvtermpath_loop_checker($origin, $child_id, $cv_id, $type_id, $depth, $increment_of_depth, $distance_between_parent_child, $possible_start_of_loop, $array_of_possible_loop){
  461. if ($distance_between_parent_child > 1) {
  462. // Search the $array_of_children for the new $child_id in the build_id column.
  463. $possible_loop_starts = array_keys(array_column($array_of_possible_loop, 'build_id'), $possible_start_of_loop);
  464. // If the search returns something check for a possible loop.
  465. if (!empty($possible_loop_starts)) {
  466. foreach ($possible_loop_starts as $possible_loop_start) {
  467. // Check the depth measurements, if the depth is equal to the $distance_between_parent_child it's a loop.
  468. if ($possible_loop_start->depth == $distance_between_parent_child) {
  469. //This is a loop so it needs to be terminated.
  470. return TRUE;
  471. }
  472. }
  473. }
  474. chado_set_active('chado');
  475. $query = db_select('cvterm_relationship', 'cvtr')
  476. ->fields('cvtr')
  477. ->condition('cvtr.object_id', $child_id, '=')
  478. ->execute();
  479. $cterm = $query->fetchAll();
  480. foreach ($cterm as $item) {
  481. //watchdog('debug', '<pre>tripal_ds_preprocess_TripalEntity $item ' . print_r($item, TRUE) . '</pre>');
  482. $increment_of_depth++;
  483. $distance_between_parent_child++;
  484. $children_id = $origin . $item->subject_id . $cv_id . $item->type_id;
  485. $array_of_possible_loop[ $distance_between_parent_child ] = array('build_id' => $children_id, 'depth' => $depth);
  486. tripal_update_cvtermpath_loop_checker($origin, $item->subject_id, $cv_id, $item->type_id, $depth + 1, $increment_of_depth, $distance_between_parent_child, $possible_start_of_loop, $array_of_possible_loop);
  487. };
  488. return FALSE;
  489. }
  490. }
  491. /*
  492. *
  493. * @param $origin
  494. * @param $subject_id
  495. * @param $cv_id
  496. * @param $type_id
  497. * @param $depth
  498. * @return multitype:
  499. function tripal_update_cvtermpath_loop($origin, $child_id, $cv_id, $type_id, $depth){
  500. // Variables and arrays needed for loop checking.
  501. $array_of_children;
  502. $array_of_possible_loop;
  503. $possible_start_of_loop;
  504. $distance_between_parent_child;
  505. $increment_of_depth;
  506. chado_set_active('chado');
  507. $count = db_query(
  508. 'SELECT *
  509. FROM cvtermpath
  510. WHERE cv_id = :cvid
  511. AND object_id = :origin
  512. AND subject_id = :child_id
  513. AND pathdistance = :depth
  514. ',
  515. array(':cvid' => $cv_id, ':origin' => $origin, ':child_id' => $child_id, ':depth' => $depth)
  516. );
  517. $count_total = $count->rowCount();
  518. //Loop check
  519. chado_set_active('chado');
  520. $loop = db_query(
  521. 'SELECT *
  522. FROM cvtermpath
  523. WHERE cv_id = :cvid
  524. AND object_id = :origin
  525. AND subject_id = :child_id
  526. AND type_id = :type_id
  527. ',
  528. array(':cvid' => $cv_id, ':origin' => $origin, ':child_id' => $child_id, ':type_id' => $type_id,)
  529. );
  530. $loop_check = $loop->rowCount();
  531. //watchdog('debug', '<pre>tripal_ds_preprocess_TripalEntity $rows ' . print_r($rows, TRUE) . '</pre>');
  532. /*if(!empty($rows)){
  533. foreach($rows as $row){
  534. tripal_update_cvtermpath_loop_check($origin, $child_id, $cv_id, $type_id, $depth, $row->cvtermpath_id, 0);
  535. }
  536. }
  537. else {*/
  538. //If no loop proceed.
  539. /*try{
  540. if($count_total == 0) {
  541. chado_set_active('chado');
  542. $query = db_insert('cvtermpath')
  543. ->fields(array(
  544. 'object_id' => $origin,
  545. 'subject_id' => $child_id,
  546. 'cv_id' => $cv_id,
  547. 'type_id' => $type_id,
  548. 'pathdistance' => $depth,
  549. ));
  550. $rows = $query->execute();
  551. }
  552. if ($loop_check == 0) {
  553. chado_set_active('chado');
  554. $query = db_select('cvterm_relationship', 'cvtr')
  555. ->fields('cvtr')
  556. ->condition('cvtr.object_id', $child_id, '=')
  557. ->execute();
  558. $cterm = $query->fetchAll();
  559. foreach ($cterm as $item) {
  560. //watchdog('debug', '<pre>tripal_ds_preprocess_TripalEntity $item ' . print_r($item, TRUE) . '</pre>');
  561. tripal_update_cvtermpath_loop($origin, $item->subject_id, $cv_id, $item->type_id, $depth + 1);
  562. };
  563. //}
  564. }
  565. }
  566. catch(Exception $e){
  567. watchdog_exception('tripal_ds', $e);
  568. return FALSE;
  569. }
  570. return 1;
  571. }
  572. */
  573. /**
  574. *
  575. * @param $origin
  576. * @param $subject_id
  577. * @param $cv_id
  578. * @param $type_id
  579. * @param $depth
  580. * @return multitype:
  581. function tripal_update_cvtermpath_loop_check($origin, $child_id, $cv_id, $type_id, $depth, $cvtermpath_id, $loop_count, $loop_check, $object_id){
  582. //Store the
  583. //Check if the passed parameters match any of the items in the loop_check array.
  584. if(!empty($loop_check)){
  585. foreach($loop_check as $item){
  586. if ($item['type_id'] = $type_id){
  587. if($item['subject_id'] = $child_id){
  588. if($item['object_id'] = $object_id){
  589. //Loop found, roll back all rows until $cvtermpath_id-1 (last correct entry)
  590. // and step into the next loop
  591. }
  592. }
  593. }
  594. }
  595. }
  596. $loop_count + 1;
  597. chado_set_active('chado');
  598. $count = db_query(
  599. 'SELECT *
  600. FROM cvtermpath
  601. WHERE cv_id = :cvid AND object_id = :origin
  602. AND subject_id = :child_id
  603. AND pathdistance = :depth
  604. ',
  605. array(':cvid' => $cv_id, ':origin' => $origin, ':child_id' => $child_id, ':depth' => $depth)
  606. );
  607. $count_total = $count->rowCount();
  608. if ($count_total == 0) {
  609. chado_set_active('chado');
  610. $query = db_insert('cvtermpath')
  611. ->fields(array(
  612. 'object_id' => $origin,
  613. 'subject_id' => $child_id,
  614. 'cv_id' => $cv_id,
  615. 'type_id' => $type_id,
  616. 'pathdistance' => $depth,
  617. ));
  618. $rows = $query->execute();
  619. $cterm = array();
  620. $query = db_select('cvterm_relationship', 'cvtr')
  621. ->fields('cvtr')
  622. ->condition('cvtr.object_id', $child_id, '=' )
  623. ->execute();
  624. $cterm = $query->fetchAll();
  625. foreach ($cterm as $item) {
  626. $loop_check[$loop_count]= $item;
  627. tripal_update_cvtermpath_loop_check($origin, $item->subject_id, $cv_id, $item->type_id, $depth + 1, $loop_count, $loop_check, $item->object_id);
  628. };
  629. }
  630. return 1;
  631. }
  632. */
  633. /**
  634. * Adds a controlled vocabular to the CV table of Chado.
  635. *
  636. * @param $name
  637. * The name of the controlled vocabulary. These are typically all lower case
  638. * with no special characters other than an undrescore (for spaces).
  639. * @param $comment
  640. * A description or definition of the vocabulary.
  641. *
  642. * @return
  643. * An object populated with fields from the newly added database.
  644. *
  645. * @ingroup tripal_chado_api
  646. */
  647. function tripal_insert_cv($name, $definition) {
  648. // insert/update values
  649. $ins_values = array(
  650. 'name' => $name,
  651. 'definition' => $definition
  652. );
  653. // see if the CV default exists already in the database
  654. $sel_values = array('name' => $name);
  655. $results = chado_select_record('cv', array('*'), $sel_values);
  656. // if it does not exists then add it
  657. if (count($results) == 0) {
  658. $success = chado_insert_record('cv', $ins_values);
  659. if (!$success) {
  660. tripal_report_error('tripal_chado', TRIPAL_WARNING, "Failed to create the CV record", NULL);
  661. return FALSE;
  662. }
  663. $results = chado_select_record('cv', array('*'), $sel_values);
  664. }
  665. // if it already exists then do an update
  666. else {
  667. $success = chado_update_record('cv', $sel_values, $ins_values);
  668. if (!$success) {
  669. tripal_report_error('tripal_chado', TRIPAL_WARNING, "Failed to update the CV record", NULL);
  670. return FALSE;
  671. }
  672. $results = chado_select_record('cv', array('*'), $sel_values);
  673. }
  674. // return the cv object
  675. return $results[0];
  676. }
  677. /**
  678. * Add's a controlled vocabulary term to Chado.
  679. *
  680. * This function will add a cvterm record (and a dbxref record if appropriate
  681. * values are provided). If the parent vocabulary does not exist then
  682. * that also is added to the cv table. If the cvterm is a relationship term
  683. * then the 'is_relationship' value should be set. All
  684. * terms must also have a corresponding database. This is specified in the
  685. * term's ID just before the colon (e.g. GO:003824). If the database does not
  686. * exist in the DB table then it will be added automatically. The accession
  687. * (the value just after the colon in the term's ID) will be added to the
  688. * dbxref table. If the CVterm already exists and $update is set (default)
  689. * then the cvterm is updated. If the CVTerm already exists and $update is
  690. * not set, then no changes are made and the CVTerm object is returned.
  691. *
  692. * @param $term
  693. * An associative array with the following keys:
  694. * - id: the term accession. must be of the form <DB>:<ACCESSION>, where
  695. * <DB> is the name of the database to which the cvterm belongs and the
  696. * <ACCESSION> is the term's accession number in the database.
  697. * - name: the name of the term. usually meant to be human-readable.
  698. * - is_obsolete: is present and set to 1 if the term is defunct
  699. * - definition: the definition of the term
  700. * - cv_name: The CV name to which the term belongs. If this arugment is
  701. * null or not provided then the function tries to find a record in the
  702. * CV table with the same name provided in the $term[namespace]. If
  703. * this field is provided then it overrides what the value in
  704. * $term[namespace]
  705. * - is_relationship: If this term is a relationship term then this value
  706. * should be 1.
  707. * - db_name: In some cases the database name will not be part of the
  708. * $term['id'] and it needs to be explicitly set. Use this argument
  709. * only if the database name cannot be specififed in the term ID
  710. * (e.g. <DB>:<ACCESSION>).
  711. * @param $options
  712. * An associative array with the following keys:
  713. * - update_existing: By default this is TRUE. If the term exists it is
  714. * automatically updated.
  715. * - force_db_change: Sometimes a term may need to switch from one
  716. * database to another. If the term already exists, but associated
  717. * with another term the insert (or update, rather) will fail. Set
  718. * this variable to TRUE to force the change to occur.
  719. *
  720. * @return
  721. * A cvterm object
  722. *
  723. * @ingroup tripal_chado_api
  724. */
  725. function tripal_insert_cvterm($term, $options = array()) {
  726. // get the term properties
  727. $id = (isset($term['id'])) ? $term['id'] : '';
  728. $name = '';
  729. $cvname = '';
  730. $definition = '';
  731. $is_obsolete = 0;
  732. $accession = '';
  733. // Set Defaults
  734. if (isset($term['cv_name'])) {
  735. $cvname = $term['cv_name'];
  736. }
  737. else {
  738. $cvname = 'local';
  739. }
  740. // Namespace is deprecated but must be supported for backwards
  741. // compatability
  742. if (array_key_exists('namespace', $term)) {
  743. $cvname = $term['namespace'];
  744. }
  745. if (isset($term['is_relationship'])) {
  746. $is_relationship = $term['is_relationship'];
  747. }
  748. else {
  749. $is_relationship = 0;
  750. }
  751. if (isset($term['db_name'])) {
  752. $dbname = $term['db_name'];
  753. }
  754. else {
  755. $dbname = 'local';
  756. }
  757. if (isset($options['update_existing'])) {
  758. $update = $options['update_existing'];
  759. }
  760. else {
  761. $update = 1;
  762. }
  763. if (array_key_exists('name', $term)) {
  764. $name = $term['name'];
  765. }
  766. else {
  767. $name = $id;
  768. }
  769. if (array_key_exists('definition', $term)) {
  770. $definition = preg_replace('/^\"(.*)\"/', '\1', $term['definition']);
  771. }
  772. else {
  773. $definition = '';
  774. }
  775. if (array_key_exists('is_obsolete', $term)) {
  776. $is_obsolete = $term['is_obsolete'];
  777. if (strcmp($is_obsolete, 'true') == 0) {
  778. $is_obsolete = 1;
  779. }
  780. }
  781. if (!$name and !$id) {
  782. tripal_report_error('tripal_chado', TRIPAL_WARNING, "Cannot find cvterm without 'id' or 'name'", NULL);
  783. return 0;
  784. }
  785. if (!$id) {
  786. $id = $name;
  787. }
  788. // Get the accession and the database from the cvterm id.
  789. if ($dbname) {
  790. $accession = $id;
  791. }
  792. if (preg_match('/^.+?:.*$/', $id)) {
  793. $accession = preg_replace('/^.+?:(.*)$/', '\1', $id);
  794. $dbname = preg_replace('/^(.+?):.*$/', '\1', $id);
  795. }
  796. // Check that we have a database name, give a different message if it's a
  797. // relationship.
  798. if ($is_relationship and !$dbname) {
  799. tripal_report_error('tripal_chado', TRIPAL_WARNING,
  800. "A database name is not provided for this relationship term: $id", NULL);
  801. return 0;
  802. }
  803. if (!$is_relationship and !$dbname) {
  804. tripal_report_error('tripal_chado', TRIPAL_WARNING,
  805. "A database identifier is missing from the term: $id", NULL);
  806. return 0;
  807. }
  808. // Make sure the CV name exists
  809. $cv = tripal_get_cv(array('name' => $cvname));
  810. if (!$cv) {
  811. $cv = tripal_insert_cv($cvname, '');
  812. }
  813. if (!$cv) {
  814. tripal_report_error('tripal_chado', TRIPAL_WARNING,
  815. "Cannot find namespace '$cvname' when adding/updating $id", NULL);
  816. return 0;
  817. }
  818. // This SQL statement will be used a lot to find a cvterm so just set it
  819. // here for easy reference below. Because CV terms can change their names
  820. // but accessions don't change, the following SQL finds cvterms based on
  821. // their accession rather than the name.
  822. $cvtermsql = "
  823. SELECT CVT.name, CVT.cvterm_id, CV.cv_id, CV.name as cvname,
  824. DB.name as dbname, DB.db_id, DBX.accession
  825. FROM {cvterm} CVT
  826. INNER JOIN {dbxref} DBX on CVT.dbxref_id = DBX.dbxref_id
  827. INNER JOIN {db} DB on DBX.db_id = DB.db_id
  828. INNER JOIN {cv} CV on CV.cv_id = CVT.cv_id
  829. WHERE DBX.accession = :accession and DB.name = :name
  830. ";
  831. // Add the database. The function will just return the DB object if the
  832. // database already exists.
  833. $db = tripal_get_db(array('name' => $dbname));
  834. if (!$db) {
  835. $db = tripal_insert_db(array('name' => $dbname));
  836. }
  837. if (!$db) {
  838. tripal_report_error('tripal_chado', TRIPAL_WARNING, "Cannot find database '$dbname' in Chado.", NULL);
  839. return 0;
  840. }
  841. // The cvterm table has two unique dependencies. We need to check both.
  842. // first check the (name, cv_id, is_obsolete) constraint.
  843. $values = array(
  844. 'name' => $name,
  845. 'is_obsolete' => $is_obsolete,
  846. 'cv_id' => array(
  847. 'name' => $cvname,
  848. ),
  849. );
  850. $result = chado_select_record('cvterm', array('*'), $values);
  851. if (count($result) == 1) {
  852. $cvterm = $result[0];
  853. // Get the dbxref record.
  854. $values = array('dbxref_id' => $cvterm->dbxref_id);
  855. $result = chado_select_record('dbxref', array('*'), $values);
  856. $dbxref = $result[0];
  857. if (!$dbxref) {
  858. tripal_report_error('tripal_cv', TRIPAL_ERROR,
  859. 'Unable to access the dbxref record for the :term cvterm. Term Record: !record',
  860. array(':term' => $name, '!record' => print_r($cvterm, TRUE))
  861. );
  862. return FALSE;
  863. }
  864. // Get the db.
  865. $values = array('db_id' => $dbxref->db_id);
  866. $result = chado_select_record('db', array('*'), $values);
  867. $db_check = $result[0];
  868. // If the database from the existing record doesn't match the one that
  869. // has been provided then we have a problem. The term already exists
  870. // but we don't want to just switch the term, the callee must force it.
  871. if ($db_check->name != $db->name) {
  872. if (array_key_exists('force_db_change', $options) and
  873. $options['force_db_change'] != TRUE) {
  874. tripal_report_error('tripal_cv', TRIPAL_ERROR,
  875. 'The term already exists, but associated with a different database record: \'!db\'. It cannot be added: !record',
  876. array(':term' => $name, '!db' => $db_check->name, '!record' => print_r($cvterm, TRUE))
  877. );
  878. return FALSE;
  879. }
  880. // Look to see if the correct dbxref record already exists for this
  881. // database.
  882. $values = array(
  883. 'db_id' => $db->db_id,
  884. 'accession' => $accession,
  885. );
  886. $result = chado_select_record('dbxref', array('*'), $values);
  887. // If we already have a good dbxref then we want to update our cvterm
  888. // to use this dbxref.
  889. if (count($result) > 0) {
  890. $dbxref = $result[0];
  891. $match = array('cvterm_id' => $cvterm->cvterm_id);
  892. $values = array('dbxref_id' => $dbxref->dbxref_id);
  893. $success = chado_update_record('cvterm', $match, $values);
  894. if (!$success) {
  895. tripal_report_error('tripal_chado', TRIPAL_WARNING, "Failed to correct the dbxref id for the cvterm " .
  896. "'$name' (id: $accession), for database $dbname", NULL);
  897. return 0;
  898. }
  899. }
  900. // If we don't have the dbxref then we want to delete our cvterm and let
  901. // the code below recreate it with the correct info.
  902. else {
  903. $match = array('cvterm_id' => $cvterm->cvterm_id);
  904. chado_delete_record('cvterm', $match);
  905. }
  906. }
  907. // Check that the accession matches. Sometimes an OBO can define a term
  908. // multiple times but with different accessions. If this is the case we
  909. // can't do an insert or it will violate the constraint in the cvterm table.
  910. // So we'll need to add the record to the cvterm_dbxref table instead.
  911. if ($dbxref->accession != $accession) {
  912. // Get/add the dbxref for his term.
  913. $dbxref_new = tripal_insert_dbxref(array(
  914. 'db_id' => $db->db_id,
  915. 'accession' => $accession
  916. ));
  917. if (!$dbxref_new) {
  918. tripal_report_error('tripal_chado', TRIPAL_WARNING, "Failed to find or insert the dbxref record for cvterm, " .
  919. "$name (id: $accession), for database $dbname", NULL);
  920. return 0;
  921. }
  922. // Check to see if the cvterm_dbxref record already exists.
  923. $values = array(
  924. 'cvterm_id' => $cvterm->cvterm_id,
  925. 'dbxref_id' => $dbxref_new->dbxref_id,
  926. 'is_for_definition' => 1,
  927. );
  928. $result = chado_select_record('cvterm_dbxref', array('*'), $values);
  929. // if the cvterm_dbxref record does not exists then add it
  930. if (count($result)==0) {
  931. $options = array(
  932. 'return_record' => FALSE,
  933. );
  934. $success = chado_insert_record('cvterm_dbxref', $values, $options);
  935. if (!$success) {
  936. tripal_report_error('tripal_chado', TRIPAL_WARNING, "Failed to find or insert the cvterm_dbxref record for a " .
  937. "duplicated cvterm: $name (id: $accession), for database $dbname", NULL);
  938. return 0;
  939. }
  940. }
  941. // get the original cvterm with the same name and return that.
  942. $result = chado_query($cvtermsql, array(':accession' => $dbxref->accession, ':name' => $dbname));
  943. $cvterm = $result->fetchObject();
  944. return $cvterm;
  945. }
  946. // Continue on, we've fixed the record if the db_id did not match.
  947. // We can now perform and updated if we need to.
  948. }
  949. // get the CVterm record
  950. $result = chado_query($cvtermsql, array(':accession' => $accession, ':name' => $dbname));
  951. $cvterm = $result->fetchObject();
  952. if (!$cvterm) {
  953. // Check to see if the dbxref exists if not, add it.
  954. $dbxref = tripal_insert_dbxref(array(
  955. 'db_id' => $db->db_id,
  956. 'accession' => $accession
  957. ));
  958. if (!$dbxref) {
  959. tripal_report_error('tripal_chado', TRIPAL_WARNING, "Failed to find or insert the dbxref record for cvterm, " .
  960. "$name (id: $accession), for database $dbname", NULL);
  961. return 0;
  962. }
  963. // Check to see if the dbxref already has an entry in the cvterm table.
  964. $values = array('dbxref_id' => $dbxref->dbxref_id);
  965. $check = chado_select_record('cvterm', array('cvterm_id'), $values);
  966. if (count($check) == 0) {
  967. // now add the cvterm
  968. $ins_values = array(
  969. 'cv_id' => $cv->cv_id,
  970. 'name' => $name,
  971. 'definition' => $definition,
  972. 'dbxref_id' => $dbxref->dbxref_id,
  973. 'is_obsolete' => $is_obsolete,
  974. 'is_relationshiptype' => $is_relationship,
  975. );
  976. $success = chado_insert_record('cvterm', $ins_values);
  977. if (!$success) {
  978. if (!$is_relationship) {
  979. tripal_report_error('tripal_chado', TRIPAL_WARNING, "Failed to insert the term: $name ($dbname)", NULL);
  980. return 0;
  981. }
  982. else {
  983. tripal_report_error('tripal_chado', TRIPAL_WARNING, "Failed to insert the relationship term: $name (cv: " . $cvname . " db: $dbname)", NULL);
  984. return 0;
  985. }
  986. }
  987. }
  988. // This dbxref already exists in the cvterm table.
  989. else {
  990. tripal_report_error('tripal_chado', TRIPAL_WARNING, "The dbxref already exists for another cvterm record: $name (cv: " . $cvname . " db: $dbname)", NULL);
  991. return 0;
  992. }
  993. $result = chado_query($cvtermsql, array(':accession' => $accession, ':name' => $dbname));
  994. $cvterm = $result->fetchObject();
  995. }
  996. // Update the cvterm.
  997. elseif ($update) {
  998. // First, basic update of the term.
  999. $match = array('cvterm_id' => $cvterm->cvterm_id);
  1000. $upd_values = array(
  1001. 'name' => $name,
  1002. 'definition' => $definition,
  1003. 'is_obsolete' => $is_obsolete,
  1004. 'is_relationshiptype' => $is_relationship,
  1005. );
  1006. $success = chado_update_record('cvterm', $match, $upd_values);
  1007. if (!$success) {
  1008. tripal_report_error('tripal_chado', TRIPAL_WARNING, "Failed to update the term: $name", NULL);
  1009. return 0;
  1010. }
  1011. // Second, check that the dbxref has not changed and if it has then update it.
  1012. $checksql = "
  1013. SELECT cvterm_id
  1014. FROM {cvterm} CVT
  1015. INNER JOIN {dbxref} DBX on CVT.dbxref_id = DBX.dbxref_id
  1016. INNER JOIN {db} DB on DBX.db_id = DB.db_id
  1017. INNER JOIN {cv} CV on CV.cv_id = CVT.cv_id
  1018. WHERE DBX.accession = :accession and DB.name = :dbname and CVT.name = :term and CV.name = :cvname
  1019. ";
  1020. $check = chado_query($checksql, array(':accession' => $dbxref->accession, ':dbname' => $dbname, ':term' => $name, ':cvname' => $cvname))->fetchObject();
  1021. if (!$check) {
  1022. // check to see if the dbxref exists if not, add it.
  1023. $dbxref = tripal_insert_dbxref(array(
  1024. 'db_id' => $db->db_id,
  1025. 'accession' => $accession
  1026. ));
  1027. if (!$dbxref) {
  1028. tripal_report_error('tripal_chado', TRIPAL_WARNING, "Failed to find or insert the dbxref record for cvterm, " .
  1029. "$name (id: $accession), for database $dbname", NULL);
  1030. return 0;
  1031. }
  1032. $match = array('cvterm_id' => $cvterm->cvterm_id);
  1033. $upd_values = array(
  1034. 'dbxref_id' => $dbxref->dbxref_id,
  1035. );
  1036. $success = chado_update_record('cvterm', $match, $upd_values);
  1037. if (!$success) {
  1038. tripal_report_error('tripal_chado', TRIPAL_WARNING, "Failed to update the term $name with new accession $db:$accession", NULL);
  1039. return 0;
  1040. }
  1041. }
  1042. // Finally grab the updated details.
  1043. $result = chado_query($cvtermsql, array(':accession' => $dbxref->accession, ':name' => $dbname));
  1044. $cvterm = $result->fetchObject();
  1045. }
  1046. else {
  1047. // do nothing, we have the cvterm but we don't want to update
  1048. }
  1049. // return the cvterm
  1050. return $cvterm;
  1051. }
  1052. /**
  1053. * This function allows other modules to programatically
  1054. * submit an ontology for loading into Chado.
  1055. *
  1056. * This function will add a job to the Jobs subsystem for parsing the ontology.
  1057. * You can either pass a known OBO ID to the function or the URL
  1058. * or full path the the ontology file. If a URL or file name is
  1059. * passed then the $obo_name argument must also be provided. If
  1060. * this is the first time the ontology has been provided to Tripal
  1061. * then it will be added to the database and will be assigned a
  1062. * unique OBO ID.
  1063. *
  1064. * @param $obo_id
  1065. * If the ontology is already loaded into the Tripal tables then
  1066. * use this argument to specify the unique ID for the ontology
  1067. * that will be loaded
  1068. * @param $obo_name
  1069. * If the OBO has not been added before then use this argument
  1070. * to specify the human readable name of the ontology.
  1071. * @param $obo_url
  1072. * If the OBO to be loaded is located on a remote server then
  1073. * use this argument to provide the URL.
  1074. * @param $obo_file
  1075. * If the OBO is housed on the local file system of the server then
  1076. * use this argument to specify the full path.
  1077. *
  1078. * @return
  1079. * returns the job_id of the submitted job or FALSE if the job was not added
  1080. *
  1081. * @ingroup tripal_chado_api
  1082. */
  1083. function tripal_submit_obo_job($obo) {
  1084. global $user;
  1085. // Set Defaults
  1086. $obo['obo_id'] = (isset($obo['obo_id'])) ? $obo['obo_id'] : NULL;
  1087. $obo['name'] = (isset($obo['name'])) ? $obo['name'] : NULL;
  1088. $obo['url'] = (isset($obo['url'])) ? $obo['url'] : NULL;
  1089. $obo['file'] = (isset($obo['file'])) ? $obo['file'] : NULL;
  1090. $includes = array(
  1091. module_load_include('inc', 'tripal_chado', 'includes/loaders/tripal_chado.obo_loader'),
  1092. );
  1093. if ($obo['obo_id']) {
  1094. $sql = "SELECT * FROM {tripal_cv_obo} WHERE obo_id = :obo_id";
  1095. $result = db_query($sql, array(':obo_id' => $obo['obo_id']))->fetchObject();
  1096. $args = array($result->obo_id);
  1097. return tripal_add_job("Load OBO " . $result->name, 'tripal_chado',
  1098. "tripal_chado_load_obo_v1_2_id", $args, $user->uid, 10, $includes);
  1099. }
  1100. else {
  1101. if ($obo['url']) {
  1102. $args = array($obo['name'], $obo['url']);
  1103. return tripal_add_job("Load OBO " . $obo['name'], 'tripal_chado',
  1104. "tripal_chado_load_obo_v1_2_url", $args, $user->uid, 10, $includes);
  1105. }
  1106. elseif ($obo['file']) {
  1107. $args = array($obo['name'], $obo['file']);
  1108. return tripal_add_job("Load OBO " . $obo['name'], 'tripal_chado',
  1109. "tripal_chado_load_obo_v1_2_file", $args, $user->uid, 10, $includes);
  1110. }
  1111. }
  1112. return FALSE;
  1113. }
  1114. /**
  1115. * Add the OBO to the tripal_cv_obo table in the Drupal database.
  1116. *
  1117. * If the OBO name already exists in the table then the path is updated.
  1118. *
  1119. * @param $name
  1120. * The human readable name of this ontology
  1121. * @param $path
  1122. * The file path or URL of the ontology
  1123. *
  1124. * @return
  1125. * Returns the ontology ID
  1126. *
  1127. * @ingroup tripal_chado_api
  1128. */
  1129. function tripal_insert_obo($name, $path) {
  1130. // make sure an OBO with the same name doesn't already exist
  1131. $obo_id = db_select('tripal_cv_obo', 'tco')
  1132. ->fields('tco', array('obo_id'))
  1133. ->condition('name', $name)
  1134. ->execute()
  1135. ->fetchField();
  1136. if ($obo_id) {
  1137. db_update('tripal_cv_obo')
  1138. ->fields(array(
  1139. 'path' => $path,
  1140. ))
  1141. ->condition('name', $name)
  1142. ->execute();
  1143. return $obo_id;
  1144. }
  1145. else {
  1146. $obo_id = db_insert('tripal_cv_obo')
  1147. ->fields(array(
  1148. 'name' => $name,
  1149. 'path' => $path,
  1150. ))
  1151. ->execute();
  1152. return $obo_id;
  1153. }
  1154. }
  1155. /**
  1156. * Retrieves an OBO record.
  1157. *
  1158. * @param $values
  1159. * An associate array with the following allowed keys: obo_id, name
  1160. *
  1161. * @return
  1162. * An instance of an OBO record object.
  1163. */
  1164. function tripal_get_obo($values) {
  1165. $query = db_select('tripal_cv_obo', 'tco')
  1166. ->fields('tco');
  1167. if (array_key_exists('name', $values)) {
  1168. $query->condition('tco.name', $values['name']);
  1169. }
  1170. if (array_key_exists('obo_id', $values)) {
  1171. $query->condition('tco.obo_id', $values['obo_id']);
  1172. }
  1173. return $query->execute()->fetchObject();
  1174. }
  1175. /**
  1176. * This function is intended to be used in autocomplete forms
  1177. * for searching for CV terms that begin with the provided string
  1178. *
  1179. * @param $cv_id
  1180. * The CV ID in which to search for the term
  1181. * @param $string
  1182. * The string to search for
  1183. *
  1184. * @return
  1185. * A json array of terms that begin with the provided string
  1186. *
  1187. * @ingroup tripal_chado_api
  1188. */
  1189. function tripal_autocomplete_cvterm($cv_id, $string = '') {
  1190. if ($cv_id) {
  1191. $sql = "
  1192. SELECT CVT.cvterm_id, CVT.name
  1193. FROM {cvterm} CVT
  1194. WHERE CVT.cv_id = :cv_id and lower(CVT.name) like lower(:name)
  1195. UNION
  1196. SELECT CVT2.cvterm_id, CVTS.synonym as name
  1197. FROM {cvterm} CVT2
  1198. INNER JOIN {cvtermsynonym} CVTS ON CVTS.cvterm_id = CVT2.cvterm_id
  1199. WHERE CVT2.cv_id = :cv_id and lower(CVTS.synonym) like lower(:name)
  1200. ORDER by name
  1201. LIMIT 25 OFFSET 0
  1202. ";
  1203. $results = chado_query($sql, array(':cv_id' => $cv_id, ':name' => $string . '%'));
  1204. $items = array();
  1205. foreach ($results as $term) {
  1206. $items[$term->name] = $term->name;
  1207. }
  1208. }
  1209. // If a CV wasn't provided then search all of them, and include the cv
  1210. // in the results.
  1211. else {
  1212. $sql = "
  1213. SELECT CVT.cvterm_id, CVT.name, CV.name as cvname, CVT.cv_id
  1214. FROM {cvterm} CVT
  1215. INNER JOIN {cv} CV on CVT.cv_id = CV.cv_id
  1216. WHERE lower(CVT.name) like lower(:name)
  1217. UNION
  1218. SELECT CVT2.cvterm_id, CVTS.synonym as name, CV2.name as cvname, CVT2.cv_id
  1219. FROM {cvterm} CVT2
  1220. INNER JOIN {cv} CV2 on CVT2.cv_id = CV2.cv_id
  1221. INNER JOIN {cvtermsynonym} CVTS ON CVTS.cvterm_id = CVT2.cvterm_id
  1222. WHERE lower(CVTS.synonym) like lower(:name)
  1223. ORDER by name
  1224. LIMIT 25 OFFSET 0
  1225. ";
  1226. $results = chado_query($sql, array(':name' => $string . '%'));
  1227. $items = array();
  1228. foreach ($results as $term) {
  1229. $items[$term->name] = $term->name;
  1230. }
  1231. }
  1232. drupal_json_output($items);
  1233. }
  1234. /**
  1235. * Add a record to a cvterm linking table (ie: feature_cvterm)
  1236. *
  1237. * @param $basetable
  1238. * The base table to which the cvterm should be linked/associated. Thus to associate a
  1239. * cvterm to a feature the basetable=feature and cvterm_id is added to the feature_cvterm table.
  1240. * @param $record_id
  1241. * The primary key of the basetable to associate the cvterm with. This should be in integer.
  1242. * @param $cvterm
  1243. * An associative array describing the cvterm. Valid keys include:
  1244. * - name: the name for the cvterm,
  1245. * - cv_name: the name of the cv the cvterm belongs to.
  1246. * - cv_id: the primary key of the cv the cvterm belongs to.
  1247. * @param $options
  1248. * An associative array of options. Valid keys include:
  1249. * - insert_cvterm: Insert the cvterm if it doesn't already exist. FALSE is the default
  1250. *
  1251. * @ingroup tripal_chado_api
  1252. */
  1253. function tripal_associate_cvterm($basetable, $record_id, $cvterm, $options = array()) {
  1254. $linking_table = $basetable . '_cvterm';
  1255. $foreignkey_name = $basetable . '_id';
  1256. // Default Values
  1257. $options['insert_cvterm'] = (isset($options['insert_cvterm'])) ? $options['insert_cvterm'] : FALSE;
  1258. // If the cvterm_id is not set then find the cvterm record using the name and cv_id
  1259. if (!isset($cvterm['cvterm_id'])) {
  1260. $values = array(
  1261. 'name' => $cvterm['name'],
  1262. );
  1263. if (isset($cvterm['cv_id'])) {
  1264. $values['cv_id'] = $cvterm['cv_id'];
  1265. }
  1266. elseif (isset($cvterm['cv_name'])) {
  1267. $values['cv_id'] = array(
  1268. 'name' => $cvterm['cv_name']
  1269. );
  1270. }
  1271. else {
  1272. tripal_report_error('tripal_chado_api', TRIPAL_WARNING,
  1273. "tripal_associate_cvterm: The cvterm needs to have either the cv_name or cv_id
  1274. supplied. You were trying to associate a cvterm with the %base %record_id
  1275. and supplied the cvterm values: %cvterm.",
  1276. array('%base' => $basetable, '%record_id' => $record_id, '%cvterm' => print_r($cvterm,TRUE))
  1277. );
  1278. return FALSE;
  1279. }
  1280. // Get the cvterm. If it doesn't exist then add it if the option
  1281. // 'insert_cvterm' is set.
  1282. $select = chado_select_record('cvterm', array('*'), $values);
  1283. if ($select) {
  1284. $cvterm['cvterm_id'] = $select[0]->cvterm_id;
  1285. }
  1286. elseif ($options['insert_cvterm']) {
  1287. // Insert the cvterm
  1288. $insert = tripal_insert_cvterm($values);
  1289. if (isset($insert->cvterm_id)) {
  1290. $cvterm['cvterm_id'] = $insert->cvterm_id;
  1291. }
  1292. else {
  1293. tripal_report_error('tripal_chado_api', TRIPAL_WARNING,
  1294. "tripal_associate_cvterm: Unable to insert the cvterm using the cvterm values: %cvterm.",
  1295. array('%cvterm' => print_r($cvterm,TRUE))
  1296. );
  1297. return FALSE;
  1298. }
  1299. }
  1300. else {
  1301. tripal_report_error('tripal_api', TRIPAL_WARNING,
  1302. "tripal_associate_cvterm: The cvterm doesn't already exist. You supplied the cvterm values: %cvterm.",
  1303. array('%cvterm' => print_r($cvterm,TRUE))
  1304. );
  1305. return FALSE;
  1306. }
  1307. }
  1308. // Now add the link between the record & cvterm
  1309. if ($cvterm['cvterm_id'] > 0) {
  1310. $values = array(
  1311. 'cvterm_id' => $cvterm['cvterm_id'],
  1312. $foreignkey_name => $record_id,
  1313. 'pub_id' => 1,
  1314. );
  1315. // Check if the cvterm is already associated. If so, don't re-add it.
  1316. $result = chado_select_record($linking_table, array('*'), $values);
  1317. if (!$result) {
  1318. $success = chado_insert_record($linking_table, $values);
  1319. if (!$success) {
  1320. tripal_report_error('tripal_api', TRIPAL_WARNING,
  1321. "Failed to insert the %base record %term",
  1322. array('%base' => $linking_table, '%term' => $cvterm['name'])
  1323. );
  1324. return FALSE;
  1325. }
  1326. $result = chado_select_record($linking_table, array('*'), $values);
  1327. }
  1328. if (isset($result[0])) {
  1329. return $result[0];
  1330. }
  1331. else {
  1332. return FALSE;
  1333. }
  1334. }
  1335. return FALSE;
  1336. }
  1337. /**
  1338. * This function sets the default vocabulary for a given table and field.
  1339. *
  1340. * @param $table
  1341. * The name of the table that contains a field with a foreign key
  1342. * relationship to the cvterm table
  1343. * @param $field
  1344. * The table field name that has the foreign key relationship to the
  1345. * cvterm table for which the default vocabulary will be set
  1346. * @param $cv_name
  1347. * The name of the vocabulary
  1348. *
  1349. * @return
  1350. * TRUE if set, FALSE if an error occured
  1351. */
  1352. function tripal_set_default_cv($table, $field, $cv_name, $cv_id = FALSE) {
  1353. // Get the CV object
  1354. if ($cv_id) {
  1355. $cv = tripal_get_cv(array('cv_id' => $cv_id));
  1356. }
  1357. else {
  1358. $cv = tripal_get_cv(array('name' => $cv_name));
  1359. }
  1360. if ($cv) {
  1361. // first delete any entries for this table and field
  1362. $num_deleted = db_delete('tripal_cv_defaults')
  1363. ->condition('table_name', $table)
  1364. ->condition('field_name', $field)
  1365. ->execute();
  1366. // now add the default value
  1367. $cv_default_id = db_insert('tripal_cv_defaults')
  1368. ->fields(array(
  1369. 'table_name' => $table,
  1370. 'field_name' => $field,
  1371. 'cv_id' => $cv->cv_id,
  1372. ))
  1373. ->execute();
  1374. if (!$cv_default_id) {
  1375. tripal_report_error('tripal_chado', TRIPAL_WARNING,
  1376. "Cannot set default vocabulary for %table.%field. Check the error logs.",
  1377. array('%table' => $table, '%field' => $field));
  1378. return FALSE;
  1379. }
  1380. }
  1381. else {
  1382. tripal_report_error('tripal_chado', TRIPAL_WARNING,
  1383. "Cannot set default vocabulary for %table.%field. The vocabulary name, '%cvname', doesn't exist.",
  1384. array('%table' => $table, '%field' => $field, '%cvname' => $cv_name));
  1385. return FALSE;
  1386. }
  1387. }