@@ -4,6 +4,7 @@ var mysql = require( "mysql" ),
4
4
var db ,
5
5
// TODO: make sure all queries support siteId
6
6
postsTable = "wp_" + ( config . siteId ? config . siteId + "_" : "" ) + "posts" ;
7
+ postmetaTable = "wp_" + ( config . siteId ? config . siteId + "_" : "" ) + "postmeta" ;
7
8
8
9
9
10
@@ -61,15 +62,15 @@ function setMeta( plugin, key, value, fn ) {
61
62
return fn ( new Error ( "Cannot set " + key + " for " + plugin + "." ) ) ;
62
63
}
63
64
64
- db . query ( "SELECT `meta_id` FROM `wp_postmeta ` " +
65
+ db . query ( "SELECT `meta_id` FROM `" + postmetaTable + " ` " +
65
66
"WHERE `post_id` = ? AND `meta_key` = ?" ,
66
67
[ id , key ] , function ( error , rows ) {
67
68
if ( error ) {
68
69
return fn ( error ) ;
69
70
}
70
71
71
72
if ( ! rows . length ) {
72
- db . query ( "INSERT INTO `wp_postmeta ` " +
73
+ db . query ( "INSERT INTO `" + postmetaTable + " ` " +
73
74
"SET `post_id` = ?, `meta_key` = ?, `meta_value` = ?" ,
74
75
[ id , key , value ] , function ( error ) {
75
76
if ( error ) {
@@ -79,7 +80,7 @@ function setMeta( plugin, key, value, fn ) {
79
80
fn ( null ) ;
80
81
} ) ;
81
82
} else {
82
- db . query ( "UPDATE `wp_postmeta ` " +
83
+ db . query ( "UPDATE `" + postmetaTable + " ` " +
83
84
"SET `meta_value` = ? WHERE `meta_id` = ?" ,
84
85
[ value , rows [ 0 ] . meta_id ] , function ( error ) {
85
86
if ( error ) {
@@ -103,7 +104,7 @@ function getMeta( plugin, key, fn ) {
103
104
return fn ( null , null ) ;
104
105
}
105
106
106
- db . query ( "SELECT `meta_value` FROM `wp_postmeta ` " +
107
+ db . query ( "SELECT `meta_value` FROM `" + postmetaTable + " ` " +
107
108
"WHERE `post_id` = ? AND `meta_key` = ?" ,
108
109
[ id , key ] , function ( error , rows ) {
109
110
if ( error ) {
0 commit comments