misc changes
[phpeclipse.git] / net.sourceforge.phpeclipse / src / net / sourceforge / phpeclipse / phpeditor / php / PHPCompletionProcessor.java
index 4d4acc5..84bfadb 100644 (file)
@@ -1,16 +1,20 @@
 /**********************************************************************
-Copyright (c) 2000, 2002 IBM Corp. and others.
-All rights reserved. This program and the accompanying materials
-are made available under the terms of the Common Public License v1.0
-which accompanies this distribution, and is available at
-http://www.eclipse.org/legal/cpl-v10.html
-
-Contributors:
-    IBM Corporation - Initial implementation
-    Klaus Hartlage - www.eclipseproject.de
-**********************************************************************/
+ Copyright (c) 2000, 2002 IBM Corp. and others.
+ All rights reserved. This program and the accompanying materials
+ are made available under the terms of the Common Public License v1.0
+ which accompanies this distribution, and is available at
+ http://www.eclipse.org/legal/cpl-v10.html
+
+ Contributors:
+ IBM Corporation - Initial implementation
+ Klaus Hartlage - www.eclipseproject.de
+ **********************************************************************/
 package net.sourceforge.phpeclipse.phpeditor.php;
 
+import java.sql.Connection;
+import java.sql.DatabaseMetaData;
+import java.sql.ResultSet;
+import java.sql.SQLException;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
@@ -24,24 +28,29 @@ import net.sourceforge.phpdt.internal.corext.template.ContextType;
 import net.sourceforge.phpdt.internal.corext.template.ContextTypeRegistry;
 import net.sourceforge.phpdt.internal.corext.template.php.CompilationUnitContextType;
 import net.sourceforge.phpdt.internal.corext.template.php.PHPUnitContext;
+import net.sourceforge.phpdt.internal.ui.PHPUiImages;
 import net.sourceforge.phpdt.internal.ui.text.java.IPHPCompletionProposal;
 import net.sourceforge.phpdt.internal.ui.text.java.PHPCompletionProposalComparator;
 import net.sourceforge.phpdt.internal.ui.text.template.BuiltInEngine;
 import net.sourceforge.phpdt.internal.ui.text.template.DeclarationEngine;
 import net.sourceforge.phpdt.internal.ui.text.template.IdentifierEngine;
+import net.sourceforge.phpdt.internal.ui.text.template.SQLProposal;
 import net.sourceforge.phpdt.internal.ui.text.template.TemplateEngine;
+import net.sourceforge.phpdt.ui.IWorkingCopyManager;
 import net.sourceforge.phpeclipse.PHPeclipsePlugin;
 import net.sourceforge.phpeclipse.builder.IdentifierIndexManager;
-import net.sourceforge.phpeclipse.phpeditor.AbstractContentOutlinePage;
-import net.sourceforge.phpeclipse.phpeditor.PHPContentOutlinePage;
 import net.sourceforge.phpeclipse.phpeditor.PHPEditor;
 import net.sourceforge.phpeclipse.phpeditor.PHPSyntaxRdr;
+import net.sourceforge.phpeclipse.ui.IPreferenceConstants;
+import net.sourceforge.phpeclipse.ui.overlaypages.Util;
 
 import org.eclipse.core.resources.IFile;
 import org.eclipse.core.resources.IProject;
 import org.eclipse.jface.text.BadLocationException;
 import org.eclipse.jface.text.IDocument;
+import org.eclipse.jface.text.IRegion;
 import org.eclipse.jface.text.ITextViewer;
+import org.eclipse.jface.text.Region;
 import org.eclipse.jface.text.TextPresentation;
 import org.eclipse.jface.text.contentassist.ICompletionProposal;
 import org.eclipse.jface.text.contentassist.IContentAssistProcessor;
@@ -53,17 +62,21 @@ import org.eclipse.swt.graphics.Image;
 import org.eclipse.ui.IEditorPart;
 import org.eclipse.ui.IFileEditorInput;
 
+import com.quantum.model.Bookmark;
+import com.quantum.model.BookmarkCollection;
+import com.quantum.model.NotConnectedException;
+import com.quantum.util.connection.ConnectionUtil;
+
 /**
  * Example PHP completion processor.
  */
 public class PHPCompletionProcessor implements IContentAssistProcessor {
-
   /**
-   * Simple content assist tip closer. The tip is valid in a range
-   * of 5 characters around its popup location.
+   * Simple content assist tip closer. The tip is valid in a range of 5
+   * characters around its popup location.
    */
-  protected static class Validator implements IContextInformationValidator, IContextInformationPresenter {
-
+  protected static class Validator implements IContextInformationValidator,
+      IContextInformationPresenter {
     protected int fInstallOffset;
 
     /*
@@ -74,23 +87,27 @@ public class PHPCompletionProcessor implements IContentAssistProcessor {
     }
 
     /*
-     * @see IContextInformationValidator#install(IContextInformation, ITextViewer, int)
+     * @see IContextInformationValidator#install(IContextInformation,
+     *      ITextViewer, int)
      */
     public void install(IContextInformation info, ITextViewer viewer, int offset) {
       fInstallOffset = offset;
     }
 
     /*
-     * @see org.eclipse.jface.text.contentassist.IContextInformationPresenter#updatePresentation(int, TextPresentation)
+     * @see org.eclipse.jface.text.contentassist.IContextInformationPresenter#updatePresentation(int,
+     *      TextPresentation)
      */
-    public boolean updatePresentation(int documentPosition, TextPresentation presentation) {
+    public boolean updatePresentation(int documentPosition,
+        TextPresentation presentation) {
       return false;
     }
   };
 
-  private static class ContextInformationWrapper implements IContextInformation, IContextInformationExtension {
-
+  private static class ContextInformationWrapper implements
+      IContextInformation, IContextInformationExtension {
     private final IContextInformation fContextInformation;
+
     private int fPosition;
 
     public ContextInformationWrapper(IContextInformation contextInformation) {
@@ -105,8 +122,8 @@ public class PHPCompletionProcessor implements IContentAssistProcessor {
     }
 
     /*
-    * @see IContextInformation#getImage()
-    */
+     * @see IContextInformation#getImage()
+     */
     public Image getImage() {
       return fContextInformation.getImage();
     }
@@ -130,25 +147,61 @@ public class PHPCompletionProcessor implements IContentAssistProcessor {
     }
   };
 
+  private class TableName {
+    String fTableName;
+
+    TableName() {
+      fTableName = null;
+    }
+
+    /**
+     * @return Returns the tableName.
+     */
+    public String getTableName() {
+      if (fTableName == null) {
+        return "<!--no-table-->";
+      }
+      return fTableName;
+    }
+
+    /**
+     * @param tableName
+     *          The tableName to set.
+     */
+    public void setTableName(String tableName) {
+      fTableName = tableName;
+    }
+  }
+
   private char[] fProposalAutoActivationSet;
+
   protected IContextInformationValidator fValidator = new Validator();
+
   private TemplateEngine fTemplateEngine;
+
   private PHPCompletionProposalComparator fComparator;
+
   private int fNumberOfComputedResults = 0;
 
-  public PHPCompletionProcessor() {
+  private IEditorPart fEditor;
 
-    ContextType contextType = ContextTypeRegistry.getInstance().getContextType("php"); //$NON-NLS-1$
+  protected IWorkingCopyManager fManager;
+
+  public PHPCompletionProcessor(IEditorPart editor) {
+    fEditor = editor;
+    fManager = PHPeclipsePlugin.getDefault().getWorkingCopyManager();
+    ContextType contextType = ContextTypeRegistry.getInstance().getContextType(
+        "php"); //$NON-NLS-1$
     if (contextType != null)
       fTemplateEngine = new TemplateEngine(contextType);
-
     fComparator = new PHPCompletionProposalComparator();
   }
 
   /**
    * Tells this processor to order the proposals alphabetically.
    * 
-   * @param order <code>true</code> if proposals should be ordered.
+   * @param order
+   *          <code>true</code> if proposals should be ordered.
    */
   public void orderProposalsAlphabetically(boolean order) {
     fComparator.setOrderAlphabetically(order);
@@ -158,28 +211,31 @@ public class PHPCompletionProcessor implements IContentAssistProcessor {
    * Sets this processor's set of characters triggering the activation of the
    * completion proposal computation.
    * 
-   * @param activationSet the activation set
+   * @param activationSet
+   *          the activation set
    */
   public void setCompletionProposalAutoActivationCharacters(char[] activationSet) {
     fProposalAutoActivationSet = activationSet;
   }
 
-  /* (non-Javadoc)
-   * Method declared on IContentAssistProcessor
+  /*
+   * (non-Javadoc) Method declared on IContentAssistProcessor
    */
-  public ICompletionProposal[] computeCompletionProposals(ITextViewer viewer, int documentOffset) {
-    int contextInformationPosition = guessContextInformationPosition(viewer, documentOffset);
-    return internalComputeCompletionProposals(viewer, documentOffset, contextInformationPosition);
+  public ICompletionProposal[] computeCompletionProposals(ITextViewer viewer,
+      int documentOffset) {
+    int contextInformationPosition = guessContextInformationPosition(viewer,
+        documentOffset);
+    return internalComputeCompletionProposals(viewer, documentOffset,
+        contextInformationPosition);
   }
 
-  private int getLastToken(ITextViewer viewer, int completionPosition, PHPUnitContext context) {
+  private int getLastToken(ITextViewer viewer, int completionPosition,
+      PHPUnitContext context, TableName tableName) {
     IDocument document = viewer.getDocument();
     int start = context.getStart();
     int end = context.getEnd();
-
     String startText;
     int lastSignificantToken = ITerminalSymbols.TokenNameEOF;
-
     try {
       // begin search 2 lines behind of this
       int j = start;
@@ -201,19 +257,35 @@ public class PHPCompletionProcessor implements IContentAssistProcessor {
       if (j != start) {
         // scan the line for the dereferencing operator '->'
         startText = document.get(j, start - j);
-        //                                             System.out.println(startText);
+        if (Scanner.DEBUG) {
+          System.out.println(startText);
+        }
+        int token = ITerminalSymbols.TokenNameEOF;
+        //        token = getLastSQLToken(startText);
+        tableName.setTableName(getLastSQLTableName(startText));
         Scanner scanner = ToolFactory.createScanner(false, false, false);
         scanner.setSource(startText.toCharArray());
         scanner.setPHPMode(true);
-        int token = ITerminalSymbols.TokenNameEOF;
         int beforeLastToken = ITerminalSymbols.TokenNameEOF;
         int lastToken = ITerminalSymbols.TokenNameEOF;
-
+        char[] ident;
         try {
           token = scanner.getNextToken();
           lastToken = token;
-          while (token != ITerminalSymbols.TokenNameERROR && token != ITerminalSymbols.TokenNameEOF) {
+          while (token != ITerminalSymbols.TokenNameERROR
+              && token != ITerminalSymbols.TokenNameEOF) {
             beforeLastToken = lastToken;
+            if (lastToken==ITerminalSymbols.TokenNameVariable) {
+              ident = scanner.getCurrentTokenSource();
+              if (ident.length==5 &&
+                  ident[0]=='$' &&
+                  ident[1]=='t' &&
+                  ident[2]=='h' &&
+                  ident[3]=='i' &&
+                  ident[4]=='s') {
+                beforeLastToken = ITerminalSymbols.TokenNamethis_PHP_COMPLETION;
+              }
+            }
             lastToken = token;
             //                                                         System.out.println(scanner.toStringAction(lastToken));
             token = scanner.getNextToken();
@@ -221,16 +293,16 @@ public class PHPCompletionProcessor implements IContentAssistProcessor {
         } catch (InvalidInputException e1) {
         }
         switch (lastToken) {
-          case ITerminalSymbols.TokenNameMINUS_GREATER :
-            // dereferencing operator '->' found
-            lastSignificantToken = ITerminalSymbols.TokenNameMINUS_GREATER;
-            if (beforeLastToken == ITerminalSymbols.TokenNamethis) {
-              lastSignificantToken = ITerminalSymbols.TokenNamethis;
-            }
-            break;
-          case ITerminalSymbols.TokenNamenew :
-            lastSignificantToken = ITerminalSymbols.TokenNamenew;
-            break;
+        case ITerminalSymbols.TokenNameMINUS_GREATER:
+          // dereferencing operator '->' found
+          lastSignificantToken = ITerminalSymbols.TokenNameMINUS_GREATER;
+          if (beforeLastToken == ITerminalSymbols.TokenNameVariable) {
+            lastSignificantToken = ITerminalSymbols.TokenNameVariable;
+          }
+          break;
+        case ITerminalSymbols.TokenNamenew:
+          lastSignificantToken = ITerminalSymbols.TokenNamenew;
+          break;
         }
       }
     } catch (BadLocationException e) {
@@ -238,117 +310,402 @@ public class PHPCompletionProcessor implements IContentAssistProcessor {
     return lastSignificantToken;
   }
 
-  private ICompletionProposal[] internalComputeCompletionProposals(ITextViewer viewer, int offset, int contextOffset) {
+  String getSQLTableName(String sqlText, int start) {
+    int tableNameStart = -1;
+    int currentCharacterPosition = start + 1;
+    char ch;
+    try {
+      while (true) {
+        ch = sqlText.charAt(currentCharacterPosition++);
+        if (tableNameStart == -1 && Character.isJavaIdentifierStart(ch)) {
+          tableNameStart = currentCharacterPosition - 1;
+        } else {
+          if (!Character.isJavaIdentifierPart(ch)) {
+            return sqlText.substring(tableNameStart,
+                currentCharacterPosition - 1);
+          }
+        }
+      }
+    } catch (IndexOutOfBoundsException e) {
+      if (tableNameStart >= 0) {
+        return sqlText.substring(tableNameStart, currentCharacterPosition - 1);
+      }
+    }
+    return "";
+  }
+
+  private String getLastSQLTableName(String startText) {
+    int token;
+    // scan for sql identifiers
+    char ch = ' ';
+    int currentSQLPosition = startText.length();
+    int identEnd = -1;
+    String ident = null;
+    boolean whiteSpace = true;
+    try {
+      while (true) {
+        ch = startText.charAt(--currentSQLPosition);
+        if (ch >= 'A' && ch <= 'Z') {
+          if (identEnd < 0) {
+            identEnd = currentSQLPosition + 1;
+          }
+        } else if (ch >= 'a' && ch <= 'z') {
+          if (identEnd < 0) {
+            identEnd = currentSQLPosition + 1;
+          }
+        } else if (identEnd >= 0) {
+          ident = startText.substring(currentSQLPosition + 1, identEnd);
+          // select -- from -- where --
+          // update -- set -- where --
+          // insert into -- ( -- ) values ( -- )
+          if (ident.length() >= 4 && ident.length() <= 6) {
+            ident = ident.toLowerCase();
+            switch (ident.length()) {
+            //              case 3 :
+            //                if (ident.equals("set")) {
+            //                  // System.out.println("set");
+            //                  token = ITerminalSymbols.TokenNameSQLset;
+            //                  return token;
+            //                }
+            //                break;
+            case 4:
+              if (ident.equals("from")) {
+                //                  System.out.println("from");
+                token = ITerminalSymbols.TokenNameSQLfrom;
+                return getSQLTableName(startText, identEnd);
+              } else if (ident.equals("into")) {
+                //                System.out.println("into");
+                token = ITerminalSymbols.TokenNameSQLinto;
+                return getSQLTableName(startText, identEnd);
+              }
+              break;
+            //              case 5 :
+            //                if (ident.equals("where")) {
+            //                  // System.out.println("where");
+            //                  token = ITerminalSymbols.TokenNameSQLwhere;
+            //                  return token;
+            //                }
+            //                break;
+            case 6:
+              //                if (ident.equals("select")) {
+              //                  // System.out.println("select");
+              //                  token = ITerminalSymbols.TokenNameSQLselect;
+              //                  return token;
+              //                } else if (ident.equals("insert")) {
+              //                  // System.out.println("insert");
+              //                  token = ITerminalSymbols.TokenNameSQLinsert;
+              //                  return token;
+              //                } else
+              if (ident.equals("update")) {
+                //                  System.out.println("update");
+                token = ITerminalSymbols.TokenNameSQLupdate;
+                return getSQLTableName(startText, identEnd);
+              }
+              //                else if (ident.equals("values")) {
+              //                  // System.out.println("values");
+              //                  token = ITerminalSymbols.TokenNameSQLvalues;
+              //                  return token;
+              //                }
+              break;
+            }
+          }
+          whiteSpace = false;
+          identEnd = -1;
+        } else if (Character.isWhitespace(ch)) {
+        } else {
+          whiteSpace = false;
+        }
+      }
+    } catch (IndexOutOfBoundsException e) {
+    }
+    return "<!--no-table-->";
+  }
+
+  /**
+   * Detect the last significant SQL token in the text before the completion
+   * 
+   * @param startText
+   */
+  private int getLastSQLToken(String startText) {
+    int token;
+    // scan for sql identifiers
+    char ch = ' ';
+    int currentSQLPosition = startText.length();
+    int identEnd = -1;
+    String ident = null;
+    boolean whiteSpace = true;
+    try {
+      while (true) {
+        ch = startText.charAt(--currentSQLPosition);
+        if (ch >= 'A' && ch <= 'Z') {
+          if (identEnd < 0) {
+            identEnd = currentSQLPosition + 1;
+          }
+        } else if (ch >= 'a' && ch <= 'z') {
+          if (identEnd < 0) {
+            identEnd = currentSQLPosition + 1;
+          }
+        } else if (identEnd >= 0) {
+          ident = startText.substring(currentSQLPosition + 1, identEnd);
+          // select -- from -- where --
+          // update -- set -- where --
+          // insert into -- ( -- ) values ( -- )
+          if (ident.length() >= 3 && ident.length() <= 6) {
+            ident = ident.toLowerCase();
+            switch (ident.length()) {
+            case 3:
+              if (ident.equals("set")) {
+                //                  System.out.println("set");
+                token = ITerminalSymbols.TokenNameSQLset;
+                return token;
+              }
+              break;
+            case 4:
+              if (ident.equals("from")) {
+                //                  System.out.println("from");
+                token = ITerminalSymbols.TokenNameSQLfrom;
+                //getSQLTableName();
+                return token;
+              } else if (ident.equals("into")) {
+                //                System.out.println("into");
+                token = ITerminalSymbols.TokenNameSQLinto;
+                return token;
+              }
+              break;
+            case 5:
+              if (ident.equals("where")) {
+                //                  System.out.println("where");
+                token = ITerminalSymbols.TokenNameSQLwhere;
+                return token;
+              }
+              break;
+            case 6:
+              if (ident.equals("select")) {
+                //                  System.out.println("select");
+                token = ITerminalSymbols.TokenNameSQLselect;
+                return token;
+              } else if (ident.equals("insert")) {
+                //                  System.out.println("insert");
+                token = ITerminalSymbols.TokenNameSQLinsert;
+                return token;
+              } else if (ident.equals("update")) {
+                //                  System.out.println("update");
+                token = ITerminalSymbols.TokenNameSQLupdate;
+                return token;
+              } else if (ident.equals("values")) {
+                //                System.out.println("values");
+                token = ITerminalSymbols.TokenNameSQLvalues;
+                return token;
+              }
+              break;
+            }
+          }
+          whiteSpace = false;
+          identEnd = -1;
+        } else if (Character.isWhitespace(ch)) {
+        } else {
+          whiteSpace = false;
+        }
+      }
+    } catch (IndexOutOfBoundsException e) {
+    }
+    return ITerminalSymbols.TokenNameEOF;
+  }
+
+  private ICompletionProposal[] internalComputeCompletionProposals(
+      ITextViewer viewer, int offset, int contextOffset) {
+
     IDocument document = viewer.getDocument();
     Object[] identifiers = null;
     IFile file = null;
     IProject project = null;
     if (offset > 0) {
-
       PHPEditor editor = null;
-      AbstractContentOutlinePage outlinePage = null;
-
-      IEditorPart targetEditor = PHPeclipsePlugin.getActiveWorkbenchWindow().getActivePage().getActiveEditor();
-      if (targetEditor != null && (targetEditor instanceof PHPEditor)) {
-        editor = (PHPEditor) targetEditor;
+      if (fEditor != null && (fEditor instanceof PHPEditor)) {
+        editor = (PHPEditor) fEditor;
         file = ((IFileEditorInput) editor.getEditorInput()).getFile();
         project = file.getProject();
-        outlinePage = editor.getfOutlinePage();
-        if (outlinePage instanceof PHPContentOutlinePage) {
-          identifiers = ((PHPContentOutlinePage) outlinePage).getVariables();
-        }
+        //        outlinePage = editor.getfOutlinePage();
+        // TODO: get the identifiers from the new model
+        //        if (outlinePage instanceof PHPContentOutlinePage) {
+        //          identifiers = ((PHPContentOutlinePage) outlinePage).getVariables();
+        //        }
       }
     }
-
-    ContextType phpContextType = ContextTypeRegistry.getInstance().getContextType("php"); //$NON-NLS-1$
-     ((CompilationUnitContextType) phpContextType).setContextParameters(document, offset, 0);
-
+    
+    ContextType phpContextType = ContextTypeRegistry.getInstance()
+        .getContextType("php"); //$NON-NLS-1$
+    ((CompilationUnitContextType) phpContextType).setContextParameters(
+        document, offset, 0);
     PHPUnitContext context = (PHPUnitContext) phpContextType.createContext();
     String prefix = context.getKey();
-
-    int lastSignificantToken = getLastToken(viewer, offset, context);
-    boolean useClassMembers =
-      (lastSignificantToken == ITerminalSymbols.TokenNameMINUS_GREATER) || 
-      (lastSignificantToken == ITerminalSymbols.TokenNamethis) ||
-                 (lastSignificantToken == ITerminalSymbols.TokenNamenew);
+    TableName sqlTable = new TableName();
+    int lastSignificantToken = getLastToken(viewer, offset, context, sqlTable);
+    boolean useClassMembers = (lastSignificantToken == ITerminalSymbols.TokenNameMINUS_GREATER)
+        || (lastSignificantToken == ITerminalSymbols.TokenNameVariable)
+        || (lastSignificantToken == ITerminalSymbols.TokenNamenew)
+        || (lastSignificantToken == ITerminalSymbols.TokenNamethis_PHP_COMPLETION);
     boolean emptyPrefix = prefix == null || prefix.equals("");
-
     if (fTemplateEngine != null) {
       IPHPCompletionProposal[] templateResults = new IPHPCompletionProposal[0];
-
       ICompletionProposal[] results;
       if (!emptyPrefix) {
         fTemplateEngine.reset();
         fTemplateEngine.complete(viewer, offset); //, unit);
         templateResults = fTemplateEngine.getResults();
       }
-
       IPHPCompletionProposal[] identifierResults = new IPHPCompletionProposal[0];
       if ((!useClassMembers) && identifiers != null) {
         IdentifierEngine identifierEngine;
-
-        ContextType contextType = ContextTypeRegistry.getInstance().getContextType("php"); //$NON-NLS-1$
+        ContextType contextType = ContextTypeRegistry.getInstance()
+            .getContextType("php"); //$NON-NLS-1$
         if (contextType != null) {
           identifierEngine = new IdentifierEngine(contextType);
           identifierEngine.complete(viewer, offset, identifiers);
           identifierResults = identifierEngine.getResults();
         }
       }
-
       // declarations stored in file project.index on project level
       IPHPCompletionProposal[] declarationResults = new IPHPCompletionProposal[0];
       if (project != null) {
         DeclarationEngine declarationEngine;
-
-        ContextType contextType = ContextTypeRegistry.getInstance().getContextType("php"); //$NON-NLS-1$
+        ContextType contextType = ContextTypeRegistry.getInstance()
+            .getContextType("php"); //$NON-NLS-1$
         if (contextType != null) {
-          IdentifierIndexManager indexManager = PHPeclipsePlugin.getDefault().getIndexManager(project);
+          IdentifierIndexManager indexManager = PHPeclipsePlugin.getDefault()
+              .getIndexManager(project);
           SortedMap sortedMap = indexManager.getIdentifierMap();
-
-          declarationEngine = new DeclarationEngine(contextType, lastSignificantToken, file);
+          declarationEngine = new DeclarationEngine(project, contextType,
+              lastSignificantToken, file);
           declarationEngine.complete(viewer, offset, sortedMap);
           declarationResults = declarationEngine.getResults();
         }
       }
-
       // built in function names from phpsyntax.xml
       ArrayList syntaxbuffer = PHPSyntaxRdr.getSyntaxData();
       IPHPCompletionProposal[] builtinResults = new IPHPCompletionProposal[0];
       if ((!useClassMembers) && syntaxbuffer != null) {
         BuiltInEngine builtinEngine;
         String proposal;
-
-        ContextType contextType = ContextTypeRegistry.getInstance().getContextType("php"); //$NON-NLS-1$
+        ContextType contextType = ContextTypeRegistry.getInstance()
+            .getContextType("php"); //$NON-NLS-1$
         if (contextType != null) {
           builtinEngine = new BuiltInEngine(contextType);
           builtinEngine.complete(viewer, offset, syntaxbuffer);
           builtinResults = builtinEngine.getResults();
         }
       }
-
+      IPHPCompletionProposal[] sqlResults = new IPHPCompletionProposal[0];
+      if (project != null) {
+        // Get The Database bookmark from the Quantum SQL plugin:
+        BookmarkCollection sqlBookMarks = BookmarkCollection.getInstance();
+        if (sqlBookMarks != null) {
+          String bookmarkString = Util.getMiscProjectsPreferenceValue(project,
+              IPreferenceConstants.PHP_BOOKMARK_DEFAULT);
+          if (bookmarkString != null && !bookmarkString.equals("")) {
+            Bookmark bookmark = sqlBookMarks.find(bookmarkString);
+            ArrayList sqlList = new ArrayList();
+            if (bookmark != null && !bookmark.isConnected()) {
+              new ConnectionUtil().connect(bookmark, null);
+            }
+            if (bookmark != null && bookmark.isConnected()) {
+              try {
+                Connection connection = bookmark.getConnection();
+                DatabaseMetaData metaData = connection.getMetaData();
+
+                if (metaData != null) {
+                  int start = context.getStart();
+                  int end = context.getEnd();
+                  String foundSQLTableName = sqlTable.getTableName();
+                  String tableName;
+                  String columnName;
+                  String prefixWithoutDollar = prefix;
+                  boolean isDollarPrefix = false;
+                  if (prefix.length() > 0 && prefix.charAt(0) == '$') {
+                    prefixWithoutDollar = prefix.substring(1);
+                    isDollarPrefix = true;
+                  }
+                  IRegion region = new Region(start, end - start);
+                  ResultSet set;
+                  if (!isDollarPrefix) {
+                    set = metaData.getTables(null, null, prefixWithoutDollar
+                        + "%", null);
+                    while (set.next()) {
+                      //                  String tempSchema = set.getString("TABLE_SCHEM");
+                      //                  tempSchema = (tempSchema == null) ? "" :
+                      // tempSchema.trim();
+                      tableName = set.getString("TABLE_NAME");
+                      tableName = (tableName == null) ? "" : tableName.trim();
+                      if (tableName != null && tableName.length() > 0) {
+                        sqlList.add(new SQLProposal(tableName, context, region,
+                            viewer, PHPUiImages.get(PHPUiImages.IMG_TABLE)));
+                      }
+                    }
+                    set.close();
+                  }
+                  set = metaData.getColumns(null, null, "%",
+                      prefixWithoutDollar + "%");
+                  SQLProposal sqlProposal;
+                  while (set.next()) {
+                    columnName = set.getString("COLUMN_NAME");
+                    columnName = (columnName == null) ? "" : columnName.trim();
+                    tableName = set.getString("TABLE_NAME");
+                    tableName = (tableName == null) ? "" : tableName.trim();
+                    if (tableName != null && tableName.length() > 0
+                        && columnName != null && columnName.length() > 0) {
+                      if (isDollarPrefix) {
+                        sqlProposal = new SQLProposal(tableName, "$"
+                            + columnName, context, region, viewer, PHPUiImages
+                            .get(PHPUiImages.IMG_COLUMN));
+                      } else {
+                        sqlProposal = new SQLProposal(tableName, columnName,
+                            context, region, viewer, PHPUiImages
+                                .get(PHPUiImages.IMG_COLUMN));
+                      }
+                      if (tableName.equals(foundSQLTableName)) {
+                        sqlProposal.setRelevance(90);
+                      } else if (tableName.indexOf(foundSQLTableName) >= 0) {
+                        sqlProposal.setRelevance(75);
+                      }
+                      sqlList.add(sqlProposal);
+                    }
+                  }
+                  set.close();
+                  sqlResults = new IPHPCompletionProposal[sqlList.size()];
+                  for (int i = 0; i < sqlList.size(); i++) {
+                    sqlResults[i] = (SQLProposal) sqlList.get(i);
+                  }
+                }
+              } catch (NotConnectedException e) {
+                // ignore this - not mission critical
+              } catch (SQLException e) {
+                e.printStackTrace();
+              }
+            }
+          }
+        }
+      }
       // concatenate the result arrays
       IPHPCompletionProposal[] total;
-      total =
-        new IPHPCompletionProposal[templateResults.length
-          + identifierResults.length
-          + builtinResults.length
-          + declarationResults.length];
+      total = new IPHPCompletionProposal[templateResults.length
+          + identifierResults.length + builtinResults.length
+          + declarationResults.length + sqlResults.length];
       System.arraycopy(templateResults, 0, total, 0, templateResults.length);
-      System.arraycopy(identifierResults, 0, total, templateResults.length, identifierResults.length);
-      System.arraycopy(builtinResults, 0, total, templateResults.length + identifierResults.length, builtinResults.length);
-      System.arraycopy(
-        declarationResults,
-        0,
-        total,
-        templateResults.length + identifierResults.length + builtinResults.length,
-        declarationResults.length);
-
+      System.arraycopy(identifierResults, 0, total, templateResults.length,
+          identifierResults.length);
+      System.arraycopy(builtinResults, 0, total, templateResults.length
+          + identifierResults.length, builtinResults.length);
+      System.arraycopy(declarationResults, 0, total, templateResults.length
+          + identifierResults.length + builtinResults.length,
+          declarationResults.length);
+      System.arraycopy(sqlResults, 0, total, templateResults.length
+          + identifierResults.length + builtinResults.length
+          + declarationResults.length, sqlResults.length);
       results = total;
-
       fNumberOfComputedResults = (results == null ? 0 : results.length);
       /*
        * Order here and not in result collector to make sure that the order
-       * applies to all proposals and not just those of the compilation unit. 
+       * applies to all proposals and not just those of the compilation unit.
        */
       return order(results);
     }
@@ -357,9 +714,7 @@ public class PHPCompletionProcessor implements IContentAssistProcessor {
 
   private int guessContextInformationPosition(ITextViewer viewer, int offset) {
     int contextPosition = offset;
-
     IDocument document = viewer.getDocument();
-
     //    try {
     //
     //      PHPCodeReader reader= new PHPCodeReader();
@@ -367,7 +722,7 @@ public class PHPCompletionProcessor implements IContentAssistProcessor {
     //  
     //      int nestingLevel= 0;
     //
-    //      int curr= reader.read();    
+    //      int curr= reader.read();
     //      while (curr != PHPCodeReader.EOF) {
     //
     //        if (')' == (char) curr)
@@ -380,44 +735,54 @@ public class PHPCompletionProcessor implements IContentAssistProcessor {
     //            int start= reader.getOffset();
     //            if (looksLikeMethod(reader))
     //              return start + 1;
-    //          } 
+    //          }
     //        }
     //
-    //        curr= reader.read();          
+    //        curr= reader.read();
     //      }
     //    } catch (IOException e) {
     //    }
-
     return contextPosition;
   }
 
-  /* (non-Javadoc)
-   * Method declared on IContentAssistProcessor
+  /*
+   * (non-Javadoc) Method declared on IContentAssistProcessor
    */
-  //  public IContextInformation[] computeContextInformation(ITextViewer viewer, int documentOffset) {
+  //  public IContextInformation[] computeContextInformation(ITextViewer viewer,
+  // int documentOffset) {
   //    IContextInformation[] result = new IContextInformation[5];
   //    for (int i = 0; i < result.length; i++)
-  //      result[i] = new ContextInformation(MessageFormat.format(PHPEditorMessages.getString("CompletionProcessor.ContextInfo.display.pattern"), new Object[] { new Integer(i), new Integer(documentOffset)}), //$NON-NLS-1$
-  //      MessageFormat.format(PHPEditorMessages.getString("CompletionProcessor.ContextInfo.value.pattern"), new Object[] { new Integer(i), new Integer(documentOffset - 5), new Integer(documentOffset + 5)})); //$NON-NLS-1$
+  //      result[i] = new
+  // ContextInformation(MessageFormat.format(PHPEditorMessages.getString("CompletionProcessor.ContextInfo.display.pattern"),
+  // new Object[] { new Integer(i), new Integer(documentOffset)}),
+  // //$NON-NLS-1$
+  //      MessageFormat.format(PHPEditorMessages.getString("CompletionProcessor.ContextInfo.value.pattern"),
+  // new Object[] { new Integer(i), new Integer(documentOffset - 5), new
+  // Integer(documentOffset + 5)})); //$NON-NLS-1$
   //    return result;
   //  }
   /**
    * @see IContentAssistProcessor#computeContextInformation(ITextViewer, int)
    */
-  public IContextInformation[] computeContextInformation(ITextViewer viewer, int offset) {
-    int contextInformationPosition = guessContextInformationPosition(viewer, offset);
+  public IContextInformation[] computeContextInformation(ITextViewer viewer,
+      int offset) {
+    int contextInformationPosition = guessContextInformationPosition(viewer,
+        offset);
     List result = addContextInformations(viewer, contextInformationPosition);
-    return (IContextInformation[]) result.toArray(new IContextInformation[result.size()]);
+    return (IContextInformation[]) result
+        .toArray(new IContextInformation[result.size()]);
   }
 
   private List addContextInformations(ITextViewer viewer, int offset) {
-    ICompletionProposal[] proposals = internalComputeCompletionProposals(viewer, offset, -1);
-
+    ICompletionProposal[] proposals = internalComputeCompletionProposals(
+        viewer, offset, -1);
     List result = new ArrayList();
     for (int i = 0; i < proposals.length; i++) {
-      IContextInformation contextInformation = proposals[i].getContextInformation();
+      IContextInformation contextInformation = proposals[i]
+          .getContextInformation();
       if (contextInformation != null) {
-        ContextInformationWrapper wrapper = new ContextInformationWrapper(contextInformation);
+        ContextInformationWrapper wrapper = new ContextInformationWrapper(
+            contextInformation);
         wrapper.setContextInformationPosition(offset);
         result.add(wrapper);
       }
@@ -433,33 +798,32 @@ public class PHPCompletionProcessor implements IContentAssistProcessor {
     return proposals;
   }
 
-  /* (non-Javadoc)
-   * Method declared on IContentAssistProcessor
+  /*
+   * (non-Javadoc) Method declared on IContentAssistProcessor
    */
   public char[] getCompletionProposalAutoActivationCharacters() {
     return fProposalAutoActivationSet;
     //    return null; // new char[] { '$' };
   }
 
-  /* (non-Javadoc)
-   * Method declared on IContentAssistProcessor
+  /*
+   * (non-Javadoc) Method declared on IContentAssistProcessor
    */
   public char[] getContextInformationAutoActivationCharacters() {
-    return new char[] {
-    };
+    return new char[] {};
   }
 
-  /* (non-Javadoc)
-   * Method declared on IContentAssistProcessor
+  /*
+   * (non-Javadoc) Method declared on IContentAssistProcessor
    */
   public IContextInformationValidator getContextInformationValidator() {
     return fValidator;
   }
 
-  /* (non-Javadoc)
-   * Method declared on IContentAssistProcessor
+  /*
+   * (non-Javadoc) Method declared on IContentAssistProcessor
    */
   public String getErrorMessage() {
     return null;
   }
-}
+}
\ No newline at end of file