CJDBCversion1.0.4: クラス org.objectweb.cjdbc.common.sql.InsertRequest

00107 { 00108 if (granularity == ParsingGranularities.NO_PARSING) 00109 { 00110 isParsed = true; 00111 return; 00112 } 00113 00114 // Sanity check 00115 if (schema == null) 00116 throw new SQLException( 00117 "Unable to parse request with an undefined database schema"); 00118 00119 String originalSQL = this.trimCarriageReturn(); 00120 String sql = originalSQL.toLowerCase(); 00121 00122 // Strip 'insert into ' 00123 sql = sql.substring(7).trim().substring(5).trim(); 00124 00125 // Look for the VALUES or SELECT clause 00126 int endIdx = sql.indexOf("values "); 00127 if (endIdx == -1) 00128 { 00129 endIdx = sql.indexOf("values("); 00130 if (endIdx == -1) 00131 { 00132 endIdx = sql.indexOf("select "); 00133 if (endIdx == -1) 00134 throw new SQLException( 00135 "Unable to find the VALUES or SELECT keyword in this INSERT statement: '" 00136 + sqlQuery + "'"); 00137 } 00138 } 00139 00140 if (isCaseSensitive) 00141 { 00142 int shift = originalSQL.length() - sql.length(); 00143 sql = originalSQL.substring(shift, shift + endIdx).trim(); 00144 } 00145 else 00146 sql = sql.substring(0, endIdx).trim(); 00147 00148 int openParenthesisIdx = sql.indexOf("("); 00149 00150 // Get the table on which INSERT occurs 00151 String insertTable; 00152 if (openParenthesisIdx == -1) 00153 insertTable = sql; 00154 else 00155 insertTable = sql.substring(0, openParenthesisIdx).trim(); 00156 00157 DatabaseTable t = schema.getTable(insertTable, isCaseSensitive); 00158 if (t == null) 00159 throw new SQLException("Unknown table '" + insertTable 00160 + "' in this INSERT statement: '" + sqlQuery + "'"); 00161 else 00162 tableName = t.getName(); 00163 00164 if ((granularity == ParsingGranularities.COLUMN) 00165 || (granularity == ParsingGranularities.COLUMN_UNIQUE)) 00166 { 00167 if (openParenthesisIdx != -1) 00168 { 00169 // Fetch the affected columns 00170 int closingParenthesisIdx = sql.indexOf(")"); 00171 if ((closingParenthesisIdx == -1) || (closingParenthesisIdx > endIdx)) 00172 { 00173 tableName = null; 00174 columns = null; 00175 throw new SQLException( 00176 "Syntax error in columns definition for this INSERT statement: '" 00177 + sqlQuery + "'"); 00178 } 00179 00180 // Column names are separated by comas 00181 StringTokenizer columnTokens = new StringTokenizer(sql.substring( 00182 openParenthesisIdx + 1, closingParenthesisIdx), ","); 00183 columns = new ArrayList(); 00184 DatabaseColumn col = null; 00185 while (columnTokens.hasMoreTokens()) 00186 { 00187 String token = columnTokens.nextToken().trim(); 00188 if ((col = t.getColumn(token)) == null) 00189 { 00190 tableName = null; 00191 columns = null; 00192 throw new SQLException("Unknown column name '" + token 00193 + "' in this INSERT statement: '" + sqlQuery + "'"); 00194 } 00195 else 00196 { 00197 columns.add(new TableColumn(tableName, col.getName())); 00198 } 00199 } 00200 } 00201 else 00202 { 00203 // All columns are affected 00204 columns = new ArrayList(); 00205 ArrayList cols = t.getColumns(); 00206 int size = cols.size(); 00207 for (int j = 0; j < size; j++) 00208 { 00209 columns.add(new TableColumn(tableName, ((DatabaseColumn) cols.get(j)) 00210 .getName())); 00211 } 00212 } 00213 } 00214 00215 isParsed = true; 00216 }


Public メソッド
	InsertRequest (String sqlQuery, boolean escapeProcessing, int timeout, String lineSeparator, DatabaseSchema schema, int granularity, boolean isCaseSensitive) throws SQLException
	InsertRequest (String sqlQuery, boolean escapeProcessing, int timeout, String lineSeparator)
void	parse (DatabaseSchema schema, int granularity, boolean isCaseSensitive) throws SQLException
void	cloneParsing (AbstractRequest request)
boolean	isInsert ()
boolean	isUpdate ()
boolean	isDelete ()
boolean	isCreate ()
boolean	isDrop ()
void	debug ()
boolean	isAlter ()

クラス org.objectweb.cjdbc.common.sql.InsertRequest

説明

Public メソッド

コンストラクタとデストラクタ

メソッド